Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T17:00:00+00:00 TriggerDagRunOperator 2021-04-07T18:10:08.017473+00:00 2021-04-07T18:10:08.432552+00:00 0:00:00.415079 14648 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T18:10:05.583593+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-07T17:05:00+00:00 EmrJobFlowSensor 2021-04-07T18:05:49.677285+00:00 2021-04-07T18:14:52.244951+00:00 0:09:02.567666 14647 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T18:05:47.344266+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-07T17:05:00+00:00 EmrCreateJobFlowOperator 2021-04-07T18:05:29.777645+00:00 2021-04-07T18:05:31.527467+00:00 0:00:01.749822 14646 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T18:05:27.270049+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-07T17:05:00+00:00 PythonOperator 2021-04-07T18:05:07.278024+00:00 2021-04-07T18:05:09.951342+00:00 0:00:02.673318 14645 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T18:05:05.168534+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T17:00:00+00:00 EmrJobFlowSensor 2021-04-07T18:00:55.225364+00:00 2021-04-07T18:09:58.156020+00:00 0:09:02.930656 14644 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T18:00:52.846194+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T18:00:35.159892+00:00 2021-04-07T18:00:36.882731+00:00 0:00:01.722839 14643 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T18:00:32.760426+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T17:00:00+00:00 PythonOperator 2021-04-07T18:00:12.964119+00:00 2021-04-07T18:00:15.830327+00:00 0:00:02.866208 14642 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T18:00:10.689911+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-07T16:00:00+00:00 EmrJobFlowSensor 2021-04-07T17:16:42.927015+00:00 2021-04-07T17:26:45.662244+00:00 0:10:02.735229 14641 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T17:16:40.279477+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-07T16:00:00+00:00 EmrJobFlowSensor 2021-04-07T17:16:42.620908+00:00 2021-04-07T17:25:45.522637+00:00 0:09:02.901729 14640 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T17:16:40.279510+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-07T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T17:16:22.860531+00:00 2021-04-07T17:16:24.676233+00:00 0:00:01.815702 14639 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T17:16:20.353249+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-07T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T17:16:22.685555+00:00 2021-04-07T17:16:24.468568+00:00 0:00:01.783013 14638 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T17:16:20.353208+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-07T16:00:00+00:00 PythonOperator 2021-04-07T17:16:01.012238+00:00 2021-04-07T17:16:03.734135+00:00 0:00:02.721897 14637 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T17:15:58.271730+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-07T16:00:00+00:00 PythonOperator 2021-04-07T17:16:01.041145+00:00 2021-04-07T17:16:04.144649+00:00 0:00:03.103504 14636 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T17:15:58.271762+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T16:00:00+00:00 TriggerDagRunOperator 2021-04-07T17:15:42.611632+00:00 2021-04-07T17:15:43.152671+00:00 0:00:00.541039 14635 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T17:15:40.099725+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T16:00:00+00:00 TriggerDagRunOperator 2021-04-07T17:15:42.530451+00:00 2021-04-07T17:15:42.957005+00:00 0:00:00.426554 14634 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T17:15:40.099696+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-07T16:05:00+00:00 EmrJobFlowSensor 2021-04-07T17:05:51.629834+00:00 2021-04-07T17:14:54.220550+00:00 0:09:02.590716 14632 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T17:05:49.434165+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-07T16:05:00+00:00 EmrCreateJobFlowOperator 2021-04-07T17:05:31.843433+00:00 2021-04-07T17:05:33.511531+00:00 0:00:01.668098 14631 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T17:05:29.495421+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-07T16:05:00+00:00 PythonOperator 2021-04-07T17:05:10.079523+00:00 2021-04-07T17:05:12.787091+00:00 0:00:02.707568 14630 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T17:05:07.464762+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T16:00:00+00:00 EmrJobFlowSensor 2021-04-07T17:01:15.387521+00:00 2021-04-07T17:10:18.195064+00:00 0:09:02.807543 14629 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T17:01:13.129107+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T17:00:53.311450+00:00 2021-04-07T17:00:54.998270+00:00 0:00:01.686820 14628 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T17:00:51.086805+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T16:00:00+00:00 PythonOperator 2021-04-07T17:00:33.236605+00:00 2021-04-07T17:00:35.989833+00:00 0:00:02.753228 14627 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T17:00:31.006505+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-07T15:00:00+00:00 EmrJobFlowSensor 2021-04-07T16:33:56.983140+00:00 2021-04-07T16:54:01.199776+00:00 0:20:04.216636 14626 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T16:33:54.606304+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-07T15:00:00+00:00 EmrJobFlowSensor 2021-04-07T16:33:40.896475+00:00 2021-04-07T16:42:43.581240+00:00 0:09:02.684765 14625 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T16:33:38.589747+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-07T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T16:33:35.015620+00:00 2021-04-07T16:33:36.698157+00:00 0:00:01.682537 14624 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T16:33:32.644019+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-07T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T16:33:18.886927+00:00 2021-04-07T16:33:20.686412+00:00 0:00:01.799485 14623 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T16:33:16.558281+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-07T15:00:00+00:00 PythonOperator 2021-04-07T16:33:14.791347+00:00 2021-04-07T16:33:17.548096+00:00 0:00:02.756749 14622 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T16:33:12.559062+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-07T15:00:00+00:00 PythonOperator 2021-04-07T16:32:58.815327+00:00 2021-04-07T16:33:01.874366+00:00 0:00:03.059039 14621 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T16:32:56.516227+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T15:00:00+00:00 TriggerDagRunOperator 2021-04-07T16:32:48.881489+00:00 2021-04-07T16:32:49.412674+00:00 0:00:00.531185 14620 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T16:32:46.499940+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T15:00:00+00:00 TriggerDagRunOperator 2021-04-07T16:32:48.798089+00:00 2021-04-07T16:32:49.222243+00:00 0:00:00.424154 14619 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T16:32:46.499912+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T15:00:00+00:00 EmrJobFlowSensor 2021-04-07T16:11:10.696897+00:00 2021-04-07T16:32:14.954094+00:00 0:21:04.257197 14618 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T16:11:08.457687+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-07T15:05:00+00:00 EmrJobFlowSensor 2021-04-07T16:11:04.680961+00:00 2021-04-07T16:20:07.307864+00:00 0:09:02.626903 14617 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T16:11:02.501625+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T16:10:48.796587+00:00 2021-04-07T16:10:50.611899+00:00 0:00:01.815312 14616 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T16:10:46.435981+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-07T15:05:00+00:00 EmrCreateJobFlowOperator 2021-04-07T16:10:42.619793+00:00 2021-04-07T16:10:44.333094+00:00 0:00:01.713301 14615 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T16:10:40.436154+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T15:00:00+00:00 PythonOperator 2021-04-07T16:10:24.621203+00:00 2021-04-07T16:10:27.318326+00:00 0:00:02.697123 14614 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T16:10:22.423724+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-07T15:05:00+00:00 PythonOperator 2021-04-07T16:10:21.061547+00:00 2021-04-07T16:10:23.869285+00:00 0:00:02.807738 14613 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T16:10:18.420375+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-07T14:00:00+00:00 EmrJobFlowSensor 2021-04-07T15:12:09.894485+00:00 2021-04-07T15:22:12.690800+00:00 0:10:02.796315 14611 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T15:12:07.717718+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-07T14:00:00+00:00 EmrJobFlowSensor 2021-04-07T15:11:58.001811+00:00 2021-04-07T15:21:00.701623+00:00 0:09:02.699812 14610 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T15:11:55.710107+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-07T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T15:11:50.193247+00:00 2021-04-07T15:11:51.920438+00:00 0:00:01.727191 14609 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T15:11:47.697671+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-07T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T15:11:37.930898+00:00 2021-04-07T15:11:39.650691+00:00 0:00:01.719793 14608 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T15:11:35.688866+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-07T14:00:00+00:00 PythonOperator 2021-04-07T15:11:28.580470+00:00 2021-04-07T15:11:31.530056+00:00 0:00:02.949586 14607 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T15:11:25.621427+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-07T14:00:00+00:00 PythonOperator 2021-04-07T15:11:15.931972+00:00 2021-04-07T15:11:18.737883+00:00 0:00:02.805911 14606 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T15:11:13.608289+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T14:00:00+00:00 TriggerDagRunOperator 2021-04-07T15:11:06.199579+00:00 2021-04-07T15:11:06.636861+00:00 0:00:00.437282 14605 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T15:11:03.656827+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T14:00:00+00:00 TriggerDagRunOperator 2021-04-07T15:11:06.227702+00:00 2021-04-07T15:11:06.791951+00:00 0:00:00.564249 14604 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T15:11:03.656874+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-07T14:05:00+00:00 EmrJobFlowSensor 2021-04-07T15:05:55.367491+00:00 2021-04-07T15:14:58.174032+00:00 0:09:02.806541 14603 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T15:05:53.129880+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-07T14:05:00+00:00 EmrCreateJobFlowOperator 2021-04-07T15:05:33.266154+00:00 2021-04-07T15:05:34.889491+00:00 0:00:01.623337 14602 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T15:05:31.111088+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-07T14:05:00+00:00 PythonOperator 2021-04-07T15:05:13.267404+00:00 2021-04-07T15:05:15.946557+00:00 0:00:02.679153 14601 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T15:05:11.092703+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T14:00:00+00:00 EmrJobFlowSensor 2021-04-07T15:00:48.933780+00:00 2021-04-07T15:10:51.770513+00:00 0:10:02.836733 14600 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T15:00:46.736687+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T15:00:29.132317+00:00 2021-04-07T15:00:30.953273+00:00 0:00:01.820956 14599 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T15:00:26.717955+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T14:00:00+00:00 PythonOperator 2021-04-07T15:00:07.380463+00:00 2021-04-07T15:00:10.147688+00:00 0:00:02.767225 14598 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T15:00:04.618281+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-07T13:00:00+00:00 EmrJobFlowSensor 2021-04-07T14:10:16.487135+00:00 2021-04-07T14:19:19.218512+00:00 0:09:02.731377 14596 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T14:10:14.196365+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-07T13:00:00+00:00 EmrJobFlowSensor 2021-04-07T14:10:08.420778+00:00 2021-04-07T14:19:11.057520+00:00 0:09:02.636742 14595 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T14:10:06.187965+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-07T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T14:09:54.442837+00:00 2021-04-07T14:09:56.237897+00:00 0:00:01.795060 14594 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T14:09:52.131203+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-07T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T14:09:46.736433+00:00 2021-04-07T14:09:48.466662+00:00 0:00:01.730229 14593 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T14:09:44.127912+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-07T13:00:00+00:00 PythonOperator 2021-04-07T14:09:34.434700+00:00 2021-04-07T14:09:37.418924+00:00 0:00:02.984224 14592 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T14:09:32.112886+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-07T13:00:00+00:00 PythonOperator 2021-04-07T14:09:24.535148+00:00 2021-04-07T14:09:27.344962+00:00 0:00:02.809814 14591 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T14:09:22.177593+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T13:00:00+00:00 TriggerDagRunOperator 2021-04-07T14:09:12.591259+00:00 2021-04-07T14:09:13.111053+00:00 0:00:00.519794 14590 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T14:09:10.097047+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T13:00:00+00:00 TriggerDagRunOperator 2021-04-07T14:09:12.216785+00:00 2021-04-07T14:09:12.641799+00:00 0:00:00.425014 14589 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T14:09:10.097083+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-07T13:05:00+00:00 EmrJobFlowSensor 2021-04-07T14:06:04.436799+00:00 2021-04-07T14:15:07.049150+00:00 0:09:02.612351 14588 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T14:06:01.866658+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-07T13:05:00+00:00 EmrCreateJobFlowOperator 2021-04-07T14:05:41.986110+00:00 2021-04-07T14:05:43.717136+00:00 0:00:01.731026 14587 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T14:05:39.796191+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-07T13:05:00+00:00 PythonOperator 2021-04-07T14:05:20.137829+00:00 2021-04-07T14:05:22.818997+00:00 0:00:02.681168 14586 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T14:05:17.725671+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T13:00:00+00:00 EmrJobFlowSensor 2021-04-07T14:01:01.659823+00:00 2021-04-07T14:09:04.324513+00:00 0:08:02.664690 14585 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T14:00:59.306114+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T14:00:39.467495+00:00 2021-04-07T14:00:41.144900+00:00 0:00:01.677405 14584 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T14:00:37.285103+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T13:00:00+00:00 PythonOperator 2021-04-07T14:00:20.214802+00:00 2021-04-07T14:00:22.994548+00:00 0:00:02.779746 14583 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T14:00:17.269005+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-07T12:00:00+00:00 EmrJobFlowSensor 2021-04-07T13:11:50.124744+00:00 2021-04-07T13:19:52.719345+00:00 0:08:02.594601 14581 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T13:11:47.788203+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-07T12:00:00+00:00 EmrJobFlowSensor 2021-04-07T13:11:27.982880+00:00 2021-04-07T13:21:30.687479+00:00 0:10:02.704599 14580 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T13:11:25.766388+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-07T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T13:11:16.045618+00:00 2021-04-07T13:11:17.867239+00:00 0:00:01.821621 14579 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T13:11:13.769563+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-07T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T13:11:00.230415+00:00 2021-04-07T13:11:02.025205+00:00 0:00:01.794790 14578 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T13:10:57.843906+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-07T12:00:00+00:00 PythonOperator 2021-04-07T13:10:54.324607+00:00 2021-04-07T13:10:57.199116+00:00 0:00:02.874509 14577 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T13:10:51.781231+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-07T12:00:00+00:00 PythonOperator 2021-04-07T13:10:40.072339+00:00 2021-04-07T13:10:43.185420+00:00 0:00:03.113081 14576 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T13:10:37.690067+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T12:00:00+00:00 TriggerDagRunOperator 2021-04-07T13:10:30.579222+00:00 2021-04-07T13:10:31.119525+00:00 0:00:00.540303 14575 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T13:10:27.842349+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T12:00:00+00:00 TriggerDagRunOperator 2021-04-07T13:10:30.451690+00:00 2021-04-07T13:10:30.881303+00:00 0:00:00.429613 14574 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T13:10:27.842401+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-07T12:05:00+00:00 EmrJobFlowSensor 2021-04-07T13:05:55.461290+00:00 2021-04-07T13:14:58.166022+00:00 0:09:02.704732 14573 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T13:05:53.156725+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-07T12:05:00+00:00 EmrCreateJobFlowOperator 2021-04-07T13:05:33.257400+00:00 2021-04-07T13:05:34.895386+00:00 0:00:01.637986 14572 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T13:05:31.060981+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-07T12:05:00+00:00 PythonOperator 2021-04-07T13:05:11.195354+00:00 2021-04-07T13:05:14.069876+00:00 0:00:02.874522 14571 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T13:05:09.005586+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T12:00:00+00:00 EmrJobFlowSensor 2021-04-07T13:01:06.721244+00:00 2021-04-07T13:10:09.461024+00:00 0:09:02.739780 14570 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T13:01:04.360126+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T13:00:46.559979+00:00 2021-04-07T13:00:48.236713+00:00 0:00:01.676734 14569 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T13:00:44.294945+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T12:00:00+00:00 PythonOperator 2021-04-07T13:00:24.641491+00:00 2021-04-07T13:00:27.526956+00:00 0:00:02.885465 14568 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T13:00:22.233030+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-07T11:00:00+00:00 EmrJobFlowSensor 2021-04-07T12:12:27.898492+00:00 2021-04-07T12:24:30.832570+00:00 0:12:02.934078 14566 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T12:12:25.742736+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-07T11:00:00+00:00 EmrJobFlowSensor 2021-04-07T12:12:23.902040+00:00 2021-04-07T12:22:26.723337+00:00 0:10:02.821297 14565 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T12:12:21.733179+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-07T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T12:12:08.174417+00:00 2021-04-07T12:12:10.042772+00:00 0:00:01.868355 14564 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T12:12:05.725444+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-07T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T12:12:04.131337+00:00 2021-04-07T12:12:05.936492+00:00 0:00:01.805155 14563 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T12:12:01.717730+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-07T11:00:00+00:00 PythonOperator 2021-04-07T12:11:44.313567+00:00 2021-04-07T12:11:47.230412+00:00 0:00:02.916845 14562 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T12:11:41.760328+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-07T11:00:00+00:00 PythonOperator 2021-04-07T12:11:40.240357+00:00 2021-04-07T12:11:43.102104+00:00 0:00:02.861747 14561 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T12:11:37.766992+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T11:00:00+00:00 TriggerDagRunOperator 2021-04-07T12:11:20.350434+00:00 2021-04-07T12:11:20.879230+00:00 0:00:00.528796 14560 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T12:11:17.681929+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T11:00:00+00:00 TriggerDagRunOperator 2021-04-07T12:11:20.193644+00:00 2021-04-07T12:11:20.620359+00:00 0:00:00.426715 14559 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T12:11:17.681963+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-07T11:05:00+00:00 EmrJobFlowSensor 2021-04-07T12:05:55.775067+00:00 2021-04-07T12:14:58.407533+00:00 0:09:02.632466 14558 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T12:05:53.286726+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-07T11:05:00+00:00 EmrCreateJobFlowOperator 2021-04-07T12:05:35.498603+00:00 2021-04-07T12:05:37.134935+00:00 0:00:01.636332 14557 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T12:05:33.263342+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-07T11:05:00+00:00 PythonOperator 2021-04-07T12:05:13.410631+00:00 2021-04-07T12:05:16.284937+00:00 0:00:02.874306 14556 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T12:05:11.187535+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T11:00:00+00:00 EmrJobFlowSensor 2021-04-07T12:01:03.140080+00:00 2021-04-07T12:11:05.984918+00:00 0:10:02.844838 14555 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T12:01:00.760605+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T12:00:40.997337+00:00 2021-04-07T12:00:42.800283+00:00 0:00:01.802946 14554 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T12:00:38.752297+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T11:00:00+00:00 PythonOperator 2021-04-07T12:00:21.022448+00:00 2021-04-07T12:00:23.938129+00:00 0:00:02.915681 14553 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T12:00:18.655083+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-07T10:00:00+00:00 EmrJobFlowSensor 2021-04-07T11:11:18.762930+00:00 2021-04-07T11:22:21.797600+00:00 0:11:03.034670 14551 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T11:11:16.100663+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-07T10:00:00+00:00 EmrJobFlowSensor 2021-04-07T11:11:08.704899+00:00 2021-04-07T11:20:11.500805+00:00 0:09:02.795906 14550 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T11:11:06.147044+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-07T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T11:10:58.223804+00:00 2021-04-07T11:10:59.905360+00:00 0:00:01.681556 14549 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T11:10:56.054902+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-07T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T11:10:48.795786+00:00 2021-04-07T11:10:50.587741+00:00 0:00:01.791955 14548 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T11:10:46.045092+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-07T10:00:00+00:00 PythonOperator 2021-04-07T11:10:36.327086+00:00 2021-04-07T11:10:39.331649+00:00 0:00:03.004563 14547 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T11:10:34.032661+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-07T10:00:00+00:00 PythonOperator 2021-04-07T11:10:26.306547+00:00 2021-04-07T11:10:29.028042+00:00 0:00:02.721495 14546 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T11:10:24.037303+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T10:00:00+00:00 TriggerDagRunOperator 2021-04-07T11:10:16.790766+00:00 2021-04-07T11:10:17.237405+00:00 0:00:00.446639 14545 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T11:10:14.019938+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T10:00:00+00:00 TriggerDagRunOperator 2021-04-07T11:10:16.349241+00:00 2021-04-07T11:10:16.944517+00:00 0:00:00.595276 14544 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T11:10:14.019980+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-07T10:05:00+00:00 EmrJobFlowSensor 2021-04-07T11:06:05.783966+00:00 2021-04-07T11:15:08.319963+00:00 0:09:02.535997 14543 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T11:06:03.579474+00:00 2 default_pool