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-history-job_v002 check_cluster_status 2021-04-02T23:00:00+00:00 EmrJobFlowSensor 2021-04-03T00:12:08.583172+00:00 2021-04-03T00:21:11.308434+00:00 0:09:02.725262 12940 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T00:12:06.215087+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-02T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T00:11:58.781140+00:00 2021-04-03T00:12:00.600278+00:00 0:00:01.819138 12939 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T00:11:56.209424+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-02T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T00:11:46.454145+00:00 2021-04-03T00:11:48.331968+00:00 0:00:01.877823 12938 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T00:11:44.200057+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-02T23:00:00+00:00 PythonOperator 2021-04-03T00:11:36.703212+00:00 2021-04-03T00:11:39.650423+00:00 0:00:02.947211 12937 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T00:11:34.193659+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-02T23:00:00+00:00 PythonOperator 2021-04-03T00:11:24.683678+00:00 2021-04-03T00:11:27.394594+00:00 0:00:02.710916 12936 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T00:11:22.152210+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T23:00:00+00:00 TriggerDagRunOperator 2021-04-03T00:11:12.565227+00:00 2021-04-03T00:11:12.986042+00:00 0:00:00.420815 12935 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T00:11:10.128929+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T23:00:00+00:00 TriggerDagRunOperator 2021-04-03T00:11:12.416304+00:00 2021-04-03T00:11:12.982504+00:00 0:00:00.566200 12934 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T00:11:10.128893+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-02T23:05:00+00:00 EmrJobFlowSensor 2021-04-03T00:05:50.022225+00:00 2021-04-03T00:13:52.518200+00:00 0:08:02.495975 12933 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T00:05:47.659270+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-02T23:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T00:05:27.808539+00:00 2021-04-03T00:05:29.535417+00:00 0:00:01.726878 12932 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T00:05:25.550085+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-02T23:05:00+00:00 PythonOperator 2021-04-03T00:05:07.882281+00:00 2021-04-03T00:05:10.553165+00:00 0:00:02.670884 12931 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T00:05:05.531318+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T23:00:00+00:00 EmrJobFlowSensor 2021-04-03T00:00:53.523872+00:00 2021-04-03T00:10:56.494672+00:00 0:10:02.970800 12930 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T00:00:51.142776+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T00:00:29.715731+00:00 2021-04-03T00:00:31.535049+00:00 0:00:01.819318 12929 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T00:00:27.168383+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T23:00:00+00:00 PythonOperator 2021-04-03T00:00:07.871825+00:00 2021-04-03T00:00:10.749458+00:00 0:00:02.877633 12928 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T00:00:05.156050+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-02T22:00:00+00:00 EmrJobFlowSensor 2021-04-02T23:18:36.136163+00:00 2021-04-02T23:27:38.869096+00:00 0:09:02.732933 12926 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T23:18:33.856727+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-02T22:00:00+00:00 EmrJobFlowSensor 2021-04-02T23:18:20.237187+00:00 2021-04-02T23:28:23.149094+00:00 0:10:02.911907 12925 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T23:18:17.842039+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-02T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T23:18:12.041436+00:00 2021-04-02T23:18:13.769485+00:00 0:00:01.728049 12924 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T23:18:09.811570+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-02T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T23:17:58.334691+00:00 2021-04-02T23:18:00.204922+00:00 0:00:01.870231 12923 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T23:17:55.863774+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-02T22:00:00+00:00 PythonOperator 2021-04-02T23:17:51.998185+00:00 2021-04-02T23:17:54.704764+00:00 0:00:02.706579 12922 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T23:17:49.793123+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-02T22:00:00+00:00 PythonOperator 2021-04-02T23:17:38.212733+00:00 2021-04-02T23:17:41.216847+00:00 0:00:03.004114 12921 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T23:17:35.761869+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T22:00:00+00:00 TriggerDagRunOperator 2021-04-02T23:17:30.234485+00:00 2021-04-02T23:17:30.837058+00:00 0:00:00.602573 12920 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T23:17:27.678290+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T22:00:00+00:00 TriggerDagRunOperator 2021-04-02T23:17:29.977521+00:00 2021-04-02T23:17:30.443109+00:00 0:00:00.465588 12919 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T23:17:27.678257+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-02T22:05:00+00:00 EmrJobFlowSensor 2021-04-02T23:06:02.665155+00:00 2021-04-02T23:15:05.450652+00:00 0:09:02.785497 12918 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T23:06:00.414742+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-02T22:05:00+00:00 EmrCreateJobFlowOperator 2021-04-02T23:05:40.611398+00:00 2021-04-02T23:05:42.369361+00:00 0:00:01.757963 12917 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T23:05:38.390815+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-02T22:05:00+00:00 PythonOperator 2021-04-02T23:05:18.959560+00:00 2021-04-02T23:05:21.682872+00:00 0:00:02.723312 12916 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T23:05:16.386844+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T22:00:00+00:00 EmrJobFlowSensor 2021-04-02T23:01:04.807316+00:00 2021-04-02T23:17:08.566611+00:00 0:16:03.759295 12915 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T23:01:02.142996+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T23:00:28.181302+00:00 2021-04-02T23:00:29.928177+00:00 0:00:01.746875 12914 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T23:00:25.993474+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T22:00:00+00:00 PythonOperator 2021-04-02T23:00:06.345058+00:00 2021-04-02T23:00:09.206301+00:00 0:00:02.861243 12913 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T23:00:03.948883+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-02T21:00:00+00:00 EmrJobFlowSensor 2021-04-02T22:11:04.696263+00:00 2021-04-02T22:20:07.366819+00:00 0:09:02.670556 12911 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T22:11:02.547376+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-02T21:00:00+00:00 EmrJobFlowSensor 2021-04-02T22:11:01.141906+00:00 2021-04-02T22:20:03.845390+00:00 0:09:02.703484 12910 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T22:10:58.651945+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-02T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T22:10:43.337311+00:00 2021-04-02T22:10:45.077111+00:00 0:00:01.739800 12909 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T22:10:40.523646+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-02T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T22:10:40.906628+00:00 2021-04-02T22:10:42.961632+00:00 0:00:02.055004 12908 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T22:10:38.526492+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-02T21:00:00+00:00 PythonOperator 2021-04-02T22:10:21.385712+00:00 2021-04-02T22:10:24.289843+00:00 0:00:02.904131 12907 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T22:10:18.515321+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-02T21:00:00+00:00 PythonOperator 2021-04-02T22:10:19.048417+00:00 2021-04-02T22:10:22.144482+00:00 0:00:03.096065 12906 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T22:10:16.562915+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T21:00:00+00:00 TriggerDagRunOperator 2021-04-02T22:09:57.037542+00:00 2021-04-02T22:09:57.463003+00:00 0:00:00.425461 12905 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T22:09:54.540859+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T21:00:00+00:00 TriggerDagRunOperator 2021-04-02T22:09:57.019898+00:00 2021-04-02T22:09:57.583202+00:00 0:00:00.563304 12904 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T22:09:54.540902+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-02T21:05:00+00:00 EmrJobFlowSensor 2021-04-02T22:05:58.600950+00:00 2021-04-02T22:14:01.073133+00:00 0:08:02.472183 12903 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T22:05:56.258355+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-02T21:05:00+00:00 EmrCreateJobFlowOperator 2021-04-02T22:05:36.279977+00:00 2021-04-02T22:05:37.932299+00:00 0:00:01.652322 12902 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T22:05:34.145360+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-02T21:05:00+00:00 PythonOperator 2021-04-02T22:05:16.255744+00:00 2021-04-02T22:05:19.021242+00:00 0:00:02.765498 12901 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T22:05:14.110093+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T21:00:00+00:00 EmrJobFlowSensor 2021-04-02T22:00:50.087422+00:00 2021-04-02T22:09:52.871288+00:00 0:09:02.783866 12900 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T22:00:47.633296+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T22:00:27.968615+00:00 2021-04-02T22:00:29.793497+00:00 0:00:01.824882 12899 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T22:00:25.616597+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T21:00:00+00:00 PythonOperator 2021-04-02T22:00:08.100707+00:00 2021-04-02T22:00:10.948328+00:00 0:00:02.847621 12898 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T22:00:05.595839+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-02T20:00:00+00:00 EmrJobFlowSensor 2021-04-02T21:11:10.055776+00:00 2021-04-02T21:20:12.592669+00:00 0:09:02.536893 12896 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T21:11:07.410252+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-02T20:00:00+00:00 EmrJobFlowSensor 2021-04-02T21:11:07.635207+00:00 2021-04-02T21:20:10.669337+00:00 0:09:03.034130 12895 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T21:11:05.407344+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-02T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T21:10:45.923734+00:00 2021-04-02T21:10:47.606474+00:00 0:00:01.682740 12894 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T21:10:43.471657+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-02T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T21:10:43.935795+00:00 2021-04-02T21:10:45.785631+00:00 0:00:01.849836 12893 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T21:10:41.459336+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-02T20:00:00+00:00 PythonOperator 2021-04-02T21:10:26.001177+00:00 2021-04-02T21:10:28.957798+00:00 0:00:02.956621 12892 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T21:10:23.371449+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-02T20:00:00+00:00 PythonOperator 2021-04-02T21:10:21.841820+00:00 2021-04-02T21:10:24.707334+00:00 0:00:02.865514 12891 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T21:10:19.349416+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T20:00:00+00:00 TriggerDagRunOperator 2021-04-02T21:10:15.730954+00:00 2021-04-02T21:10:16.243981+00:00 0:00:00.513027 12890 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T21:10:13.346431+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T20:00:00+00:00 TriggerDagRunOperator 2021-04-02T21:10:15.616795+00:00 2021-04-02T21:10:16.025114+00:00 0:00:00.408319 12889 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T21:10:13.346463+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-02T20:05:00+00:00 EmrJobFlowSensor 2021-04-02T21:05:49.082530+00:00 2021-04-02T21:14:51.616368+00:00 0:09:02.533838 12888 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T21:05:46.854538+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-02T20:05:00+00:00 EmrCreateJobFlowOperator 2021-04-02T21:05:28.991093+00:00 2021-04-02T21:05:30.661210+00:00 0:00:01.670117 12887 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T21:05:26.690158+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-02T20:05:00+00:00 PythonOperator 2021-04-02T21:05:06.869119+00:00 2021-04-02T21:05:09.606437+00:00 0:00:02.737318 12886 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T21:05:04.666056+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T20:00:00+00:00 EmrJobFlowSensor 2021-04-02T21:00:48.429424+00:00 2021-04-02T21:09:51.207973+00:00 0:09:02.778549 12885 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T21:00:46.123217+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T21:00:26.550735+00:00 2021-04-02T21:00:28.294207+00:00 0:00:01.743472 12884 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T21:00:24.161031+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T20:00:00+00:00 PythonOperator 2021-04-02T21:00:04.463371+00:00 2021-04-02T21:00:07.288605+00:00 0:00:02.825234 12883 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T21:00:02.090151+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-02T19:00:00+00:00 EmrJobFlowSensor 2021-04-02T20:11:12.441951+00:00 2021-04-02T20:21:15.266899+00:00 0:10:02.824948 12881 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T20:11:10.223277+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-02T19:00:00+00:00 EmrJobFlowSensor 2021-04-02T20:11:08.504565+00:00 2021-04-02T20:22:11.562931+00:00 0:11:03.058366 12880 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T20:11:06.222898+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-02T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T20:10:50.520392+00:00 2021-04-02T20:10:52.217903+00:00 0:00:01.697511 12879 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T20:10:48.266371+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-02T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T20:10:46.541188+00:00 2021-04-02T20:10:48.243788+00:00 0:00:01.702600 12878 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T20:10:44.259337+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-02T19:00:00+00:00 PythonOperator 2021-04-02T20:10:28.910498+00:00 2021-04-02T20:10:31.706988+00:00 0:00:02.796490 12877 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T20:10:26.191902+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-02T19:00:00+00:00 PythonOperator 2021-04-02T20:10:26.441740+00:00 2021-04-02T20:10:29.899109+00:00 0:00:03.457369 12876 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T20:10:24.144130+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T19:00:00+00:00 TriggerDagRunOperator 2021-04-02T20:10:12.460962+00:00 2021-04-02T20:10:12.903318+00:00 0:00:00.442356 12875 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T20:10:10.124778+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T19:00:00+00:00 TriggerDagRunOperator 2021-04-02T20:10:12.421947+00:00 2021-04-02T20:10:13.004360+00:00 0:00:00.582413 12874 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T20:10:10.124746+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-02T19:05:00+00:00 EmrJobFlowSensor 2021-04-02T20:05:56.193306+00:00 2021-04-02T20:13:58.580542+00:00 0:08:02.387236 12873 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T20:05:53.861780+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-02T19:05:00+00:00 EmrCreateJobFlowOperator 2021-04-02T20:05:34.107292+00:00 2021-04-02T20:05:35.740996+00:00 0:00:01.633704 12872 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T20:05:31.860513+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-02T19:05:00+00:00 PythonOperator 2021-04-02T20:05:12.203512+00:00 2021-04-02T20:05:14.997672+00:00 0:00:02.794160 12871 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T20:05:09.852482+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T19:00:00+00:00 EmrJobFlowSensor 2021-04-02T20:01:01.711435+00:00 2021-04-02T20:10:04.489489+00:00 0:09:02.778054 12870 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T20:00:59.364463+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T20:00:37.611124+00:00 2021-04-02T20:00:39.312916+00:00 0:00:01.701792 12869 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T20:00:35.369649+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T19:00:00+00:00 PythonOperator 2021-04-02T20:00:15.725665+00:00 2021-04-02T20:00:18.592541+00:00 0:00:02.866876 12868 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T20:00:13.321533+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-02T18:00:00+00:00 EmrJobFlowSensor 2021-04-02T19:19:56.316220+00:00 2021-04-02T19:29:59.290538+00:00 0:10:02.974318 12866 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T19:19:54.111225+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-02T18:00:00+00:00 EmrJobFlowSensor 2021-04-02T19:19:54.339150+00:00 2021-04-02T19:30:57.234148+00:00 0:11:02.894998 12865 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T19:19:52.100815+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-02T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T19:19:34.990351+00:00 2021-04-02T19:19:36.739139+00:00 0:00:01.748788 12864 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T19:19:32.143530+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-02T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T19:19:32.599953+00:00 2021-04-02T19:19:34.580360+00:00 0:00:01.980407 12863 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T19:19:30.152621+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-02T18:00:00+00:00 PythonOperator 2021-04-02T19:19:13.370786+00:00 2021-04-02T19:19:16.369191+00:00 0:00:02.998405 12862 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T19:19:10.070208+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-02T18:00:00+00:00 PythonOperator 2021-04-02T19:19:11.109316+00:00 2021-04-02T19:19:14.249706+00:00 0:00:03.140390 12861 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T19:19:08.067140+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T18:00:00+00:00 TriggerDagRunOperator 2021-04-02T19:18:58.873203+00:00 2021-04-02T19:18:59.585849+00:00 0:00:00.712646 12860 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T19:18:56.062195+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T18:00:00+00:00 TriggerDagRunOperator 2021-04-02T19:18:58.431977+00:00 2021-04-02T19:18:58.995048+00:00 0:00:00.563071 12859 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T19:18:56.062162+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-02T18:05:00+00:00 EmrJobFlowSensor 2021-04-02T19:05:48.999452+00:00 2021-04-02T19:14:51.641549+00:00 0:09:02.642097 12858 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T19:05:46.752308+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-02T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-02T19:05:26.791816+00:00 2021-04-02T19:05:28.426437+00:00 0:00:01.634621 12857 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T19:05:24.622129+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-02T18:05:00+00:00 PythonOperator 2021-04-02T19:05:06.887525+00:00 2021-04-02T19:05:09.664111+00:00 0:00:02.776586 12856 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T19:05:04.605516+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T18:00:00+00:00 EmrJobFlowSensor 2021-04-02T19:00:48.297950+00:00 2021-04-02T19:18:52.069667+00:00 0:18:03.771717 12855 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T19:00:46.143603+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T19:00:26.397648+00:00 2021-04-02T19:00:28.086356+00:00 0:00:01.688708 12854 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T19:00:24.131313+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T18:00:00+00:00 PythonOperator 2021-04-02T19:00:04.624755+00:00 2021-04-02T19:00:07.376553+00:00 0:00:02.751798 12853 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T19:00:02.100097+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-02T17:00:00+00:00 EmrJobFlowSensor 2021-04-02T18:12:37.348928+00:00 2021-04-02T18:22:40.170935+00:00 0:10:02.822007 12851 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T18:12:35.187215+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-02T17:00:00+00:00 EmrJobFlowSensor 2021-04-02T18:12:31.570615+00:00 2021-04-02T18:21:34.352236+00:00 0:09:02.781621 12850 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T18:12:29.244126+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-02T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T18:12:13.367319+00:00 2021-04-02T18:12:15.226331+00:00 0:00:01.859012 12849 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T18:12:11.091553+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-02T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T18:12:09.515548+00:00 2021-04-02T18:12:11.255636+00:00 0:00:01.740088 12848 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T18:12:07.157848+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-02T17:00:00+00:00 PythonOperator 2021-04-02T18:11:53.197037+00:00 2021-04-02T18:11:56.103973+00:00 0:00:02.906936 12847 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T18:11:51.036384+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-02T17:00:00+00:00 PythonOperator 2021-04-02T18:11:47.282708+00:00 2021-04-02T18:11:50.145029+00:00 0:00:02.862321 12846 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T18:11:45.077476+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T17:00:00+00:00 TriggerDagRunOperator 2021-04-02T18:11:29.483618+00:00 2021-04-02T18:11:30.024138+00:00 0:00:00.540520 12845 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T18:11:27.010492+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T17:00:00+00:00 TriggerDagRunOperator 2021-04-02T18:11:29.205336+00:00 2021-04-02T18:11:29.683369+00:00 0:00:00.478033 12844 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T18:11:27.010519+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-02T17:05:00+00:00 EmrJobFlowSensor 2021-04-02T18:05:54.904096+00:00 2021-04-02T18:14:57.492399+00:00 0:09:02.588303 12843 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T18:05:52.543836+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-02T17:05:00+00:00 EmrCreateJobFlowOperator 2021-04-02T18:05:35.127867+00:00 2021-04-02T18:05:36.842812+00:00 0:00:01.714945 12842 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T18:05:32.491719+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-02T17:05:00+00:00 PythonOperator 2021-04-02T18:05:10.888203+00:00 2021-04-02T18:05:13.589710+00:00 0:00:02.701507 12841 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T18:05:08.490464+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T17:00:00+00:00 EmrJobFlowSensor 2021-04-02T18:01:04.536764+00:00 2021-04-02T18:11:07.389877+00:00 0:10:02.853113 12840 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T18:01:02.185583+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T18:00:42.447669+00:00 2021-04-02T18:00:44.264936+00:00 0:00:01.817267 12839 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T18:00:40.143616+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T17:00:00+00:00 PythonOperator 2021-04-02T18:00:22.660492+00:00 2021-04-02T18:00:25.532310+00:00 0:00:02.871818 12838 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T18:00:20.035276+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-02T16:00:00+00:00 EmrJobFlowSensor 2021-04-02T17:12:48.816612+00:00 2021-04-02T17:21:51.488628+00:00 0:09:02.672016 12836 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T17:12:46.640811+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-02T16:00:00+00:00 EmrJobFlowSensor 2021-04-02T17:12:46.910228+00:00 2021-04-02T17:21:49.635253+00:00 0:09:02.725025 12835 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T17:12:44.641409+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-02T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T17:12:26.856290+00:00 2021-04-02T17:12:28.620948+00:00 0:00:01.764658 12834 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T17:12:24.622378+00:00 2 default_pool