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 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
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-02T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T17:12:24.785835+00:00 2021-04-02T17:12:26.470760+00:00 0:00:01.684925 12833 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T17:12:22.621639+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-02T16:00:00+00:00 PythonOperator 2021-04-02T17:12:05.138555+00:00 2021-04-02T17:12:07.965024+00:00 0:00:02.826469 12832 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T17:12:02.676258+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-02T16:00:00+00:00 PythonOperator 2021-04-02T17:12:03.011228+00:00 2021-04-02T17:12:05.973881+00:00 0:00:02.962653 12831 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T17:12:00.662388+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T16:00:00+00:00 TriggerDagRunOperator 2021-04-02T17:11:40.866091+00:00 2021-04-02T17:11:41.393569+00:00 0:00:00.527478 12830 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T17:11:38.593507+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T16:00:00+00:00 TriggerDagRunOperator 2021-04-02T17:11:40.853763+00:00 2021-04-02T17:11:41.255276+00:00 0:00:00.401513 12829 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T17:11:38.593539+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-02T16:05:00+00:00 EmrJobFlowSensor 2021-04-02T17:05:54.234174+00:00 2021-04-02T17:14:56.726254+00:00 0:09:02.492080 12828 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T17:05:51.984605+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-02T16:05:00+00:00 EmrCreateJobFlowOperator 2021-04-02T17:05:34.094718+00:00 2021-04-02T17:05:35.707681+00:00 0:00:01.612963 12827 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T17:05:31.925216+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-02T16:05:00+00:00 PythonOperator 2021-04-02T17:05:11.999255+00:00 2021-04-02T17:05:14.675910+00:00 0:00:02.676655 12826 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T17:05:09.903794+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T16:00:00+00:00 EmrJobFlowSensor 2021-04-02T17:01:07.818691+00:00 2021-04-02T17:11:10.893781+00:00 0:10:03.075090 12825 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T17:01:05.618694+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T17:00:45.835118+00:00 2021-04-02T17:00:47.580065+00:00 0:00:01.744947 12824 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T17:00:43.596017+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T16:00:00+00:00 PythonOperator 2021-04-02T17:00:24.370566+00:00 2021-04-02T17:00:27.258741+00:00 0:00:02.888175 12823 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T17:00:21.584024+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-02T15:00:00+00:00 EmrJobFlowSensor 2021-04-02T16:12:03.634511+00:00 2021-04-02T16:20:06.166589+00:00 0:08:02.532078 12821 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T16:12:01.418942+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-02T15:00:00+00:00 EmrJobFlowSensor 2021-04-02T16:12:00.037050+00:00 2021-04-02T16:22:02.976195+00:00 0:10:02.939145 12820 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T16:11:57.453274+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-02T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T16:11:39.897900+00:00 2021-04-02T16:11:41.600472+00:00 0:00:01.702572 12819 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T16:11:37.483205+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-02T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T16:11:38.025479+00:00 2021-04-02T16:11:39.883734+00:00 0:00:01.858255 12818 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T16:11:35.468240+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-02T15:00:00+00:00 PythonOperator 2021-04-02T16:11:19.908402+00:00 2021-04-02T16:11:22.864248+00:00 0:00:02.955846 12817 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T16:11:17.379085+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-02T15:00:00+00:00 PythonOperator 2021-04-02T16:11:15.854402+00:00 2021-04-02T16:11:18.757348+00:00 0:00:02.902946 12816 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T16:11:13.449505+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T15:00:00+00:00 TriggerDagRunOperator 2021-04-02T16:10:59.874190+00:00 2021-04-02T16:11:00.384339+00:00 0:00:00.510149 12815 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T16:10:57.309479+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T15:00:00+00:00 TriggerDagRunOperator 2021-04-02T16:10:59.484879+00:00 2021-04-02T16:10:59.890548+00:00 0:00:00.405669 12814 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T16:10:57.309452+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-02T15:05:00+00:00 EmrJobFlowSensor 2021-04-02T16:05:47.027193+00:00 2021-04-02T16:13:49.611370+00:00 0:08:02.584177 12813 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T16:05:44.820686+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-02T15:05:00+00:00 EmrCreateJobFlowOperator 2021-04-02T16:05:24.989632+00:00 2021-04-02T16:05:26.645160+00:00 0:00:01.655528 12812 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T16:05:22.805949+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-02T15:05:00+00:00 PythonOperator 2021-04-02T16:05:05.069234+00:00 2021-04-02T16:05:07.802556+00:00 0:00:02.733322 12811 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T16:05:02.791399+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T15:00:00+00:00 EmrJobFlowSensor 2021-04-02T16:00:46.697294+00:00 2021-04-02T16:10:49.544609+00:00 0:10:02.847315 12810 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T16:00:44.421251+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T16:00:26.614369+00:00 2021-04-02T16:00:28.336483+00:00 0:00:01.722114 12809 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T16:00:24.402097+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T15:00:00+00:00 PythonOperator 2021-04-02T16:00:05.107472+00:00 2021-04-02T16:00:07.995766+00:00 0:00:02.888294 12808 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T16:00:02.385758+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-02T14:00:00+00:00 EmrJobFlowSensor 2021-04-02T15:10:33.636322+00:00 2021-04-02T15:19:36.194177+00:00 0:09:02.557855 12806 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T15:10:31.447719+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-02T14:00:00+00:00 EmrJobFlowSensor 2021-04-02T15:10:15.730744+00:00 2021-04-02T15:20:18.680632+00:00 0:10:02.949888 12805 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T15:10:13.430292+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-02T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T15:10:01.884151+00:00 2021-04-02T15:10:03.546494+00:00 0:00:01.662343 12804 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T15:09:59.414511+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-02T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T15:09:50.264579+00:00 2021-04-02T15:09:51.913892+00:00 0:00:01.649313 12803 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T15:09:47.488783+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-02T14:00:00+00:00 PythonOperator 2021-04-02T15:09:37.701396+00:00 2021-04-02T15:09:40.534881+00:00 0:00:02.833485 12802 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T15:09:35.393861+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-02T14:00:00+00:00 PythonOperator 2021-04-02T15:09:28.139309+00:00 2021-04-02T15:09:31.111919+00:00 0:00:02.972610 12801 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T15:09:25.388692+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T14:00:00+00:00 TriggerDagRunOperator 2021-04-02T15:09:15.732656+00:00 2021-04-02T15:09:16.244342+00:00 0:00:00.511686 12800 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T15:09:13.346760+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T14:00:00+00:00 TriggerDagRunOperator 2021-04-02T15:09:15.725679+00:00 2021-04-02T15:09:16.379065+00:00 0:00:00.653386 12799 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T15:09:13.346727+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-02T14:05:00+00:00 EmrJobFlowSensor 2021-04-02T15:05:57.027312+00:00 2021-04-02T15:14:59.622601+00:00 0:09:02.595289 12798 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T15:05:54.903052+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-02T14:05:00+00:00 EmrCreateJobFlowOperator 2021-04-02T15:05:35.115876+00:00 2021-04-02T15:05:36.840420+00:00 0:00:01.724544 12797 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T15:05:32.884546+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-02T14:05:00+00:00 PythonOperator 2021-04-02T15:05:13.053476+00:00 2021-04-02T15:05:15.758257+00:00 0:00:02.704781 12796 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T15:05:10.831470+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T14:00:00+00:00 EmrJobFlowSensor 2021-04-02T15:00:58.621024+00:00 2021-04-02T15:09:01.257629+00:00 0:08:02.636605 12795 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T15:00:56.427880+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T15:00:38.894777+00:00 2021-04-02T15:00:40.720580+00:00 0:00:01.825803 12794 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T15:00:36.407657+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T14:00:00+00:00 PythonOperator 2021-04-02T15:00:16.910955+00:00 2021-04-02T15:00:19.791853+00:00 0:00:02.880898 12793 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T15:00:14.456112+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-02T13:00:00+00:00 EmrJobFlowSensor 2021-04-02T14:14:40.316608+00:00 2021-04-02T14:22:42.816445+00:00 0:08:02.499837 12792 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T14:14:37.955988+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-02T13:00:00+00:00 EmrJobFlowSensor 2021-04-02T14:14:30.218211+00:00 2021-04-02T14:24:33.037663+00:00 0:10:02.819452 12791 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T14:14:27.843312+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-02T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T14:14:18.020734+00:00 2021-04-02T14:14:19.772704+00:00 0:00:01.751970 12790 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T14:14:15.821810+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-02T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T14:14:08.262936+00:00 2021-04-02T14:14:10.086851+00:00 0:00:01.823915 12789 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T14:14:05.809474+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-02T13:00:00+00:00 PythonOperator 2021-04-02T14:13:58.100595+00:00 2021-04-02T14:14:00.774893+00:00 0:00:02.674298 12788 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T14:13:55.799440+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-02T13:00:00+00:00 PythonOperator 2021-04-02T14:13:48.134805+00:00 2021-04-02T14:13:51.092864+00:00 0:00:02.958059 12787 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T14:13:45.789573+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T13:00:00+00:00 TriggerDagRunOperator 2021-04-02T14:13:40.544413+00:00 2021-04-02T14:13:41.068122+00:00 0:00:00.523709 12786 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T14:13:37.696784+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T13:00:00+00:00 TriggerDagRunOperator 2021-04-02T14:13:40.428379+00:00 2021-04-02T14:13:40.891127+00:00 0:00:00.462748 12785 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T14:13:37.696816+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-02T13:05:00+00:00 EmrJobFlowSensor 2021-04-02T14:05:46.886601+00:00 2021-04-02T14:14:49.562961+00:00 0:09:02.676360 12783 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T14:05:44.645354+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-02T13:05:00+00:00 EmrCreateJobFlowOperator 2021-04-02T14:05:26.841957+00:00 2021-04-02T14:05:28.574271+00:00 0:00:01.732314 12782 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T14:05:24.538064+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-02T13:05:00+00:00 PythonOperator 2021-04-02T14:05:04.913764+00:00 2021-04-02T14:05:07.575146+00:00 0:00:02.661382 12781 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T14:05:02.572683+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T13:00:00+00:00 EmrJobFlowSensor 2021-04-02T14:00:50.385122+00:00 2021-04-02T14:10:53.370776+00:00 0:10:02.985654 12780 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T14:00:48.157528+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T14:00:28.602753+00:00 2021-04-02T14:00:30.427232+00:00 0:00:01.824479 12779 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T14:00:26.173297+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T13:00:00+00:00 PythonOperator 2021-04-02T14:00:08.397686+00:00 2021-04-02T14:00:11.154235+00:00 0:00:02.756549 12778 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T14:00:06.149043+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-02T12:00:00+00:00 EmrJobFlowSensor 2021-04-02T13:12:19.170408+00:00 2021-04-02T13:22:21.943968+00:00 0:10:02.773560 12777 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T13:12:16.506176+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-02T12:00:00+00:00 EmrJobFlowSensor 2021-04-02T13:12:16.718247+00:00 2021-04-02T13:21:19.737383+00:00 0:09:03.019136 12776 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T13:12:14.508903+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-02T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T13:11:57.021311+00:00 2021-04-02T13:11:58.792769+00:00 0:00:01.771458 12775 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T13:11:54.546731+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-02T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T13:11:55.099650+00:00 2021-04-02T13:11:56.793575+00:00 0:00:01.693925 12774 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T13:11:52.490538+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-02T12:00:00+00:00 PythonOperator 2021-04-02T13:11:37.454082+00:00 2021-04-02T13:11:40.362552+00:00 0:00:02.908470 12773 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T13:11:34.477398+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-02T12:00:00+00:00 PythonOperator 2021-04-02T13:11:32.785186+00:00 2021-04-02T13:11:36.178337+00:00 0:00:03.393151 12772 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T13:11:30.475552+00:00 2 default_pool