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 vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-26T13:05:00+00:00 EmrCreateJobFlowOperator 2021-04-26T14:05:37.433496+00:00 2021-04-26T14:05:39.181608+00:00 0:00:01.748112 21488 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T14:05:34.948573+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-26T13:05:00+00:00 PythonOperator 2021-04-26T14:05:15.148688+00:00 2021-04-26T14:05:18.155263+00:00 0:00:03.006575 21487 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T14:05:12.807593+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-26T13:00:00+00:00 EmrJobFlowSensor 2021-04-26T14:00:50.785159+00:00 2021-04-26T14:09:53.465784+00:00 0:09:02.680625 21486 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T14:00:48.450372+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-26T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T14:00:28.653164+00:00 2021-04-26T14:00:30.403271+00:00 0:00:01.750107 21485 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-26T14:00:26.349697+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-26T13:00:00+00:00 PythonOperator 2021-04-26T14:00:08.605592+00:00 2021-04-26T14:00:11.644910+00:00 0:00:03.039318 21484 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-26T14:00:06.329570+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-26T12:00:00+00:00 EmrJobFlowSensor 2021-04-26T13:17:36.875881+00:00 2021-04-26T13:26:39.440932+00:00 0:09:02.565051 21483 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T13:17:34.418165+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-26T12:00:00+00:00 EmrJobFlowSensor 2021-04-26T13:17:32.875979+00:00 2021-04-26T13:27:35.685402+00:00 0:10:02.809423 21482 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T13:17:30.416701+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-26T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T13:17:14.726100+00:00 2021-04-26T13:17:16.455538+00:00 0:00:01.729438 21481 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T13:17:12.462451+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-26T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T13:17:10.780639+00:00 2021-04-26T13:17:12.546284+00:00 0:00:01.765645 21480 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T13:17:08.454549+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-26T12:05:00+00:00 EmrJobFlowSensor 2021-04-26T13:16:57.128105+00:00 2021-04-26T13:24:59.471265+00:00 0:08:02.343160 21479 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T13:16:54.386546+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-26T12:00:00+00:00 PythonOperator 2021-04-26T13:16:52.529358+00:00 2021-04-26T13:16:55.855778+00:00 0:00:03.326420 21478 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T13:16:50.360948+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-26T12:00:00+00:00 PythonOperator 2021-04-26T13:16:50.745267+00:00 2021-04-26T13:16:54.031499+00:00 0:00:03.286232 21477 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T13:16:48.383631+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-26T12:05:00+00:00 EmrCreateJobFlowOperator 2021-04-26T13:16:36.978864+00:00 2021-04-26T13:16:38.619286+00:00 0:00:01.640422 21476 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T13:16:34.320628+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-26T12:00:00+00:00 TriggerDagRunOperator 2021-04-26T13:16:34.803665+00:00 2021-04-26T13:16:35.562791+00:00 0:00:00.759126 21475 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T13:16:32.326476+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T12:00:00+00:00 TriggerDagRunOperator 2021-04-26T13:16:34.688193+00:00 2021-04-26T13:16:35.396782+00:00 0:00:00.708589 21474 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T13:16:32.326505+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-26T12:05:00+00:00 PythonOperator 2021-04-26T13:16:15.146454+00:00 2021-04-26T13:16:18.093191+00:00 0:00:02.946737 21473 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T13:16:12.308743+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-26T12:00:00+00:00 EmrJobFlowSensor 2021-04-26T13:16:15.192709+00:00 2021-04-26T13:16:16.778066+00:00 0:00:01.585357 21472 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T13:16:12.308786+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-26T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T13:00:30.626574+00:00 2021-04-26T13:00:32.343192+00:00 0:00:01.716618 21470 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-26T13:00:28.263205+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-26T12:00:00+00:00 PythonOperator 2021-04-26T13:00:10.593256+00:00 2021-04-26T13:00:13.681004+00:00 0:00:03.087748 21469 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-26T13:00:08.187427+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-26T11:00:00+00:00 EmrJobFlowSensor 2021-04-26T12:13:01.482045+00:00 2021-04-26T12:22:04.264217+00:00 0:09:02.782172 21468 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T12:12:59.206189+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-26T11:00:00+00:00 EmrJobFlowSensor 2021-04-26T12:12:51.421557+00:00 2021-04-26T12:23:54.249433+00:00 0:11:02.827876 21467 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T12:12:49.196423+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-26T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T12:12:35.586477+00:00 2021-04-26T12:12:37.262309+00:00 0:00:01.675832 21466 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T12:12:33.255464+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-26T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T12:12:31.602166+00:00 2021-04-26T12:12:33.323879+00:00 0:00:01.721713 21465 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T12:12:29.245101+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-26T11:00:00+00:00 PythonOperator 2021-04-26T12:12:14.552933+00:00 2021-04-26T12:12:17.527465+00:00 0:00:02.974532 21464 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T12:12:11.146218+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-26T11:00:00+00:00 PythonOperator 2021-04-26T12:12:09.399769+00:00 2021-04-26T12:12:13.397992+00:00 0:00:03.998223 21463 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T12:12:07.156849+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T11:00:00+00:00 TriggerDagRunOperator 2021-04-26T12:12:05.678357+00:00 2021-04-26T12:12:06.285527+00:00 0:00:00.607170 21462 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T12:12:03.088035+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-26T11:00:00+00:00 TriggerDagRunOperator 2021-04-26T12:12:05.363478+00:00 2021-04-26T12:12:05.790365+00:00 0:00:00.426887 21461 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T12:12:03.087986+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-26T11:05:00+00:00 EmrJobFlowSensor 2021-04-26T12:05:54.581567+00:00 2021-04-26T12:14:57.211383+00:00 0:09:02.629816 21460 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T12:05:52.457880+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-26T11:05:00+00:00 EmrCreateJobFlowOperator 2021-04-26T12:05:34.740814+00:00 2021-04-26T12:05:36.588803+00:00 0:00:01.847989 21459 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T12:05:32.443475+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-26T11:05:00+00:00 PythonOperator 2021-04-26T12:05:12.805204+00:00 2021-04-26T12:05:15.725202+00:00 0:00:02.919998 21458 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T12:05:10.422650+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-26T11:00:00+00:00 EmrJobFlowSensor 2021-04-26T12:01:40.386400+00:00 2021-04-26T12:11:43.215686+00:00 0:10:02.829286 21457 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T12:01:38.114663+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-26T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T12:01:18.306423+00:00 2021-04-26T12:01:20.129026+00:00 0:00:01.822603 21456 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-26T12:01:16.088278+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-26T11:00:00+00:00 PythonOperator 2021-04-26T12:00:58.851873+00:00 2021-04-26T12:01:01.850561+00:00 0:00:02.998688 21455 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-26T12:00:56.127518+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-26T10:00:00+00:00 EmrJobFlowSensor 2021-04-26T11:11:40.216042+00:00 2021-04-26T11:20:42.911988+00:00 0:09:02.695946 21453 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T11:11:37.851849+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-26T10:00:00+00:00 EmrJobFlowSensor 2021-04-26T11:11:38.018433+00:00 2021-04-26T11:22:40.753135+00:00 0:11:02.734702 21452 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T11:11:35.814957+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-26T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T11:11:18.739138+00:00 2021-04-26T11:11:20.423404+00:00 0:00:01.684266 21451 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T11:11:15.863123+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-26T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T11:11:16.172790+00:00 2021-04-26T11:11:18.315587+00:00 0:00:02.142797 21450 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T11:11:13.863699+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-26T10:00:00+00:00 PythonOperator 2021-04-26T11:10:56.340920+00:00 2021-04-26T11:10:59.594899+00:00 0:00:03.253979 21449 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T11:10:53.868466+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-26T10:00:00+00:00 PythonOperator 2021-04-26T11:10:56.195320+00:00 2021-04-26T11:10:59.158539+00:00 0:00:02.963219 21448 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T11:10:53.868415+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-26T10:00:00+00:00 TriggerDagRunOperator 2021-04-26T11:10:40.042008+00:00 2021-04-26T11:10:40.559113+00:00 0:00:00.517105 21447 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T11:10:37.741767+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T10:00:00+00:00 TriggerDagRunOperator 2021-04-26T11:10:39.993820+00:00 2021-04-26T11:10:40.402245+00:00 0:00:00.408425 21446 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T11:10:37.741801+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-26T10:05:00+00:00 EmrJobFlowSensor 2021-04-26T11:06:01.619855+00:00 2021-04-26T11:15:04.424015+00:00 0:09:02.804160 21445 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T11:05:59.413838+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-26T10:05:00+00:00 EmrCreateJobFlowOperator 2021-04-26T11:05:39.767399+00:00 2021-04-26T11:05:41.415999+00:00 0:00:01.648600 21444 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T11:05:37.461450+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-26T10:05:00+00:00 PythonOperator 2021-04-26T11:05:17.577312+00:00 2021-04-26T11:05:20.539192+00:00 0:00:02.961880 21443 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T11:05:15.366454+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-26T10:00:00+00:00 EmrJobFlowSensor 2021-04-26T11:01:09.704411+00:00 2021-04-26T11:10:12.471931+00:00 0:09:02.767520 21442 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T11:01:07.051193+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-26T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T11:00:47.149595+00:00 2021-04-26T11:00:48.872112+00:00 0:00:01.722517 21441 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-26T11:00:44.952067+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-26T10:00:00+00:00 PythonOperator 2021-04-26T11:00:27.321163+00:00 2021-04-26T11:00:30.361302+00:00 0:00:03.040139 21440 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-26T11:00:24.936681+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-26T09:00:00+00:00 EmrJobFlowSensor 2021-04-26T10:13:18.229118+00:00 2021-04-26T10:23:21.044586+00:00 0:10:02.815468 21438 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T10:13:16.062082+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-26T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T10:12:56.210494+00:00 2021-04-26T10:12:57.932944+00:00 0:00:01.722450 21437 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T10:12:54.049254+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-26T09:00:00+00:00 PythonOperator 2021-04-26T10:12:26.319235+00:00 2021-04-26T10:12:29.639460+00:00 0:00:03.320225 21436 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T10:12:24.013527+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-26T09:00:00+00:00 EmrJobFlowSensor 2021-04-26T10:12:12.314680+00:00 2021-04-26T10:20:15.034832+00:00 0:08:02.720152 21435 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T10:12:10.002218+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-26T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T10:11:42.161967+00:00 2021-04-26T10:11:43.909246+00:00 0:00:01.747279 21434 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T10:11:39.972726+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-26T09:00:00+00:00 PythonOperator 2021-04-26T10:11:16.120041+00:00 2021-04-26T10:11:19.100728+00:00 0:00:02.980687 21433 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T10:11:13.947075+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-26T09:00:00+00:00 TriggerDagRunOperator 2021-04-26T10:11:10.313709+00:00 2021-04-26T10:11:10.904929+00:00 0:00:00.591220 21432 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T10:11:07.942618+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T09:00:00+00:00 TriggerDagRunOperator 2021-04-26T10:11:10.264468+00:00 2021-04-26T10:11:10.732307+00:00 0:00:00.467839 21431 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T10:11:07.942646+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-26T09:05:00+00:00 EmrJobFlowSensor 2021-04-26T10:06:03.847951+00:00 2021-04-26T10:14:06.381490+00:00 0:08:02.533539 21430 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T10:06:01.528016+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-26T09:05:00+00:00 EmrCreateJobFlowOperator 2021-04-26T10:05:41.728928+00:00 2021-04-26T10:05:43.375381+00:00 0:00:01.646453 21429 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T10:05:39.509366+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-26T09:05:00+00:00 PythonOperator 2021-04-26T10:05:19.677561+00:00 2021-04-26T10:05:22.631355+00:00 0:00:02.953794 21428 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T10:05:17.498000+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-26T09:00:00+00:00 EmrJobFlowSensor 2021-04-26T10:00:57.669853+00:00 2021-04-26T10:11:00.409871+00:00 0:10:02.740018 21427 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T10:00:55.260754+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-26T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T10:00:37.768016+00:00 2021-04-26T10:00:39.477811+00:00 0:00:01.709795 21426 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-26T10:00:35.159627+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-26T09:00:00+00:00 PythonOperator 2021-04-26T10:00:05.451642+00:00 2021-04-26T10:00:08.509747+00:00 0:00:03.058105 21425 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-26T10:00:03.128294+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-26T08:00:00+00:00 EmrJobFlowSensor 2021-04-26T09:12:26.670299+00:00 2021-04-26T09:22:29.490203+00:00 0:10:02.819904 21423 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T09:12:24.157876+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-26T08:00:00+00:00 EmrJobFlowSensor 2021-04-26T09:12:18.572561+00:00 2021-04-26T09:23:21.552001+00:00 0:11:02.979440 21422 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T09:12:16.167455+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-26T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T09:12:04.829653+00:00 2021-04-26T09:12:06.710836+00:00 0:00:01.881183 21421 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T09:12:02.154125+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-26T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T09:11:56.409477+00:00 2021-04-26T09:11:58.160938+00:00 0:00:01.751461 21420 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T09:11:54.146305+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-26T08:00:00+00:00 PythonOperator 2021-04-26T09:11:42.291090+00:00 2021-04-26T09:11:45.401453+00:00 0:00:03.110363 21419 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T09:11:40.036083+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-26T08:00:00+00:00 PythonOperator 2021-04-26T09:11:36.212671+00:00 2021-04-26T09:11:39.442351+00:00 0:00:03.229680 21418 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T09:11:34.036189+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-26T08:00:00+00:00 TriggerDagRunOperator 2021-04-26T09:11:20.355441+00:00 2021-04-26T09:11:20.920500+00:00 0:00:00.565059 21417 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T09:11:18.015369+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T08:00:00+00:00 TriggerDagRunOperator 2021-04-26T09:11:20.294243+00:00 2021-04-26T09:11:20.727906+00:00 0:00:00.433663 21416 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T09:11:18.015403+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-26T08:05:00+00:00 EmrJobFlowSensor 2021-04-26T09:06:01.804491+00:00 2021-04-26T09:15:04.394569+00:00 0:09:02.590078 21415 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T09:05:59.492840+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-26T08:05:00+00:00 EmrCreateJobFlowOperator 2021-04-26T09:05:39.704702+00:00 2021-04-26T09:05:41.437509+00:00 0:00:01.732807 21414 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T09:05:37.424243+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-26T08:05:00+00:00 PythonOperator 2021-04-26T09:05:17.818334+00:00 2021-04-26T09:05:20.788875+00:00 0:00:02.970541 21413 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T09:05:15.452767+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-26T08:00:00+00:00 EmrJobFlowSensor 2021-04-26T09:00:59.420138+00:00 2021-04-26T09:11:02.255597+00:00 0:10:02.835459 21412 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T09:00:56.985375+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-26T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T09:00:37.231981+00:00 2021-04-26T09:00:38.932173+00:00 0:00:01.700192 21411 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-26T09:00:34.961010+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-26T08:00:00+00:00 PythonOperator 2021-04-26T09:00:17.206911+00:00 2021-04-26T09:00:20.251784+00:00 0:00:03.044873 21410 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-26T09:00:14.887941+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-26T07:00:00+00:00 EmrJobFlowSensor 2021-04-26T08:11:29.656408+00:00 2021-04-26T08:22:32.698858+00:00 0:11:03.042450 21408 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T08:11:27.177134+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-26T07:00:00+00:00 EmrJobFlowSensor 2021-04-26T08:11:15.498500+00:00 2021-04-26T08:21:18.303332+00:00 0:10:02.804832 21407 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T08:11:13.165736+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-26T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T08:11:07.392687+00:00 2021-04-26T08:11:09.149003+00:00 0:00:01.756316 21406 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T08:11:05.159859+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-26T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T08:10:54.228845+00:00 2021-04-26T08:10:56.028789+00:00 0:00:01.799944 21405 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T08:10:51.260025+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-26T07:00:00+00:00 PythonOperator 2021-04-26T08:10:45.718774+00:00 2021-04-26T08:10:49.035557+00:00 0:00:03.316783 21404 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T08:10:43.184251+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-26T07:00:00+00:00 PythonOperator 2021-04-26T08:10:33.405949+00:00 2021-04-26T08:10:36.396022+00:00 0:00:02.990073 21403 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T08:10:31.173953+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-26T07:00:00+00:00 TriggerDagRunOperator 2021-04-26T08:10:05.510584+00:00 2021-04-26T08:10:05.953833+00:00 0:00:00.443249 21402 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T08:10:03.035094+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T07:00:00+00:00 TriggerDagRunOperator 2021-04-26T08:10:05.420960+00:00 2021-04-26T08:10:05.983119+00:00 0:00:00.562159 21401 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T08:10:03.035130+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-26T07:05:00+00:00 EmrJobFlowSensor 2021-04-26T08:06:14.816228+00:00 2021-04-26T08:15:17.466001+00:00 0:09:02.649773 21400 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T08:06:12.590413+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-26T07:05:00+00:00 EmrCreateJobFlowOperator 2021-04-26T08:05:54.892738+00:00 2021-04-26T08:05:56.613331+00:00 0:00:01.720593 21399 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T08:05:52.533647+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-26T07:05:00+00:00 PythonOperator 2021-04-26T08:05:24.676841+00:00 2021-04-26T08:05:27.649664+00:00 0:00:02.972823 21398 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T08:05:22.508928+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-26T07:00:00+00:00 EmrJobFlowSensor 2021-04-26T08:00:56.347161+00:00 2021-04-26T08:09:58.945645+00:00 0:09:02.598484 21397 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T08:00:54.008215+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-26T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T08:00:34.397102+00:00 2021-04-26T08:00:36.113675+00:00 0:00:01.716573 21396 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-26T08:00:32.052208+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-26T07:00:00+00:00 PythonOperator 2021-04-26T08:00:14.486793+00:00 2021-04-26T08:00:17.480194+00:00 0:00:02.993401 21395 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-26T08:00:11.966358+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-04-26T07:43:40.085018+00:00 EmrJobFlowSensor 2021-04-26T07:44:41.077639+00:00 2021-04-26T07:53:43.744561+00:00 0:09:02.666922 21393 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T07:44:38.893625+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-04-26T07:43:40.085018+00:00 EmrCreateJobFlowOperator 2021-04-26T07:44:20.949438+00:00 2021-04-26T07:44:22.711075+00:00 0:00:01.761637 21392 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T07:44:18.803018+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-04-26T07:43:40.085018+00:00 PythonOperator 2021-04-26T07:43:59.290327+00:00 2021-04-26T07:44:02.344955+00:00 0:00:03.054628 21391 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T07:43:56.779466+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-26T06:00:00+00:00 EmrJobFlowSensor 2021-04-26T07:12:20.222352+00:00 2021-04-26T07:24:23.399077+00:00 0:12:03.176725 21390 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T07:12:17.672035+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-26T06:00:00+00:00 EmrJobFlowSensor 2021-04-26T07:12:09.894345+00:00 2021-04-26T07:22:12.692901+00:00 0:10:02.798556 21389 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T07:12:07.660913+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-26T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T07:12:00.132512+00:00 2021-04-26T07:12:01.926780+00:00 0:00:01.794268 21388 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T07:11:57.663176+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-26T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T07:11:47.861742+00:00 2021-04-26T07:11:49.701046+00:00 0:00:01.839304 21387 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T07:11:45.537739+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-26T06:00:00+00:00 PythonOperator 2021-04-26T07:11:37.722809+00:00 2021-04-26T07:11:40.982437+00:00 0:00:03.259628 21386 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T07:11:35.525790+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-26T06:00:00+00:00 PythonOperator 2021-04-26T07:11:27.823013+00:00 2021-04-26T07:11:30.857766+00:00 0:00:03.034753 21385 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T07:11:25.515897+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T06:00:00+00:00 TriggerDagRunOperator 2021-04-26T07:11:14.254829+00:00 2021-04-26T07:11:14.772733+00:00 0:00:00.517904 21384 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T07:11:11.572831+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-26T06:00:00+00:00 TriggerDagRunOperator 2021-04-26T07:11:14.060509+00:00 2021-04-26T07:11:14.508789+00:00 0:00:00.448280 21383 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T07:11:11.572782+00:00 2 default_pool