Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T20:00:00+00:00 TriggerDagRunOperator 2021-04-08T21:11:03.691553+00:00 2021-04-08T21:11:04.155429+00:00 0:00:00.463876 15052 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T21:11:01.510717+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-08T20:05:00+00:00 EmrJobFlowSensor 2021-04-08T21:05:57.392051+00:00 2021-04-08T21:14:59.984976+00:00 0:09:02.592925 15051 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T21:05:55.065331+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-08T20:05:00+00:00 EmrCreateJobFlowOperator 2021-04-08T21:05:37.203130+00:00 2021-04-08T21:05:38.957735+00:00 0:00:01.754605 15050 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T21:05:34.961483+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-08T20:05:00+00:00 PythonOperator 2021-04-08T21:05:15.169948+00:00 2021-04-08T21:05:17.942783+00:00 0:00:02.772835 15049 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T21:05:12.940774+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T20:00:00+00:00 EmrJobFlowSensor 2021-04-08T21:00:48.890561+00:00 2021-04-08T21:10:51.829047+00:00 0:10:02.938486 15048 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T21:00:46.510476+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T21:00:26.940330+00:00 2021-04-08T21:00:28.839687+00:00 0:00:01.899357 15047 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T21:00:24.433091+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T20:00:00+00:00 PythonOperator 2021-04-08T21:00:05.146768+00:00 2021-04-08T21:00:08.055582+00:00 0:00:02.908814 15046 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T21:00:02.426179+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-08T19:00:00+00:00 EmrJobFlowSensor 2021-04-08T20:11:31.992736+00:00 2021-04-08T20:30:36.059756+00:00 0:19:04.067020 15044 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T20:11:29.547097+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-08T19:00:00+00:00 EmrJobFlowSensor 2021-04-08T20:11:15.715759+00:00 2021-04-08T20:20:18.405673+00:00 0:09:02.689914 15043 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T20:11:13.373015+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-08T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T20:11:09.699063+00:00 2021-04-08T20:11:11.441396+00:00 0:00:01.742333 15042 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T20:11:07.350260+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-08T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T20:10:53.630165+00:00 2021-04-08T20:10:55.526900+00:00 0:00:01.896735 15041 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T20:10:51.277678+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-08T19:00:00+00:00 PythonOperator 2021-04-08T20:10:47.513356+00:00 2021-04-08T20:10:50.226005+00:00 0:00:02.712649 15040 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T20:10:45.273307+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-08T19:00:00+00:00 PythonOperator 2021-04-08T20:10:33.685766+00:00 2021-04-08T20:10:36.782822+00:00 0:00:03.097056 15039 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T20:10:31.260933+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T19:00:00+00:00 TriggerDagRunOperator 2021-04-08T20:10:23.817782+00:00 2021-04-08T20:10:24.480121+00:00 0:00:00.662339 15038 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T20:10:21.252854+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T19:00:00+00:00 TriggerDagRunOperator 2021-04-08T20:10:23.682369+00:00 2021-04-08T20:10:24.269471+00:00 0:00:00.587102 15037 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T20:10:21.252823+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-08T19:05:00+00:00 EmrJobFlowSensor 2021-04-08T20:05:54.980248+00:00 2021-04-08T20:14:57.614189+00:00 0:09:02.633941 15036 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T20:05:52.766384+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-08T19:05:00+00:00 EmrCreateJobFlowOperator 2021-04-08T20:05:34.888056+00:00 2021-04-08T20:05:36.519157+00:00 0:00:01.631101 15035 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T20:05:32.691417+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-08T19:05:00+00:00 PythonOperator 2021-04-08T20:05:12.992943+00:00 2021-04-08T20:05:15.692890+00:00 0:00:02.699947 15034 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T20:05:10.618467+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T19:00:00+00:00 EmrJobFlowSensor 2021-04-08T20:00:56.302565+00:00 2021-04-08T20:09:59.043447+00:00 0:09:02.740882 15033 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T20:00:54.121402+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T20:00:34.467576+00:00 2021-04-08T20:00:36.370249+00:00 0:00:01.902673 15032 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T20:00:32.083650+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T19:00:00+00:00 PythonOperator 2021-04-08T20:00:12.309512+00:00 2021-04-08T20:00:15.068804+00:00 0:00:02.759292 15031 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T20:00:10.024343+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-08T18:00:00+00:00 EmrJobFlowSensor 2021-04-08T19:10:12.202465+00:00 2021-04-08T19:19:14.952598+00:00 0:09:02.750133 15029 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T19:10:09.960287+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-08T18:00:00+00:00 EmrJobFlowSensor 2021-04-08T19:10:04.383144+00:00 2021-04-08T19:19:07.149488+00:00 0:09:02.766344 15028 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T19:10:01.909487+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-08T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T19:09:50.295050+00:00 2021-04-08T19:09:51.959922+00:00 0:00:01.664872 15027 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T19:09:47.954136+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-08T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T19:09:42.102027+00:00 2021-04-08T19:09:43.935599+00:00 0:00:01.833572 15026 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T19:09:39.893769+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-08T18:00:00+00:00 PythonOperator 2021-04-08T19:09:30.696845+00:00 2021-04-08T19:09:33.642399+00:00 0:00:02.945554 15025 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T19:09:28.053220+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-08T18:00:00+00:00 PythonOperator 2021-04-08T19:09:22.049957+00:00 2021-04-08T19:09:24.767069+00:00 0:00:02.717112 15024 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T19:09:19.853457+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T18:00:00+00:00 TriggerDagRunOperator 2021-04-08T19:09:08.409654+00:00 2021-04-08T19:09:08.901200+00:00 0:00:00.491546 15023 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T19:09:05.843306+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T18:00:00+00:00 TriggerDagRunOperator 2021-04-08T19:09:08.120125+00:00 2021-04-08T19:09:08.671897+00:00 0:00:00.551772 15022 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T19:09:05.843338+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-08T18:05:00+00:00 EmrJobFlowSensor 2021-04-08T19:05:54.160633+00:00 2021-04-08T19:13:56.729680+00:00 0:08:02.569047 15021 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T19:05:51.668012+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-08T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-08T19:05:31.873412+00:00 2021-04-08T19:05:33.594120+00:00 0:00:01.720708 15020 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T19:05:29.587593+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-08T18:05:00+00:00 PythonOperator 2021-04-08T19:05:09.670072+00:00 2021-04-08T19:05:12.421316+00:00 0:00:02.751244 15019 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T19:05:07.524589+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T18:00:00+00:00 EmrJobFlowSensor 2021-04-08T19:00:55.273406+00:00 2021-04-08T19:08:57.684991+00:00 0:08:02.411585 15018 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T19:00:53.102241+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T19:00:35.240886+00:00 2021-04-08T19:00:36.953161+00:00 0:00:01.712275 15017 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T19:00:33.084873+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T18:00:00+00:00 PythonOperator 2021-04-08T19:00:11.710050+00:00 2021-04-08T19:00:14.458367+00:00 0:00:02.748317 15016 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T19:00:09.074647+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-08T17:00:00+00:00 EmrJobFlowSensor 2021-04-08T18:11:30.611689+00:00 2021-04-08T18:21:33.557566+00:00 0:10:02.945877 15014 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T18:11:28.060474+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-08T17:00:00+00:00 EmrJobFlowSensor 2021-04-08T18:11:16.210004+00:00 2021-04-08T18:21:19.070637+00:00 0:10:02.860633 15013 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T18:11:13.943973+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-08T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T18:11:06.207443+00:00 2021-04-08T18:11:08.066644+00:00 0:00:01.859201 15012 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T18:11:03.906868+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-08T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T18:10:52.191829+00:00 2021-04-08T18:10:54.108023+00:00 0:00:01.916194 15011 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T18:10:49.893220+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-08T17:00:00+00:00 PythonOperator 2021-04-08T18:10:44.289974+00:00 2021-04-08T18:10:47.314179+00:00 0:00:03.024205 15010 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T18:10:41.885575+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-08T17:00:00+00:00 PythonOperator 2021-04-08T18:10:28.071468+00:00 2021-04-08T18:10:30.826938+00:00 0:00:02.755470 15009 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T18:10:25.855615+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T17:00:00+00:00 TriggerDagRunOperator 2021-04-08T18:10:20.340514+00:00 2021-04-08T18:10:20.909886+00:00 0:00:00.569372 15008 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T18:10:17.847625+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T17:00:00+00:00 TriggerDagRunOperator 2021-04-08T18:10:20.197331+00:00 2021-04-08T18:10:20.646413+00:00 0:00:00.449082 15007 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T18:10:17.847661+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-08T17:05:00+00:00 EmrJobFlowSensor 2021-04-08T18:05:59.674594+00:00 2021-04-08T18:15:02.494910+00:00 0:09:02.820316 15006 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T18:05:57.460426+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-08T17:05:00+00:00 EmrCreateJobFlowOperator 2021-04-08T18:05:37.801110+00:00 2021-04-08T18:05:39.649060+00:00 0:00:01.847950 15005 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T18:05:35.441963+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-08T17:05:00+00:00 PythonOperator 2021-04-08T18:05:15.695784+00:00 2021-04-08T18:05:18.358613+00:00 0:00:02.662829 15004 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T18:05:13.362933+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T17:00:00+00:00 EmrJobFlowSensor 2021-04-08T18:00:55.158755+00:00 2021-04-08T18:09:57.764573+00:00 0:09:02.605818 15003 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T18:00:52.790752+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T18:00:35.259976+00:00 2021-04-08T18:00:37.144305+00:00 0:00:01.884329 15002 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T18:00:32.770793+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T17:00:00+00:00 PythonOperator 2021-04-08T18:00:13.047039+00:00 2021-04-08T18:00:15.925923+00:00 0:00:02.878884 15001 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T18:00:10.690980+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-08T16:00:00+00:00 EmrJobFlowSensor 2021-04-08T17:13:52.236158+00:00 2021-04-08T17:21:54.897184+00:00 0:08:02.661026 15000 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T17:13:49.963001+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-08T16:00:00+00:00 EmrJobFlowSensor 2021-04-08T17:12:54.572370+00:00 2021-04-08T17:21:57.158979+00:00 0:09:02.586609 14999 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T17:12:51.904625+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-08T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T17:12:07.649681+00:00 2021-04-08T17:12:09.370072+00:00 0:00:01.720391 14997 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T17:12:05.435747+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-08T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T17:12:05.743457+00:00 2021-04-08T17:12:07.568327+00:00 0:00:01.824870 14996 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T17:12:03.432463+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-08T16:00:00+00:00 PythonOperator 2021-04-08T17:11:46.350692+00:00 2021-04-08T17:11:49.371695+00:00 0:00:03.021003 14995 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T17:11:43.473173+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-08T16:00:00+00:00 PythonOperator 2021-04-08T17:11:43.953603+00:00 2021-04-08T17:11:47.058062+00:00 0:00:03.104459 14994 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T17:11:41.478507+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T16:00:00+00:00 TriggerDagRunOperator 2021-04-08T17:11:28.179677+00:00 2021-04-08T17:11:28.789058+00:00 0:00:00.609381 14993 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T17:11:25.456325+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T16:00:00+00:00 TriggerDagRunOperator 2021-04-08T17:11:27.994013+00:00 2021-04-08T17:11:28.409249+00:00 0:00:00.415236 14992 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T17:11:25.456285+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-08T16:05:00+00:00 EmrJobFlowSensor 2021-04-08T17:06:05.041761+00:00 2021-04-08T17:14:07.492882+00:00 0:08:02.451121 14991 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T17:06:02.798053+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-08T16:05:00+00:00 EmrCreateJobFlowOperator 2021-04-08T17:05:41.129442+00:00 2021-04-08T17:05:42.813500+00:00 0:00:01.684058 14990 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T17:05:38.844004+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-08T16:05:00+00:00 PythonOperator 2021-04-08T17:05:21.044018+00:00 2021-04-08T17:05:23.745939+00:00 0:00:02.701921 14989 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T17:05:18.756083+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T16:00:00+00:00 EmrJobFlowSensor 2021-04-08T17:01:06.620045+00:00 2021-04-08T17:11:09.510874+00:00 0:10:02.890829 14988 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T17:01:04.349203+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T17:00:46.581304+00:00 2021-04-08T17:00:48.402438+00:00 0:00:01.821134 14987 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T17:00:44.245087+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T16:00:00+00:00 PythonOperator 2021-04-08T17:00:24.545225+00:00 2021-04-08T17:00:27.258743+00:00 0:00:02.713518 14986 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T17:00:22.227640+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-08T15:00:00+00:00 EmrJobFlowSensor 2021-04-08T16:13:09.678669+00:00 2021-04-08T16:33:13.743889+00:00 0:20:04.065220 14985 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T16:13:07.404191+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-08T15:00:00+00:00 EmrJobFlowSensor 2021-04-08T16:13:05.725745+00:00 2021-04-08T16:25:08.890307+00:00 0:12:03.164562 14984 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T16:13:03.460031+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-08T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T16:12:47.664820+00:00 2021-04-08T16:12:49.552581+00:00 0:00:01.887761 14983 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T16:12:45.386931+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-08T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T16:12:45.664345+00:00 2021-04-08T16:12:47.517185+00:00 0:00:01.852840 14982 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T16:12:43.388548+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-08T15:00:00+00:00 PythonOperator 2021-04-08T16:12:27.550519+00:00 2021-04-08T16:12:30.314754+00:00 0:00:02.764235 14981 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T16:12:25.366587+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-08T15:00:00+00:00 PythonOperator 2021-04-08T16:12:23.918376+00:00 2021-04-08T16:12:27.045221+00:00 0:00:03.126845 14980 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T16:12:21.366108+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T15:00:00+00:00 TriggerDagRunOperator 2021-04-08T16:12:18.354042+00:00 2021-04-08T16:12:18.881381+00:00 0:00:00.527339 14979 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T16:12:15.363733+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T15:00:00+00:00 TriggerDagRunOperator 2021-04-08T16:12:18.150590+00:00 2021-04-08T16:12:18.647034+00:00 0:00:00.496444 14978 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T16:12:15.363696+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-08T15:05:00+00:00 EmrJobFlowSensor 2021-04-08T16:05:58.694538+00:00 2021-04-08T16:15:01.323044+00:00 0:09:02.628506 14976 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T16:05:56.347964+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-08T15:05:00+00:00 EmrCreateJobFlowOperator 2021-04-08T16:05:38.412569+00:00 2021-04-08T16:05:40.062702+00:00 0:00:01.650133 14975 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T16:05:36.285042+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-08T15:05:00+00:00 PythonOperator 2021-04-08T16:05:16.461486+00:00 2021-04-08T16:05:19.149545+00:00 0:00:02.688059 14974 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T16:05:14.265705+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T15:00:00+00:00 EmrJobFlowSensor 2021-04-08T16:01:04.020358+00:00 2021-04-08T16:11:06.817368+00:00 0:10:02.797010 14973 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T16:01:01.854485+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T16:00:42.183640+00:00 2021-04-08T16:00:43.998679+00:00 0:00:01.815039 14972 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T16:00:39.880816+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T15:00:00+00:00 PythonOperator 2021-04-08T16:00:20.211057+00:00 2021-04-08T16:00:22.986362+00:00 0:00:02.775305 14971 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T16:00:17.867677+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-08T14:00:00+00:00 EmrJobFlowSensor 2021-04-08T15:12:19.061822+00:00 2021-04-08T15:22:21.958518+00:00 0:10:02.896696 14970 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T15:12:16.739546+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-08T14:00:00+00:00 EmrJobFlowSensor 2021-04-08T15:12:06.927936+00:00 2021-04-08T15:21:09.662658+00:00 0:09:02.734722 14969 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T15:12:04.725990+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-08T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T15:11:57.450310+00:00 2021-04-08T15:11:59.164315+00:00 0:00:01.714005 14968 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T15:11:54.720424+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-08T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T15:11:45.264104+00:00 2021-04-08T15:11:46.916468+00:00 0:00:01.652364 14967 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T15:11:42.769355+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-08T14:00:00+00:00 PythonOperator 2021-04-08T15:11:35.146965+00:00 2021-04-08T15:11:38.119410+00:00 0:00:02.972445 14966 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T15:11:32.762969+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-08T14:00:00+00:00 PythonOperator 2021-04-08T15:11:23.231011+00:00 2021-04-08T15:11:26.189637+00:00 0:00:02.958626 14965 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T15:11:20.763145+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T14:00:00+00:00 TriggerDagRunOperator 2021-04-08T15:11:15.720664+00:00 2021-04-08T15:11:16.265585+00:00 0:00:00.544921 14964 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T15:11:12.749368+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T14:00:00+00:00 TriggerDagRunOperator 2021-04-08T15:11:15.682374+00:00 2021-04-08T15:11:16.083488+00:00 0:00:00.401114 14963 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T15:11:12.749411+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-08T14:05:00+00:00 EmrJobFlowSensor 2021-04-08T15:05:56.792345+00:00 2021-04-08T15:14:59.335607+00:00 0:09:02.543262 14961 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T15:05:54.561146+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-08T14:05:00+00:00 EmrCreateJobFlowOperator 2021-04-08T15:05:36.715326+00:00 2021-04-08T15:05:38.450704+00:00 0:00:01.735378 14960 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T15:05:34.541600+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-08T14:05:00+00:00 PythonOperator 2021-04-08T15:05:14.790907+00:00 2021-04-08T15:05:17.605013+00:00 0:00:02.814106 14959 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T15:05:12.519438+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T14:00:00+00:00 EmrJobFlowSensor 2021-04-08T15:01:06.318607+00:00 2021-04-08T15:11:09.187705+00:00 0:10:02.869098 14958 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T15:01:04.143651+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T15:00:38.531829+00:00 2021-04-08T15:00:40.258174+00:00 0:00:01.726345 14957 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T15:00:36.174302+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T14:00:00+00:00 PythonOperator 2021-04-08T15:00:18.405622+00:00 2021-04-08T15:00:21.182009+00:00 0:00:02.776387 14956 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T15:00:16.144221+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-08T13:00:00+00:00 EmrJobFlowSensor 2021-04-08T14:19:36.527308+00:00 2021-04-08T14:28:39.054579+00:00 0:09:02.527271 14955 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T14:19:34.302866+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-08T13:00:00+00:00 EmrJobFlowSensor 2021-04-08T14:19:20.517053+00:00 2021-04-08T14:27:23.079315+00:00 0:08:02.562262 14954 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T14:19:18.297961+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-08T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T14:19:14.632689+00:00 2021-04-08T14:19:16.352847+00:00 0:00:01.720158 14953 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T14:19:12.358413+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-08T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T14:18:58.818354+00:00 2021-04-08T14:19:00.531593+00:00 0:00:01.713239 14952 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T14:18:56.350164+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-08T13:00:00+00:00 PythonOperator 2021-04-08T14:18:52.418465+00:00 2021-04-08T14:18:55.332692+00:00 0:00:02.914227 14951 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T14:18:50.238786+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-08T13:00:00+00:00 PythonOperator 2021-04-08T14:18:38.583952+00:00 2021-04-08T14:18:41.338023+00:00 0:00:02.754071 14950 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T14:18:36.229421+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T13:00:00+00:00 TriggerDagRunOperator 2021-04-08T14:18:28.961170+00:00 2021-04-08T14:18:29.475522+00:00 0:00:00.514352 14949 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T14:18:26.218409+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T13:00:00+00:00 TriggerDagRunOperator 2021-04-08T14:18:28.642508+00:00 2021-04-08T14:18:29.077629+00:00 0:00:00.435121 14948 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T14:18:26.218442+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-08T13:05:00+00:00 EmrJobFlowSensor 2021-04-08T14:08:25.018632+00:00 2021-04-08T14:17:27.647117+00:00 0:09:02.628485 14947 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T14:08:22.823059+00:00 2 default_pool