Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-flow-job_v002 trigger_dagrun_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
success campaign-flow-job_v002 check_cluster_status 2021-04-05T22:00:00+00:00 EmrJobFlowSensor 2021-04-05T23:00:59.551816+00:00 2021-04-05T23:11:02.527576+00:00 0:10:02.975760 13997 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T23:00:57.234619+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T23:00:37.548732+00:00 2021-04-05T23:00:39.310008+00:00 0:00:01.761276 13996 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T23:00:35.216566+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T22:00:00+00:00 PythonOperator 2021-04-05T23:00:18.037238+00:00 2021-04-05T23:00:20.824444+00:00 0:00:02.787206 13995 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T23:00:15.198746+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-05T21:00:00+00:00 EmrJobFlowSensor 2021-04-05T22:11:58.189679+00:00 2021-04-05T22:21:01.027508+00:00 0:09:02.837829 13993 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T22:11:55.826883+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-05T21:00:00+00:00 EmrJobFlowSensor 2021-04-05T22:11:54.280422+00:00 2021-04-05T22:20:57.115870+00:00 0:09:02.835448 13992 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T22:11:51.823608+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-05T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T22:11:36.285008+00:00 2021-04-05T22:11:37.948732+00:00 0:00:01.663724 13991 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T22:11:33.871050+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-05T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T22:11:32.287134+00:00 2021-04-05T22:11:34.066283+00:00 0:00:01.779149 13990 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T22:11:29.856245+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-05T21:00:00+00:00 PythonOperator 2021-04-05T22:11:14.267120+00:00 2021-04-05T22:11:17.261492+00:00 0:00:02.994372 13989 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T22:11:11.854257+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-05T21:00:00+00:00 PythonOperator 2021-04-05T22:11:10.401153+00:00 2021-04-05T22:11:13.233250+00:00 0:00:02.832097 13988 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T22:11:07.846716+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T21:00:00+00:00 TriggerDagRunOperator 2021-04-05T22:11:04.287584+00:00 2021-04-05T22:11:04.701435+00:00 0:00:00.413851 13987 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T22:11:01.789365+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T21:00:00+00:00 TriggerDagRunOperator 2021-04-05T22:11:04.260148+00:00 2021-04-05T22:11:04.827419+00:00 0:00:00.567271 13986 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T22:11:01.789397+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-05T21:05:00+00:00 EmrJobFlowSensor 2021-04-05T22:06:03.646744+00:00 2021-04-05T22:15:06.299993+00:00 0:09:02.653249 13985 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T22:06:01.284428+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-05T21:05:00+00:00 EmrCreateJobFlowOperator 2021-04-05T22:05:41.393359+00:00 2021-04-05T22:05:43.032426+00:00 0:00:01.639067 13984 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T22:05:39.192303+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-05T21:05:00+00:00 PythonOperator 2021-04-05T22:05:19.588718+00:00 2021-04-05T22:05:22.391574+00:00 0:00:02.802856 13983 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T22:05:17.144032+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T21:00:00+00:00 EmrJobFlowSensor 2021-04-05T22:00:46.852529+00:00 2021-04-05T22:10:49.727257+00:00 0:10:02.874728 13982 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T22:00:44.589928+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T22:00:26.715661+00:00 2021-04-05T22:00:28.465412+00:00 0:00:01.749751 13981 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T22:00:24.566237+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T21:00:00+00:00 PythonOperator 2021-04-05T22:00:05.096757+00:00 2021-04-05T22:00:07.976803+00:00 0:00:02.880046 13980 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T22:00:02.549373+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-05T20:00:00+00:00 EmrJobFlowSensor 2021-04-05T21:12:13.894381+00:00 2021-04-05T21:22:16.651932+00:00 0:10:02.757551 13978 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T21:12:11.642775+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-05T20:00:00+00:00 EmrJobFlowSensor 2021-04-05T21:12:09.921104+00:00 2021-04-05T21:20:12.454623+00:00 0:08:02.533519 13977 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T21:12:07.650806+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-05T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T21:11:51.932262+00:00 2021-04-05T21:11:53.725710+00:00 0:00:01.793448 13976 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T21:11:49.626905+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-05T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T21:11:48.014154+00:00 2021-04-05T21:11:49.920804+00:00 0:00:01.906650 13975 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T21:11:45.624491+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-05T20:00:00+00:00 PythonOperator 2021-04-05T21:11:30.393341+00:00 2021-04-05T21:11:33.376621+00:00 0:00:02.983280 13974 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T21:11:27.748142+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-05T20:00:00+00:00 PythonOperator 2021-04-05T21:11:26.172653+00:00 2021-04-05T21:11:29.140944+00:00 0:00:02.968291 13973 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T21:11:23.674470+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T20:00:00+00:00 TriggerDagRunOperator 2021-04-05T21:11:18.233904+00:00 2021-04-05T21:11:18.776973+00:00 0:00:00.543069 13972 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T21:11:15.598674+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T20:00:00+00:00 TriggerDagRunOperator 2021-04-05T21:11:17.907121+00:00 2021-04-05T21:11:18.336125+00:00 0:00:00.429004 13971 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T21:11:15.598721+00:00 2 default_pool