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-06T05:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T06:07:09.956061+00:00 2021-04-06T06:07:11.706721+00:00 0:00:01.750660 14104 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T06:07:07.690007+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T05:05:00+00:00 PythonOperator 2021-04-06T06:06:47.974540+00:00 2021-04-06T06:06:50.739268+00:00 0:00:02.764728 14103 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T06:06:45.666960+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T05:00:00+00:00 EmrJobFlowSensor 2021-04-06T06:01:03.910774+00:00 2021-04-06T06:10:06.717021+00:00 0:09:02.806247 14101 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T06:01:01.685900+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T06:00:41.808968+00:00 2021-04-06T06:00:43.530205+00:00 0:00:01.721237 14100 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T06:00:39.644665+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T05:00:00+00:00 PythonOperator 2021-04-06T06:00:21.826256+00:00 2021-04-06T06:00:24.542992+00:00 0:00:02.716736 14099 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T06:00:19.622545+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T04:00:00+00:00 EmrJobFlowSensor 2021-04-06T05:12:10.785790+00:00 2021-04-06T05:21:13.467479+00:00 0:09:02.681689 14098 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T05:12:08.583456+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T04:00:00+00:00 EmrJobFlowSensor 2021-04-06T05:12:04.879853+00:00 2021-04-06T05:21:07.581634+00:00 0:09:02.701781 14097 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T05:12:02.547655+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T05:11:48.908851+00:00 2021-04-06T05:11:50.589161+00:00 0:00:01.680310 14096 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T05:11:46.530593+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T05:11:44.736629+00:00 2021-04-06T05:11:46.512025+00:00 0:00:01.775396 14095 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T05:11:42.530609+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T04:00:00+00:00 PythonOperator 2021-04-06T05:11:26.710775+00:00 2021-04-06T05:11:29.638334+00:00 0:00:02.927559 14094 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T05:11:24.512388+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T04:00:00+00:00 PythonOperator 2021-04-06T05:11:23.106560+00:00 2021-04-06T05:11:26.193712+00:00 0:00:03.087152 14093 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T05:11:20.564030+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T04:00:00+00:00 TriggerDagRunOperator 2021-04-06T05:11:05.356995+00:00 2021-04-06T05:11:05.872251+00:00 0:00:00.515256 14092 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T05:11:02.567336+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T04:00:00+00:00 TriggerDagRunOperator 2021-04-06T05:11:04.987948+00:00 2021-04-06T05:11:05.396040+00:00 0:00:00.408092 14091 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T05:11:02.567289+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T04:05:00+00:00 EmrJobFlowSensor 2021-04-06T05:05:54.404462+00:00 2021-04-06T05:14:57.054530+00:00 0:09:02.650068 14090 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T05:05:52.059347+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T04:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T05:05:32.301972+00:00 2021-04-06T05:05:34.068342+00:00 0:00:01.766370 14089 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T05:05:30.050824+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T04:05:00+00:00 PythonOperator 2021-04-06T05:05:12.433267+00:00 2021-04-06T05:05:15.159747+00:00 0:00:02.726480 14088 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T05:05:10.046855+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T04:00:00+00:00 EmrJobFlowSensor 2021-04-06T05:00:54.710096+00:00 2021-04-06T05:10:57.682394+00:00 0:10:02.972298 14086 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T05:00:52.140509+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T05:00:32.614004+00:00 2021-04-06T05:00:34.298636+00:00 0:00:01.684632 14085 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T05:00:30.153071+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T04:00:00+00:00 PythonOperator 2021-04-06T05:00:10.524677+00:00 2021-04-06T05:00:13.269362+00:00 0:00:02.744685 14084 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T05:00:08.072536+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T03:00:00+00:00 EmrJobFlowSensor 2021-04-06T04:14:30.230123+00:00 2021-04-06T04:23:32.853632+00:00 0:09:02.623509 14083 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T04:14:27.609859+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T03:00:00+00:00 EmrJobFlowSensor 2021-04-06T04:14:27.828453+00:00 2021-04-06T04:24:30.884089+00:00 0:10:03.055636 14082 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T04:14:25.599338+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T04:14:07.950165+00:00 2021-04-06T04:14:09.636750+00:00 0:00:01.686585 14081 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T04:14:05.646702+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T04:14:06.027246+00:00 2021-04-06T04:14:07.905806+00:00 0:00:01.878560 14080 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T04:14:03.578827+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T03:00:00+00:00 PythonOperator 2021-04-06T04:13:45.837250+00:00 2021-04-06T04:13:48.652749+00:00 0:00:02.815499 14079 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T04:13:43.523516+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T03:00:00+00:00 PythonOperator 2021-04-06T04:13:43.862083+00:00 2021-04-06T04:13:46.813138+00:00 0:00:02.951055 14078 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T04:13:41.573148+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T03:00:00+00:00 TriggerDagRunOperator 2021-04-06T04:13:21.812544+00:00 2021-04-06T04:13:22.361319+00:00 0:00:00.548775 14077 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T04:13:19.503442+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T03:00:00+00:00 TriggerDagRunOperator 2021-04-06T04:13:21.714307+00:00 2021-04-06T04:13:22.143018+00:00 0:00:00.428711 14076 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T04:13:19.503398+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T03:05:00+00:00 EmrJobFlowSensor 2021-04-06T04:05:56.668510+00:00 2021-04-06T04:14:59.195264+00:00 0:09:02.526754 14075 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T04:05:54.546756+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T03:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T04:05:36.676845+00:00 2021-04-06T04:05:38.335494+00:00 0:00:01.658649 14074 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T04:05:34.524798+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T03:05:00+00:00 PythonOperator 2021-04-06T04:05:14.681427+00:00 2021-04-06T04:05:17.332729+00:00 0:00:02.651302 14073 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T04:05:12.506050+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T03:00:00+00:00 EmrJobFlowSensor 2021-04-06T04:03:04.835692+00:00 2021-04-06T04:13:07.690181+00:00 0:10:02.854489 14072 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T04:03:02.352995+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T04:02:42.517269+00:00 2021-04-06T04:02:44.255885+00:00 0:00:01.738616 14071 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T04:02:40.256084+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T03:00:00+00:00 PythonOperator 2021-04-06T04:02:10.667191+00:00 2021-04-06T04:02:13.531373+00:00 0:00:02.864182 14070 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T04:02:08.220983+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T02:00:00+00:00 EmrJobFlowSensor 2021-04-06T03:11:28.200765+00:00 2021-04-06T03:20:30.834594+00:00 0:09:02.633829 14068 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T03:11:26.067618+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T02:00:00+00:00 EmrJobFlowSensor 2021-04-06T03:11:26.350452+00:00 2021-04-06T03:20:29.075371+00:00 0:09:02.724919 14067 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T03:11:24.076804+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T03:10:58.228032+00:00 2021-04-06T03:10:59.938259+00:00 0:00:01.710227 14066 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T03:10:56.044340+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T03:10:56.352985+00:00 2021-04-06T03:10:58.200709+00:00 0:00:01.847724 14065 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T03:10:54.048948+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T02:00:00+00:00 PythonOperator 2021-04-06T03:10:30.341151+00:00 2021-04-06T03:10:33.394046+00:00 0:00:03.052895 14064 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T03:10:28.012899+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T02:00:00+00:00 PythonOperator 2021-04-06T03:10:26.221411+00:00 2021-04-06T03:10:28.916403+00:00 0:00:02.694992 14063 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T03:10:24.016998+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T02:00:00+00:00 TriggerDagRunOperator 2021-04-06T03:10:08.445170+00:00 2021-04-06T03:10:08.970061+00:00 0:00:00.524891 14062 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T03:10:05.993137+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T02:00:00+00:00 TriggerDagRunOperator 2021-04-06T03:10:08.369477+00:00 2021-04-06T03:10:08.774885+00:00 0:00:00.405408 14061 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T03:10:05.993105+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T02:05:00+00:00 EmrJobFlowSensor 2021-04-06T03:05:55.977339+00:00 2021-04-06T03:14:58.688155+00:00 0:09:02.710816 14060 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T03:05:53.624854+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T02:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T03:05:34.123053+00:00 2021-04-06T03:05:35.860621+00:00 0:00:01.737568 14059 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T03:05:31.669032+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T02:05:00+00:00 PythonOperator 2021-04-06T03:05:11.858373+00:00 2021-04-06T03:05:14.521002+00:00 0:00:02.662629 14058 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T03:05:09.646395+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T02:00:00+00:00 EmrJobFlowSensor 2021-04-06T03:01:01.456558+00:00 2021-04-06T03:10:04.205312+00:00 0:09:02.748754 14057 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T03:00:59.236723+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T03:00:39.433074+00:00 2021-04-06T03:00:41.194465+00:00 0:00:01.761391 14056 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T03:00:37.217355+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T02:00:00+00:00 PythonOperator 2021-04-06T03:00:19.516355+00:00 2021-04-06T03:00:22.217478+00:00 0:00:02.701123 14055 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T03:00:17.198714+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T01:00:00+00:00 EmrJobFlowSensor 2021-04-06T02:10:21.120014+00:00 2021-04-06T02:19:23.814184+00:00 0:09:02.694170 14053 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T02:10:18.800200+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T01:00:00+00:00 EmrJobFlowSensor 2021-04-06T02:10:21.137684+00:00 2021-04-06T02:19:23.864685+00:00 0:09:02.727001 14052 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T02:10:18.800236+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T02:10:01.613189+00:00 2021-04-06T02:10:03.370782+00:00 0:00:01.757593 14051 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T02:09:58.849209+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T02:09:59.295322+00:00 2021-04-06T02:10:01.285862+00:00 0:00:01.990540 14050 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T02:09:56.740835+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T01:00:00+00:00 PythonOperator 2021-04-06T02:09:39.478453+00:00 2021-04-06T02:09:42.308830+00:00 0:00:02.830377 14049 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T02:09:36.657914+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T01:00:00+00:00 PythonOperator 2021-04-06T02:09:39.068044+00:00 2021-04-06T02:09:42.018861+00:00 0:00:02.950817 14048 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T02:09:36.657864+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T01:00:00+00:00 TriggerDagRunOperator 2021-04-06T02:09:23.335478+00:00 2021-04-06T02:09:24.084464+00:00 0:00:00.748986 14047 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T02:09:20.646637+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T01:00:00+00:00 TriggerDagRunOperator 2021-04-06T02:09:23.024154+00:00 2021-04-06T02:09:23.672697+00:00 0:00:00.648543 14046 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T02:09:20.646605+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T01:05:00+00:00 EmrJobFlowSensor 2021-04-06T02:06:12.440081+00:00 2021-04-06T02:15:15.045409+00:00 0:09:02.605328 14045 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T02:06:10.251244+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T01:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T02:05:50.359191+00:00 2021-04-06T02:05:51.973431+00:00 0:00:01.614240 14044 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T02:05:48.235471+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T01:05:00+00:00 PythonOperator 2021-04-06T02:05:20.495800+00:00 2021-04-06T02:05:23.221687+00:00 0:00:02.725887 14043 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T02:05:18.208672+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T01:00:00+00:00 EmrJobFlowSensor 2021-04-06T02:01:10.418709+00:00 2021-04-06T02:09:13.082308+00:00 0:08:02.663599 14042 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T02:01:07.866326+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T02:00:38.049337+00:00 2021-04-06T02:00:39.883368+00:00 0:00:01.834031 14041 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T02:00:35.792378+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T01:00:00+00:00 PythonOperator 2021-04-06T02:00:14.120896+00:00 2021-04-06T02:00:16.986289+00:00 0:00:02.865393 14040 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T02:00:11.737190+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T00:00:00+00:00 EmrJobFlowSensor 2021-04-06T01:12:00.985485+00:00 2021-04-06T01:21:03.609982+00:00 0:09:02.624497 14038 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T01:11:58.688147+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T00:00:00+00:00 EmrJobFlowSensor 2021-04-06T01:11:50.819821+00:00 2021-04-06T01:21:53.659846+00:00 0:10:02.840025 14037 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T01:11:48.624613+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T01:11:32.813514+00:00 2021-04-06T01:11:34.483089+00:00 0:00:01.669575 14036 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T01:11:30.612319+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T01:11:25.133210+00:00 2021-04-06T01:11:27.116569+00:00 0:00:01.983359 14035 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T01:11:22.651581+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T00:00:00+00:00 PythonOperator 2021-04-06T01:11:11.158257+00:00 2021-04-06T01:11:13.875777+00:00 0:00:02.717520 14034 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T01:11:08.591038+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T00:00:00+00:00 PythonOperator 2021-04-06T01:11:05.321552+00:00 2021-04-06T01:11:08.357442+00:00 0:00:03.035890 14033 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T01:11:02.666977+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T00:00:00+00:00 TriggerDagRunOperator 2021-04-06T01:10:59.220141+00:00 2021-04-06T01:10:59.783810+00:00 0:00:00.563669 14032 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T01:10:56.655232+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T00:00:00+00:00 TriggerDagRunOperator 2021-04-06T01:10:59.200403+00:00 2021-04-06T01:10:59.614693+00:00 0:00:00.414290 14031 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T01:10:56.655196+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T00:05:00+00:00 EmrJobFlowSensor 2021-04-06T01:05:48.352573+00:00 2021-04-06T01:13:50.771972+00:00 0:08:02.419399 14030 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T01:05:46.124683+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T00:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T01:05:26.577140+00:00 2021-04-06T01:05:28.303101+00:00 0:00:01.725961 14029 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T01:05:24.180851+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T00:05:00+00:00 PythonOperator 2021-04-06T01:05:04.387458+00:00 2021-04-06T01:05:07.090347+00:00 0:00:02.702889 14028 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T01:05:02.091073+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T00:00:00+00:00 EmrJobFlowSensor 2021-04-06T01:00:50.124547+00:00 2021-04-06T01:10:52.729938+00:00 0:10:02.605391 14027 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T01:00:47.764012+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T01:00:30.081444+00:00 2021-04-06T01:00:31.772009+00:00 0:00:01.690565 14026 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T01:00:27.747044+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T00:00:00+00:00 PythonOperator 2021-04-06T01:00:08.054677+00:00 2021-04-06T01:00:10.759299+00:00 0:00:02.704622 14025 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T01:00:05.660682+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-05T23:00:00+00:00 EmrJobFlowSensor 2021-04-06T00:11:05.730854+00:00 2021-04-06T00:21:08.603759+00:00 0:10:02.872905 14023 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T00:11:03.431926+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-05T23:00:00+00:00 EmrJobFlowSensor 2021-04-06T00:11:03.785521+00:00 2021-04-06T00:20:06.495887+00:00 0:09:02.710366 14022 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T00:11:01.431390+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-05T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T00:10:45.758329+00:00 2021-04-06T00:10:47.517678+00:00 0:00:01.759349 14021 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T00:10:43.417859+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-05T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T00:10:39.800229+00:00 2021-04-06T00:10:41.494376+00:00 0:00:01.694147 14020 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T00:10:37.469046+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-05T23:00:00+00:00 PythonOperator 2021-04-06T00:10:23.890771+00:00 2021-04-06T00:10:26.961753+00:00 0:00:03.070982 14019 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T00:10:21.458424+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-05T23:00:00+00:00 PythonOperator 2021-04-06T00:10:19.743728+00:00 2021-04-06T00:10:22.465752+00:00 0:00:02.722024 14018 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T00:10:17.478669+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T23:00:00+00:00 TriggerDagRunOperator 2021-04-06T00:10:03.913065+00:00 2021-04-06T00:10:04.364079+00:00 0:00:00.451014 14017 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T00:10:01.350584+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T23:00:00+00:00 TriggerDagRunOperator 2021-04-06T00:10:03.853089+00:00 2021-04-06T00:10:04.451012+00:00 0:00:00.597923 14016 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T00:10:01.350554+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-05T23:05:00+00:00 EmrJobFlowSensor 2021-04-06T00:06:01.555951+00:00 2021-04-06T00:15:04.182030+00:00 0:09:02.626079 14015 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T00:05:59.045151+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-05T23:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T00:05:39.111516+00:00 2021-04-06T00:05:40.741223+00:00 0:00:01.629707 14014 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T00:05:36.863115+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-05T23:05:00+00:00 PythonOperator 2021-04-06T00:05:19.044049+00:00 2021-04-06T00:05:21.746590+00:00 0:00:02.702541 14013 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T00:05:16.841748+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T23:00:00+00:00 EmrJobFlowSensor 2021-04-06T00:00:48.870508+00:00 2021-04-06T00:09:51.603278+00:00 0:09:02.732770 14012 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T00:00:46.499067+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T00:00:28.636567+00:00 2021-04-06T00:00:30.358823+00:00 0:00:01.722256 14011 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T00:00:26.446844+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T23:00:00+00:00 PythonOperator 2021-04-06T00:00:06.957092+00:00 2021-04-06T00:00:09.746504+00:00 0:00:02.789412 14010 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T00:00:04.477292+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-05T22:00:00+00:00 EmrJobFlowSensor 2021-04-05T23:12:16.934549+00:00 2021-04-05T23:22:19.857826+00:00 0:10:02.923277 14008 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T23:12:14.134871+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-05T22:00:00+00:00 EmrJobFlowSensor 2021-04-05T23:12:14.812508+00:00 2021-04-05T23:22:17.807735+00:00 0:10:02.995227 14007 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T23:12:12.130608+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-05T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T23:11:55.082872+00:00 2021-04-05T23:11:56.800367+00:00 0:00:01.717495 14006 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T23:11:52.174775+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-05T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T23:11:52.735660+00:00 2021-04-05T23:11:54.716910+00:00 0:00:01.981250 14005 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T23:11:50.171455+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-05T22:00:00+00:00 PythonOperator 2021-04-05T23:11:34.547420+00:00 2021-04-05T23:11:37.584493+00:00 0:00:03.037073 14004 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T23:11:32.144253+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-05T22:00:00+00:00 PythonOperator 2021-04-05T23:11:30.733179+00:00 2021-04-05T23:11:33.472408+00:00 0:00:02.739229 14003 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T23:11:28.248173+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T22:00:00+00:00 TriggerDagRunOperator 2021-04-05T23:11:08.535717+00:00 2021-04-05T23:11:09.094062+00:00 0:00:00.558345 14002 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T23:11:06.043829+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T22:00:00+00:00 TriggerDagRunOperator 2021-04-05T23:11:08.174725+00:00 2021-04-05T23:11:08.601651+00:00 0:00:00.426926 14001 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T23:11:06.043794+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-05T22:05:00+00:00 EmrJobFlowSensor 2021-04-05T23:05:49.955510+00:00 2021-04-05T23:14:52.615913+00:00 0:09:02.660403 14000 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T23:05:47.688847+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-05T22:05:00+00:00 EmrCreateJobFlowOperator 2021-04-05T23:05:27.974864+00:00 2021-04-05T23:05:29.579162+00:00 0:00:01.604298 13999 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T23:05:25.672794+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-05T22:05:00+00:00 PythonOperator 2021-04-05T23:05:07.814972+00:00 2021-04-05T23:05:10.504564+00:00 0:00:02.689592 13998 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T23:05:05.635035+00:00 2 default_pool