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 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
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-21T03:00:00+00:00 TriggerDagRunOperator 2021-04-21T04:11:12.889398+00:00 2021-04-21T04:11:13.367270+00:00 0:00:00.477872 19500 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T04:11:10.290069+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-21T03:05:00+00:00 EmrCreateJobFlowOperator 2021-04-21T04:10:50.782072+00:00 2021-04-21T04:10:52.412907+00:00 0:00:01.630835 19499 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T04:10:48.344362+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-21T03:05:00+00:00 PythonOperator 2021-04-21T04:10:30.453366+00:00 2021-04-21T04:10:33.912257+00:00 0:00:03.458891 19498 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T04:10:27.473304+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-21T03:00:00+00:00 EmrJobFlowSensor 2021-04-21T04:01:00.426003+00:00 2021-04-21T04:11:03.430060+00:00 0:10:03.004057 19496 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T04:00:57.721795+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-21T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T04:00:38.419826+00:00 2021-04-21T04:00:40.375607+00:00 0:00:01.955781 19495 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-21T04:00:35.763176+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-21T03:00:00+00:00 PythonOperator 2021-04-21T04:00:16.082798+00:00 2021-04-21T04:00:19.364246+00:00 0:00:03.281448 19494 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-21T04:00:13.686373+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-21T02:00:00+00:00 EmrJobFlowSensor 2021-04-21T03:14:39.996737+00:00 2021-04-21T03:24:42.899991+00:00 0:10:02.903254 19493 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T03:14:37.484442+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-21T02:00:00+00:00 EmrJobFlowSensor 2021-04-21T03:14:29.975703+00:00 2021-04-21T03:24:32.810009+00:00 0:10:02.834306 19492 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T03:14:27.460576+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-21T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T03:14:19.940338+00:00 2021-04-21T03:14:21.790910+00:00 0:00:01.850572 19491 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T03:14:17.544140+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-21T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T03:14:07.700779+00:00 2021-04-21T03:14:09.551804+00:00 0:00:01.851025 19490 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T03:14:05.399405+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-21T02:00:00+00:00 PythonOperator 2021-04-21T03:13:57.721099+00:00 2021-04-21T03:14:00.884972+00:00 0:00:03.163873 19489 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T03:13:55.454171+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-21T02:00:00+00:00 PythonOperator 2021-04-21T03:13:47.705859+00:00 2021-04-21T03:13:51.075114+00:00 0:00:03.369255 19488 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T03:13:45.362992+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-21T02:00:00+00:00 TriggerDagRunOperator 2021-04-21T03:13:41.882432+00:00 2021-04-21T03:13:42.707143+00:00 0:00:00.824711 19487 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T03:13:39.316789+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-21T02:00:00+00:00 TriggerDagRunOperator 2021-04-21T03:13:41.574293+00:00 2021-04-21T03:13:42.042071+00:00 0:00:00.467778 19486 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T03:13:39.316755+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-21T02:05:00+00:00 EmrJobFlowSensor 2021-04-21T03:06:07.020131+00:00 2021-04-21T03:14:09.515532+00:00 0:08:02.495401 19485 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T03:06:04.732320+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-21T02:05:00+00:00 EmrCreateJobFlowOperator 2021-04-21T03:05:46.761356+00:00 2021-04-21T03:05:48.413159+00:00 0:00:01.651803 19484 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T03:05:44.602654+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-21T02:05:00+00:00 PythonOperator 2021-04-21T03:05:24.868832+00:00 2021-04-21T03:05:28.004135+00:00 0:00:03.135303 19483 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T03:05:22.591452+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-21T02:00:00+00:00 EmrJobFlowSensor 2021-04-21T03:03:24.827252+00:00 2021-04-21T03:13:27.634362+00:00 0:10:02.807110 19482 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T03:03:22.558889+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-21T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T03:03:02.838545+00:00 2021-04-21T03:03:04.762544+00:00 0:00:01.923999 19481 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-21T03:03:00.445312+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-21T02:00:00+00:00 PythonOperator 2021-04-21T03:02:43.070085+00:00 2021-04-21T03:02:46.385616+00:00 0:00:03.315531 19480 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-21T03:02:40.429321+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-21T01:00:00+00:00 EmrJobFlowSensor 2021-04-21T02:11:20.585352+00:00 2021-04-21T02:20:23.314799+00:00 0:09:02.729447 19478 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T02:11:18.306481+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-21T01:00:00+00:00 EmrJobFlowSensor 2021-04-21T02:11:04.901704+00:00 2021-04-21T02:21:07.797919+00:00 0:10:02.896215 19477 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T02:11:02.349339+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-21T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T02:10:58.636744+00:00 2021-04-21T02:11:00.387382+00:00 0:00:01.750638 19476 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T02:10:56.271162+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-21T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T02:10:42.598263+00:00 2021-04-21T02:10:44.289889+00:00 0:00:01.691626 19475 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T02:10:40.279633+00:00 2 default_pool