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-21T10:00:00+00:00 TriggerDagRunOperator 2021-04-21T11:12:28.047955+00:00 2021-04-21T11:12:28.654844+00:00 0:00:00.606889 19621 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T11:12:25.791020+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-21T10:00:00+00:00 TriggerDagRunOperator 2021-04-21T11:12:27.997035+00:00 2021-04-21T11:12:28.411079+00:00 0:00:00.414044 19620 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T11:12:25.791052+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-21T10:05:00+00:00 EmrJobFlowSensor 2021-04-21T11:06:07.487644+00:00 2021-04-21T11:15:10.195523+00:00 0:09:02.707879 19619 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T11:06:05.216255+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-21T10:05:00+00:00 EmrCreateJobFlowOperator 2021-04-21T11:05:45.861864+00:00 2021-04-21T11:05:47.768553+00:00 0:00:01.906689 19618 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T11:05:43.263246+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-21T10:05:00+00:00 PythonOperator 2021-04-21T11:05:25.377204+00:00 2021-04-21T11:05:28.315847+00:00 0:00:02.938643 19617 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T11:05:23.165640+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-21T10:00:00+00:00 EmrJobFlowSensor 2021-04-21T11:01:09.274689+00:00 2021-04-21T11:12:12.290890+00:00 0:11:03.016201 19616 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T11:01:06.687794+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-21T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T11:00:44.875212+00:00 2021-04-21T11:00:46.578188+00:00 0:00:01.702976 19615 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-21T11:00:42.664563+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-21T10:00:00+00:00 PythonOperator 2021-04-21T11:00:13.518431+00:00 2021-04-21T11:00:17.077994+00:00 0:00:03.559563 19614 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-21T11:00:10.635420+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-21T09:00:00+00:00 EmrJobFlowSensor 2021-04-21T10:13:03.520552+00:00 2021-04-21T10:26:06.817216+00:00 0:13:03.296664 19612 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T10:13:01.290303+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-21T09:00:00+00:00 EmrJobFlowSensor 2021-04-21T10:12:59.683563+00:00 2021-04-21T10:23:02.605311+00:00 0:10:02.921748 19611 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T10:12:57.358844+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-21T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T10:12:43.502785+00:00 2021-04-21T10:12:45.230565+00:00 0:00:01.727780 19610 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T10:12:41.202266+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-21T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T10:12:37.452742+00:00 2021-04-21T10:12:39.128550+00:00 0:00:01.675808 19609 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T10:12:35.205971+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-21T09:00:00+00:00 PythonOperator 2021-04-21T10:12:21.365242+00:00 2021-04-21T10:12:24.590551+00:00 0:00:03.225309 19608 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T10:12:19.152480+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-21T09:00:00+00:00 PythonOperator 2021-04-21T10:12:17.285318+00:00 2021-04-21T10:12:20.286721+00:00 0:00:03.001403 19607 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T10:12:15.159178+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-21T09:00:00+00:00 TriggerDagRunOperator 2021-04-21T10:12:07.671353+00:00 2021-04-21T10:12:08.194838+00:00 0:00:00.523485 19606 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T10:12:05.167697+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-21T09:00:00+00:00 TriggerDagRunOperator 2021-04-21T10:12:07.561491+00:00 2021-04-21T10:12:07.983420+00:00 0:00:00.421929 19605 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T10:12:05.167658+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-21T09:05:00+00:00 EmrJobFlowSensor 2021-04-21T10:06:14.616093+00:00 2021-04-21T10:15:17.112615+00:00 0:09:02.496522 19604 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T10:06:12.412024+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-21T09:05:00+00:00 EmrCreateJobFlowOperator 2021-04-21T10:05:54.718405+00:00 2021-04-21T10:05:56.452080+00:00 0:00:01.733675 19603 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T10:05:52.379160+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-21T09:05:00+00:00 PythonOperator 2021-04-21T10:05:24.655035+00:00 2021-04-21T10:05:27.618928+00:00 0:00:02.963893 19602 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T10:05:22.366028+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-21T09:00:00+00:00 EmrJobFlowSensor 2021-04-21T10:00:48.388920+00:00 2021-04-21T10:11:51.333109+00:00 0:11:02.944189 19601 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T10:00:46.058531+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-21T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T10:00:26.335728+00:00 2021-04-21T10:00:28.201150+00:00 0:00:01.865422 19600 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-21T10:00:23.976031+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-21T09:00:00+00:00 PythonOperator 2021-04-21T10:00:06.090291+00:00 2021-04-21T10:00:09.800184+00:00 0:00:03.709893 19599 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-21T10:00:03.912062+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-21T08:00:00+00:00 EmrJobFlowSensor 2021-04-21T09:29:07.093100+00:00 2021-04-21T09:40:10.044913+00:00 0:11:02.951813 19598 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T09:29:04.841269+00:00 3 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-21T08:00:00+00:00 EmrJobFlowSensor 2021-04-21T09:28:50.825258+00:00 2021-04-21T09:37:53.536418+00:00 0:09:02.711160 19597 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T09:28:48.581319+00:00 3 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-21T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T09:28:34.765073+00:00 2021-04-21T09:28:36.508916+00:00 0:00:01.743843 19596 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T09:28:32.566555+00:00 3 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-21T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T09:28:24.932996+00:00 2021-04-21T09:28:26.720526+00:00 0:00:01.787530 19595 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T09:28:22.558545+00:00 3 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-21T08:00:00+00:00 PythonOperator 2021-04-21T09:28:10.752120+00:00 2021-04-21T09:28:13.961045+00:00 0:00:03.208925 19594 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T09:28:08.544352+00:00 3 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-21T08:00:00+00:00 PythonOperator 2021-04-21T09:28:04.866957+00:00 2021-04-21T09:28:07.892933+00:00 0:00:03.025976 19593 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T09:28:02.539877+00:00 3 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-21T08:00:00+00:00 TriggerDagRunOperator 2021-04-21T09:26:04.989602+00:00 2021-04-21T09:26:05.533767+00:00 0:00:00.544165 19592 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T09:26:02.411243+00:00 5 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-21T08:00:00+00:00 TriggerDagRunOperator 2021-04-21T09:26:04.888398+00:00 2021-04-21T09:26:05.400882+00:00 0:00:00.512484 19591 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T09:26:02.411280+00:00 5 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-21T08:00:00+00:00 EmrJobFlowSensor 2021-04-21T09:14:37.420348+00:00 2021-04-21T09:23:40.042205+00:00 0:09:02.621857 19585 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T09:14:35.248216+00:00 3 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-21T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T09:14:15.540999+00:00 2021-04-21T09:14:17.249359+00:00 0:00:01.708360 19584 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-21T09:14:13.226628+00:00 3 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-21T08:00:00+00:00 PythonOperator 2021-04-21T09:13:47.425644+00:00 2021-04-21T09:13:50.405399+00:00 0:00:02.979755 19583 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-21T09:13:45.201930+00:00 3 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-21T08:05:00+00:00 EmrJobFlowSensor 2021-04-21T09:06:00.880128+00:00 2021-04-21T09:15:03.576800+00:00 0:09:02.696672 19574 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T09:05:58.471770+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-21T08:05:00+00:00 EmrCreateJobFlowOperator 2021-04-21T09:05:38.567094+00:00 2021-04-21T09:05:40.294602+00:00 0:00:01.727508 19573 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T09:05:36.242299+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-21T08:05:00+00:00 PythonOperator 2021-04-21T09:05:16.561660+00:00 2021-04-21T09:05:19.496355+00:00 0:00:02.934695 19572 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T09:05:14.277777+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-21T07:00:00+00:00 EmrJobFlowSensor 2021-04-21T08:12:00.880782+00:00 2021-04-21T08:21:03.776125+00:00 0:09:02.895343 19567 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T08:11:58.465561+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-21T07:00:00+00:00 EmrJobFlowSensor 2021-04-21T08:11:54.852132+00:00 2021-04-21T08:20:57.654064+00:00 0:09:02.801932 19566 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T08:11:52.373296+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-21T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T08:11:38.711758+00:00 2021-04-21T08:11:40.394126+00:00 0:00:01.682368 19565 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T08:11:36.361603+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-21T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T08:11:34.844852+00:00 2021-04-21T08:11:36.673492+00:00 0:00:01.828640 19564 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T08:11:32.355975+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-21T07:00:00+00:00 PythonOperator 2021-04-21T08:11:16.391119+00:00 2021-04-21T08:11:19.333120+00:00 0:00:02.942001 19563 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T08:11:14.218733+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-21T07:00:00+00:00 PythonOperator 2021-04-21T08:11:12.479770+00:00 2021-04-21T08:11:16.150438+00:00 0:00:03.670668 19562 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T08:11:10.213745+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-21T07:00:00+00:00 TriggerDagRunOperator 2021-04-21T08:10:58.929700+00:00 2021-04-21T08:10:59.454592+00:00 0:00:00.524892 19561 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T08:10:56.205593+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-21T07:00:00+00:00 TriggerDagRunOperator 2021-04-21T08:10:58.493562+00:00 2021-04-21T08:10:58.902785+00:00 0:00:00.409223 19560 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T08:10:56.205556+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-21T07:05:00+00:00 EmrJobFlowSensor 2021-04-21T08:05:58.079343+00:00 2021-04-21T08:14:01.060828+00:00 0:08:02.981485 19559 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T08:05:55.843422+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-21T07:05:00+00:00 EmrCreateJobFlowOperator 2021-04-21T08:05:36.081349+00:00 2021-04-21T08:05:37.900639+00:00 0:00:01.819290 19558 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T08:05:33.680312+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-21T07:05:00+00:00 PythonOperator 2021-04-21T08:05:15.844554+00:00 2021-04-21T08:05:18.786974+00:00 0:00:02.942420 19557 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T08:05:13.625310+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-21T07:00:00+00:00 EmrJobFlowSensor 2021-04-21T08:00:47.512743+00:00 2021-04-21T08:10:50.358095+00:00 0:10:02.845352 19556 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T08:00:45.146979+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-21T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T08:00:27.273214+00:00 2021-04-21T08:00:28.941496+00:00 0:00:01.668282 19555 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-21T08:00:25.103082+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-21T07:00:00+00:00 PythonOperator 2021-04-21T08:00:05.657357+00:00 2021-04-21T08:00:08.571439+00:00 0:00:02.914082 19554 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-21T08:00:03.086898+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-21T06:00:00+00:00 EmrJobFlowSensor 2021-04-21T07:11:24.800863+00:00 2021-04-21T07:21:27.509515+00:00 0:10:02.708652 19552 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T07:11:22.532651+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-21T06:00:00+00:00 EmrJobFlowSensor 2021-04-21T07:11:06.769367+00:00 2021-04-21T07:19:09.302051+00:00 0:08:02.532684 19551 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T07:11:04.521239+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-21T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T07:11:03.278698+00:00 2021-04-21T07:11:05.106563+00:00 0:00:01.827865 19550 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T07:11:00.515928+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-21T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T07:10:46.760382+00:00 2021-04-21T07:10:48.515455+00:00 0:00:01.755073 19549 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T07:10:44.482214+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-21T06:00:00+00:00 PythonOperator 2021-04-21T07:10:40.742447+00:00 2021-04-21T07:10:43.937538+00:00 0:00:03.195091 19548 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T07:10:38.449087+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-21T06:00:00+00:00 PythonOperator 2021-04-21T07:10:25.109124+00:00 2021-04-21T07:10:28.006966+00:00 0:00:02.897842 19547 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T07:10:22.411613+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-21T06:00:00+00:00 TriggerDagRunOperator 2021-04-21T07:10:16.703191+00:00 2021-04-21T07:10:17.279845+00:00 0:00:00.576654 19546 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T07:10:14.396183+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-21T06:00:00+00:00 TriggerDagRunOperator 2021-04-21T07:10:16.655474+00:00 2021-04-21T07:10:17.083371+00:00 0:00:00.427897 19545 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T07:10:14.396155+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-21T06:05:00+00:00 EmrJobFlowSensor 2021-04-21T07:05:50.100122+00:00 2021-04-21T07:13:52.484455+00:00 0:08:02.384333 19544 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T07:05:47.960532+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-21T06:05:00+00:00 EmrCreateJobFlowOperator 2021-04-21T07:05:28.202734+00:00 2021-04-21T07:05:29.995900+00:00 0:00:01.793166 19543 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T07:05:25.939223+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-21T06:05:00+00:00 PythonOperator 2021-04-21T07:05:06.145549+00:00 2021-04-21T07:05:09.050705+00:00 0:00:02.905156 19542 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T07:05:03.952900+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-21T06:00:00+00:00 EmrJobFlowSensor 2021-04-21T07:00:59.559523+00:00 2021-04-21T07:10:02.295031+00:00 0:09:02.735508 19541 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T07:00:57.229206+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-21T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T07:00:39.665890+00:00 2021-04-21T07:00:41.526322+00:00 0:00:01.860432 19540 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-21T07:00:37.212066+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-21T06:00:00+00:00 PythonOperator 2021-04-21T07:00:18.181875+00:00 2021-04-21T07:00:21.527790+00:00 0:00:03.345915 19539 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-21T07:00:15.261360+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-21T05:00:00+00:00 EmrJobFlowSensor 2021-04-21T06:16:35.417639+00:00 2021-04-21T06:26:38.281104+00:00 0:10:02.863465 19538 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T06:16:32.963778+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-21T05:00:00+00:00 EmrJobFlowSensor 2021-04-21T06:16:35.319034+00:00 2021-04-21T06:25:38.088518+00:00 0:09:02.769484 19537 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T06:16:32.963749+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-21T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T06:16:15.534456+00:00 2021-04-21T06:16:17.316518+00:00 0:00:01.782062 19536 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T06:16:12.927310+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-21T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T06:16:13.595087+00:00 2021-04-21T06:16:15.741375+00:00 0:00:02.146288 19535 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T06:16:10.923506+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-21T05:00:00+00:00 PythonOperator 2021-04-21T06:15:53.094139+00:00 2021-04-21T06:15:55.981801+00:00 0:00:02.887662 19534 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T06:15:50.905582+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-21T05:00:00+00:00 PythonOperator 2021-04-21T06:15:51.189116+00:00 2021-04-21T06:15:54.829025+00:00 0:00:03.639909 19533 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T06:15:48.904774+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-21T05:00:00+00:00 TriggerDagRunOperator 2021-04-21T06:15:39.812809+00:00 2021-04-21T06:15:40.503563+00:00 0:00:00.690754 19532 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T06:15:36.722849+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-21T05:00:00+00:00 TriggerDagRunOperator 2021-04-21T06:15:39.573163+00:00 2021-04-21T06:15:39.992160+00:00 0:00:00.418997 19531 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T06:15:36.722815+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-21T05:05:00+00:00 EmrJobFlowSensor 2021-04-21T06:06:07.887156+00:00 2021-04-21T06:14:10.494923+00:00 0:08:02.607767 19529 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T06:06:05.585545+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-21T05:05:00+00:00 EmrCreateJobFlowOperator 2021-04-21T06:05:43.684133+00:00 2021-04-21T06:05:45.318340+00:00 0:00:01.634207 19528 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T06:05:41.446551+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-21T05:05:00+00:00 PythonOperator 2021-04-21T06:05:19.993482+00:00 2021-04-21T06:05:23.000676+00:00 0:00:03.007194 19527 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T06:05:17.434774+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-21T05:00:00+00:00 EmrJobFlowSensor 2021-04-21T06:01:07.607341+00:00 2021-04-21T06:11:10.304105+00:00 0:10:02.696764 19526 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T06:01:05.174168+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-21T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T06:00:45.390373+00:00 2021-04-21T06:00:47.085558+00:00 0:00:01.695185 19525 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-21T06:00:43.094297+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-21T05:00:00+00:00 PythonOperator 2021-04-21T06:00:25.307347+00:00 2021-04-21T06:00:28.318644+00:00 0:00:03.011297 19524 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-21T06:00:23.027036+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-21T04:00:00+00:00 EmrJobFlowSensor 2021-04-21T05:12:10.511384+00:00 2021-04-21T05:22:13.310915+00:00 0:10:02.799531 19523 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T05:12:08.073091+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-21T04:00:00+00:00 EmrJobFlowSensor 2021-04-21T05:11:56.422509+00:00 2021-04-21T05:21:59.366203+00:00 0:10:02.943694 19522 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T05:11:54.066100+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-21T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T05:11:48.405304+00:00 2021-04-21T05:11:50.123847+00:00 0:00:01.718543 19521 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T05:11:46.056280+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-21T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T05:11:34.418939+00:00 2021-04-21T05:11:36.257367+00:00 0:00:01.838428 19520 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T05:11:32.047013+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-21T04:00:00+00:00 PythonOperator 2021-04-21T05:11:28.251836+00:00 2021-04-21T05:11:31.505503+00:00 0:00:03.253667 19519 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T05:11:25.939274+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-21T04:00:00+00:00 PythonOperator 2021-04-21T05:11:14.272527+00:00 2021-04-21T05:11:17.387049+00:00 0:00:03.114522 19518 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T05:11:11.923776+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-21T04:00:00+00:00 TriggerDagRunOperator 2021-04-21T05:11:08.418665+00:00 2021-04-21T05:11:08.878078+00:00 0:00:00.459413 19517 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T05:11:05.919141+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-21T04:00:00+00:00 TriggerDagRunOperator 2021-04-21T05:11:08.366525+00:00 2021-04-21T05:11:08.950990+00:00 0:00:00.584465 19516 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T05:11:05.919113+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-21T04:05:00+00:00 EmrJobFlowSensor 2021-04-21T05:05:56.242784+00:00 2021-04-21T05:13:58.676890+00:00 0:08:02.434106 19514 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T05:05:53.975373+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-21T04:05:00+00:00 EmrCreateJobFlowOperator 2021-04-21T05:05:34.447265+00:00 2021-04-21T05:05:36.164009+00:00 0:00:01.716744 19513 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T05:05:31.891776+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-21T04:05:00+00:00 PythonOperator 2021-04-21T05:05:12.103878+00:00 2021-04-21T05:05:14.968378+00:00 0:00:02.864500 19512 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T05:05:09.869633+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-21T04:00:00+00:00 EmrJobFlowSensor 2021-04-21T05:00:51.625728+00:00 2021-04-21T05:10:54.401887+00:00 0:10:02.776159 19511 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T05:00:49.445110+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-21T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T05:00:29.799939+00:00 2021-04-21T05:00:31.505347+00:00 0:00:01.705408 19510 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-21T05:00:27.443376+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-21T04:00:00+00:00 PythonOperator 2021-04-21T05:00:09.688521+00:00 2021-04-21T05:00:13.768610+00:00 0:00:04.080089 19509 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-21T05:00:07.412287+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-21T03:00:00+00:00 EmrJobFlowSensor 2021-04-21T04:12:16.776816+00:00 2021-04-21T04:20:19.236915+00:00 0:08:02.460099 19508 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T04:12:14.460468+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-21T03:00:00+00:00 EmrJobFlowSensor 2021-04-21T04:12:04.796007+00:00 2021-04-21T04:22:07.746740+00:00 0:10:02.950733 19507 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T04:12:02.335876+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-21T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T04:11:56.670644+00:00 2021-04-21T04:11:58.476318+00:00 0:00:01.805674 19506 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T04:11:54.385857+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-21T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T04:11:42.531250+00:00 2021-04-21T04:11:44.351521+00:00 0:00:01.820271 19505 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T04:11:40.312747+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-21T03:00:00+00:00 PythonOperator 2021-04-21T04:11:34.657674+00:00 2021-04-21T04:11:37.673629+00:00 0:00:03.015955 19504 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T04:11:32.314048+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-21T03:00:00+00:00 PythonOperator 2021-04-21T04:11:22.740947+00:00 2021-04-21T04:11:26.329659+00:00 0:00:03.588712 19503 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T04:11:20.299355+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-21T03:00:00+00:00 TriggerDagRunOperator 2021-04-21T04:11:14.838469+00:00 2021-04-21T04:11:15.403087+00:00 0:00:00.564618 19502 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T04:11:10.290100+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-21T03:05:00+00:00 EmrJobFlowSensor 2021-04-21T04:11:14.781834+00:00 2021-04-21T04:20:17.452423+00:00 0:09:02.670589 19501 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T04:11:10.290114+00:00 2 default_pool