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-07-04T05:00:00+00:00 TriggerDagRunOperator 2021-07-04T06:10:24.205972+00:00 2021-07-04T06:10:24.613723+00:00 0:00:00.407751 49570 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T06:10:21.822624+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-04T05:00:00+00:00 TriggerDagRunOperator 2021-07-04T06:10:24.109390+00:00 2021-07-04T06:10:24.660784+00:00 0:00:00.551394 49569 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T06:10:21.822664+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-04T05:05:00+00:00 EmrJobFlowSensor 2021-07-04T06:06:05.756592+00:00 2021-07-04T06:15:08.462711+00:00 0:09:02.706119 49568 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T06:06:03.455351+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-04T05:05:00+00:00 EmrCreateJobFlowOperator 2021-07-04T06:05:43.688658+00:00 2021-07-04T06:05:45.450386+00:00 0:00:01.761728 49567 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T06:05:41.366518+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-04T05:05:00+00:00 PythonOperator 2021-07-04T06:05:21.408518+00:00 2021-07-04T06:05:25.092557+00:00 0:00:03.684039 49566 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T06:05:19.282428+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-04T05:00:00+00:00 EmrJobFlowSensor 2021-07-04T06:01:17.538428+00:00 2021-07-04T06:12:20.592914+00:00 0:11:03.054486 49565 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T06:01:14.796736+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-04T05:00:00+00:00 EmrJobFlowSensor 2021-07-04T06:01:15.193191+00:00 2021-07-04T06:10:18.429855+00:00 0:09:03.236664 49564 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T06:01:12.794750+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-04T05:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T06:00:47.017174+00:00 2021-07-04T06:00:48.904418+00:00 0:00:01.887244 49563 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T06:00:44.769729+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-04T05:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T06:00:35.032016+00:00 2021-07-04T06:00:36.762685+00:00 0:00:01.730669 49562 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-04T06:00:32.752072+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-04T05:00:00+00:00 PythonOperator 2021-07-04T06:00:23.034560+00:00 2021-07-04T06:00:26.648141+00:00 0:00:03.613581 49561 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T06:00:20.843944+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-04T05:00:00+00:00 PythonOperator 2021-07-04T06:00:13.274364+00:00 2021-07-04T06:00:16.898890+00:00 0:00:03.624526 49560 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-04T06:00:10.773914+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-04T04:00:00+00:00 EmrJobFlowSensor 2021-07-04T05:11:26.091004+00:00 2021-07-04T05:21:28.962758+00:00 0:10:02.871754 49558 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T05:11:23.771572+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-04T04:00:00+00:00 EmrJobFlowSensor 2021-07-04T05:11:20.091440+00:00 2021-07-04T05:20:22.833014+00:00 0:09:02.741574 49557 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T05:11:17.779283+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-04T04:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T05:11:03.990601+00:00 2021-07-04T05:11:05.720709+00:00 0:00:01.730108 49556 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T05:11:01.748232+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-04T04:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T05:10:57.978825+00:00 2021-07-04T05:10:59.825067+00:00 0:00:01.846242 49555 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T05:10:55.685931+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-04T04:00:00+00:00 PythonOperator 2021-07-04T05:10:41.981234+00:00 2021-07-04T05:10:46.005874+00:00 0:00:04.024640 49554 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T05:10:39.616109+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-04T04:00:00+00:00 PythonOperator 2021-07-04T05:10:36.184845+00:00 2021-07-04T05:10:39.864704+00:00 0:00:03.679859 49553 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T05:10:33.613593+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-04T04:00:00+00:00 TriggerDagRunOperator 2021-07-04T05:10:16.198031+00:00 2021-07-04T05:10:16.694450+00:00 0:00:00.496419 49552 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T05:10:13.663286+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-04T04:00:00+00:00 TriggerDagRunOperator 2021-07-04T05:10:16.005173+00:00 2021-07-04T05:10:16.408495+00:00 0:00:00.403322 49551 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T05:10:13.663255+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-04T04:05:00+00:00 EmrJobFlowSensor 2021-07-04T05:05:49.395857+00:00 2021-07-04T05:13:51.932819+00:00 0:08:02.536962 49550 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T05:05:47.169862+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-04T04:05:00+00:00 EmrCreateJobFlowOperator 2021-07-04T05:05:27.424480+00:00 2021-07-04T05:05:29.144971+00:00 0:00:01.720491 49549 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T05:05:25.037603+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-04T04:05:00+00:00 PythonOperator 2021-07-04T05:05:07.340830+00:00 2021-07-04T05:05:11.133833+00:00 0:00:03.793003 49548 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T05:05:05.019387+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-04T04:00:00+00:00 EmrJobFlowSensor 2021-07-04T05:01:08.937982+00:00 2021-07-04T05:10:11.607453+00:00 0:09:02.669471 49547 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T05:01:06.545487+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-04T04:00:00+00:00 EmrJobFlowSensor 2021-07-04T05:00:50.579216+00:00 2021-07-04T05:10:53.337014+00:00 0:10:02.757798 49546 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T05:00:48.349049+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-04T04:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T05:00:44.583553+00:00 2021-07-04T05:00:46.287189+00:00 0:00:01.703636 49545 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-04T05:00:42.333046+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-04T04:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T05:00:30.702332+00:00 2021-07-04T05:00:32.512541+00:00 0:00:01.810209 49544 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T05:00:28.363896+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-04T04:00:00+00:00 PythonOperator 2021-07-04T05:00:22.825086+00:00 2021-07-04T05:00:26.533232+00:00 0:00:03.708146 49543 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-04T05:00:20.310951+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-04T04:00:00+00:00 PythonOperator 2021-07-04T05:00:08.969291+00:00 2021-07-04T05:00:12.404409+00:00 0:00:03.435118 49542 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T05:00:06.302790+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-04T03:00:00+00:00 EmrJobFlowSensor 2021-07-04T04:10:46.575088+00:00 2021-07-04T04:19:49.312207+00:00 0:09:02.737119 49540 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T04:10:44.361055+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-04T03:00:00+00:00 EmrJobFlowSensor 2021-07-04T04:10:32.464920+00:00 2021-07-04T04:19:35.298928+00:00 0:09:02.834008 49539 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T04:10:30.285226+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-04T03:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T04:10:24.601007+00:00 2021-07-04T04:10:26.505564+00:00 0:00:01.904557 49538 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T04:10:22.273777+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-04T03:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T04:10:10.501441+00:00 2021-07-04T04:10:12.302950+00:00 0:00:01.801509 49537 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T04:10:08.243513+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-04T03:00:00+00:00 PythonOperator 2021-07-04T04:09:50.633704+00:00 2021-07-04T04:09:54.247422+00:00 0:00:03.613718 49536 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T04:09:48.222226+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-04T03:00:00+00:00 PythonOperator 2021-07-04T04:09:44.420762+00:00 2021-07-04T04:09:48.406765+00:00 0:00:03.986003 49535 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T04:09:42.230874+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-04T03:00:00+00:00 TriggerDagRunOperator 2021-07-04T04:09:28.897318+00:00 2021-07-04T04:09:29.422082+00:00 0:00:00.524764 49534 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T04:09:26.273050+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-04T03:00:00+00:00 TriggerDagRunOperator 2021-07-04T04:09:28.680389+00:00 2021-07-04T04:09:29.090433+00:00 0:00:00.410044 49533 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T04:09:26.272992+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-04T03:05:00+00:00 EmrJobFlowSensor 2021-07-04T04:05:50.292191+00:00 2021-07-04T04:13:52.926526+00:00 0:08:02.634335 49532 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T04:05:47.966891+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-04T03:05:00+00:00 EmrCreateJobFlowOperator 2021-07-04T04:05:28.421508+00:00 2021-07-04T04:05:30.233574+00:00 0:00:01.812066 49531 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T04:05:25.961483+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-04T03:05:00+00:00 PythonOperator 2021-07-04T04:05:07.986107+00:00 2021-07-04T04:05:11.345261+00:00 0:00:03.359154 49530 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T04:05:05.823402+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-04T03:00:00+00:00 EmrJobFlowSensor 2021-07-04T04:01:13.842454+00:00 2021-07-04T04:09:16.652980+00:00 0:08:02.810526 49529 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T04:01:11.442752+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-04T03:00:00+00:00 EmrJobFlowSensor 2021-07-04T04:00:57.588877+00:00 2021-07-04T04:11:00.403261+00:00 0:10:02.814384 49528 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T04:00:55.435036+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-04T03:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T04:00:45.793324+00:00 2021-07-04T04:00:47.607145+00:00 0:00:01.813821 49527 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-04T04:00:43.428875+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-04T03:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T04:00:26.069422+00:00 2021-07-04T04:00:27.947884+00:00 0:00:01.878462 49526 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T04:00:23.454897+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-04T03:00:00+00:00 PythonOperator 2021-07-04T04:00:21.532371+00:00 2021-07-04T04:00:25.145520+00:00 0:00:03.613149 49525 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-04T04:00:19.361166+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-04T03:00:00+00:00 PythonOperator 2021-07-04T04:00:05.901454+00:00 2021-07-04T04:00:09.666121+00:00 0:00:03.764667 49524 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T04:00:03.347662+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-04T02:00:00+00:00 EmrJobFlowSensor 2021-07-04T03:12:20.377533+00:00 2021-07-04T03:21:23.337184+00:00 0:09:02.959651 49522 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T03:12:18.034969+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-04T02:00:00+00:00 EmrJobFlowSensor 2021-07-04T03:12:04.238995+00:00 2021-07-04T03:24:07.398328+00:00 0:12:03.159333 49521 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T03:12:02.029012+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-04T02:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T03:11:54.142956+00:00 2021-07-04T03:11:55.980268+00:00 0:00:01.837312 49520 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T03:11:51.830232+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-04T02:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T03:11:42.086494+00:00 2021-07-04T03:11:43.925638+00:00 0:00:01.839144 49519 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T03:11:39.819966+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-04T02:00:00+00:00 PythonOperator 2021-07-04T03:11:31.993817+00:00 2021-07-04T03:11:35.721873+00:00 0:00:03.728056 49518 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T03:11:29.812613+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-04T02:00:00+00:00 PythonOperator 2021-07-04T03:11:20.128978+00:00 2021-07-04T03:11:24.058531+00:00 0:00:03.929553 49517 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T03:11:17.798238+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-04T02:00:00+00:00 TriggerDagRunOperator 2021-07-04T03:11:14.243255+00:00 2021-07-04T03:11:14.751252+00:00 0:00:00.507997 49516 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T03:11:11.798857+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-04T02:00:00+00:00 TriggerDagRunOperator 2021-07-04T03:11:14.118002+00:00 2021-07-04T03:11:14.510335+00:00 0:00:00.392333 49515 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T03:11:11.798890+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-04T02:05:00+00:00 EmrJobFlowSensor 2021-07-04T03:06:03.671540+00:00 2021-07-04T03:15:06.244192+00:00 0:09:02.572652 49514 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T03:06:01.360552+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-04T02:05:00+00:00 EmrCreateJobFlowOperator 2021-07-04T03:05:41.377033+00:00 2021-07-04T03:05:43.193678+00:00 0:00:01.816645 49513 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T03:05:39.220161+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-04T02:05:00+00:00 PythonOperator 2021-07-04T03:05:17.287229+00:00 2021-07-04T03:05:20.896654+00:00 0:00:03.609425 49512 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T03:05:15.197555+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-04T02:00:00+00:00 EmrJobFlowSensor 2021-07-04T03:01:07.017936+00:00 2021-07-04T03:11:10.111687+00:00 0:10:03.093751 49511 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T03:01:04.797491+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-04T02:00:00+00:00 EmrJobFlowSensor 2021-07-04T03:00:49.164352+00:00 2021-07-04T03:10:52.051521+00:00 0:10:02.887169 49510 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T03:00:46.850394+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-04T02:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T03:00:44.956830+00:00 2021-07-04T03:00:46.772730+00:00 0:00:01.815900 49509 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-04T03:00:42.726826+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-04T02:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T03:00:27.138382+00:00 2021-07-04T03:00:28.930396+00:00 0:00:01.792014 49508 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T03:00:24.767129+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-04T02:00:00+00:00 PythonOperator 2021-07-04T03:00:24.894427+00:00 2021-07-04T03:00:28.563411+00:00 0:00:03.668984 49507 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-04T03:00:22.702690+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-04T02:00:00+00:00 PythonOperator 2021-07-04T03:00:07.079594+00:00 2021-07-04T03:00:10.676442+00:00 0:00:03.596848 49506 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T03:00:04.754847+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-04T01:05:00+00:00 EmrJobFlowSensor 2021-07-04T02:13:18.181860+00:00 2021-07-04T02:14:19.971502+00:00 0:01:01.789642 49504 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T02:13:15.710116+00:00 3 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-04T01:00:00+00:00 EmrJobFlowSensor 2021-07-04T02:12:15.673015+00:00 2021-07-04T02:22:18.486802+00:00 0:10:02.813787 49503 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T02:12:13.525671+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-04T01:00:00+00:00 EmrJobFlowSensor 2021-07-04T02:12:11.648547+00:00 2021-07-04T02:21:14.446797+00:00 0:09:02.798250 49502 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T02:12:09.523189+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-04T01:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T02:11:53.954363+00:00 2021-07-04T02:11:55.735816+00:00 0:00:01.781453 49501 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T02:11:51.502623+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-04T01:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T02:11:34.192008+00:00 2021-07-04T02:11:35.924148+00:00 0:00:01.732140 49500 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T02:11:31.486953+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-04T01:00:00+00:00 PythonOperator 2021-07-04T02:11:27.979329+00:00 2021-07-04T02:11:32.129130+00:00 0:00:04.149801 49499 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T02:11:25.555347+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-04T01:00:00+00:00 PythonOperator 2021-07-04T02:11:11.574277+00:00 2021-07-04T02:11:15.407700+00:00 0:00:03.833423 49498 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T02:11:09.417929+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-04T01:00:00+00:00 TriggerDagRunOperator 2021-07-04T02:11:08.031932+00:00 2021-07-04T02:11:08.549488+00:00 0:00:00.517556 49497 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T02:11:05.475356+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-04T01:00:00+00:00 TriggerDagRunOperator 2021-07-04T02:11:07.857815+00:00 2021-07-04T02:11:08.372205+00:00 0:00:00.514390 49496 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T02:11:05.475315+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-04T01:05:00+00:00 EmrCreateJobFlowOperator 2021-07-04T02:05:27.067401+00:00 2021-07-04T02:05:28.790157+00:00 0:00:01.722756 49494 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T02:05:24.903367+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-04T01:05:00+00:00 PythonOperator 2021-07-04T02:05:03.186891+00:00 2021-07-04T02:05:06.639551+00:00 0:00:03.452660 49493 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T02:05:00.834009+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-04T01:00:00+00:00 EmrJobFlowSensor 2021-07-04T02:00:56.711292+00:00 2021-07-04T02:10:59.609654+00:00 0:10:02.898362 49491 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T02:00:54.385907+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-04T01:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T02:00:36.661219+00:00 2021-07-04T02:00:38.386202+00:00 0:00:01.724983 49489 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-04T02:00:34.346405+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-04T01:00:00+00:00 PythonOperator 2021-07-04T02:00:14.860698+00:00 2021-07-04T02:00:18.373325+00:00 0:00:03.512627 49487 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-04T02:00:12.232609+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-04T00:00:00+00:00 EmrJobFlowSensor 2021-07-04T01:11:27.962857+00:00 2021-07-04T01:19:30.562978+00:00 0:08:02.600121 49485 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T01:11:25.752279+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-04T00:00:00+00:00 EmrJobFlowSensor 2021-07-04T01:11:09.782246+00:00 2021-07-04T01:21:12.782441+00:00 0:10:03.000195 49484 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T01:11:07.630088+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-04T00:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T01:11:05.827066+00:00 2021-07-04T01:11:07.553870+00:00 0:00:01.726804 49483 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T01:11:03.621160+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-04T00:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T01:10:47.910290+00:00 2021-07-04T01:10:49.619223+00:00 0:00:01.708933 49482 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T01:10:45.613762+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-04T00:00:00+00:00 PythonOperator 2021-07-04T01:10:44.066520+00:00 2021-07-04T01:10:47.586191+00:00 0:00:03.519671 49481 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T01:10:41.744573+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-04T00:00:00+00:00 PythonOperator 2021-07-04T01:10:26.033688+00:00 2021-07-04T01:10:29.998619+00:00 0:00:03.964931 49480 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T01:10:23.646673+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-04T00:00:00+00:00 TriggerDagRunOperator 2021-07-04T01:10:19.966371+00:00 2021-07-04T01:10:20.469328+00:00 0:00:00.502957 49479 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T01:10:17.584888+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-04T00:00:00+00:00 TriggerDagRunOperator 2021-07-04T01:10:19.886602+00:00 2021-07-04T01:10:20.272692+00:00 0:00:00.386090 49478 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T01:10:17.584853+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-04T00:05:00+00:00 EmrJobFlowSensor 2021-07-04T01:05:47.171004+00:00 2021-07-04T01:14:49.679265+00:00 0:09:02.508261 49477 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T01:05:45.105216+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-04T00:05:00+00:00 EmrCreateJobFlowOperator 2021-07-04T01:05:27.280457+00:00 2021-07-04T01:05:28.999277+00:00 0:00:01.718820 49476 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T01:05:25.013986+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-04T00:05:00+00:00 PythonOperator 2021-07-04T01:05:05.308002+00:00 2021-07-04T01:05:08.779416+00:00 0:00:03.471414 49475 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T01:05:03.047717+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-04T00:00:00+00:00 EmrJobFlowSensor 2021-07-04T01:01:23.047244+00:00 2021-07-04T01:11:25.894069+00:00 0:10:02.846825 49474 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T01:01:20.659645+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-04T00:00:00+00:00 EmrJobFlowSensor 2021-07-04T01:00:58.907165+00:00 2021-07-04T01:10:01.847867+00:00 0:09:02.940702 49473 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T01:00:56.542332+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-04T00:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T01:00:52.853156+00:00 2021-07-04T01:00:54.557117+00:00 0:00:01.703961 49472 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T01:00:50.535718+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-04T00:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T01:00:34.675536+00:00 2021-07-04T01:00:36.356390+00:00 0:00:01.680854 49471 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-04T01:00:32.522335+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-04T00:00:00+00:00 PythonOperator 2021-07-04T01:00:24.684992+00:00 2021-07-04T01:00:28.335933+00:00 0:00:03.650941 49470 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T01:00:22.512696+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-04T00:00:00+00:00 PythonOperator 2021-07-04T01:00:10.904820+00:00 2021-07-04T01:00:14.448762+00:00 0:00:03.543942 49469 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-04T01:00:08.504173+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-03T23:00:00+00:00 EmrJobFlowSensor 2021-07-04T00:11:16.103971+00:00 2021-07-04T00:21:19.002749+00:00 0:10:02.898778 49467 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T00:11:13.668719+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-03T23:00:00+00:00 EmrJobFlowSensor 2021-07-04T00:11:00.215763+00:00 2021-07-04T00:20:03.114849+00:00 0:09:02.899086 49466 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T00:10:57.594969+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-03T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T00:10:53.926335+00:00 2021-07-04T00:10:55.739712+00:00 0:00:01.813377 49465 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T00:10:51.578691+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-03T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T00:10:38.738501+00:00 2021-07-04T00:10:40.427885+00:00 0:00:01.689384 49464 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T00:10:35.516641+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-03T23:00:00+00:00 PythonOperator 2021-07-04T00:10:33.695198+00:00 2021-07-04T00:10:38.525071+00:00 0:00:04.829873 49463 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T00:10:31.513302+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-03T23:00:00+00:00 PythonOperator 2021-07-04T00:10:15.829868+00:00 2021-07-04T00:10:19.711958+00:00 0:00:03.882090 49462 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T00:10:13.500669+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-03T23:00:00+00:00 TriggerDagRunOperator 2021-07-04T00:10:10.207085+00:00 2021-07-04T00:10:10.722562+00:00 0:00:00.515477 49461 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T00:10:07.566482+00:00 2 default_pool