Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T18:11:06.896904+00:00 2021-04-06T18:11:08.597335+00:00 0:00:01.700431 14294 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T18:11:04.603862+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T18:10:52.900914+00:00 2021-04-06T18:10:54.604907+00:00 0:00:01.703993 14293 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T18:10:50.589001+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T17:00:00+00:00 PythonOperator 2021-04-06T18:10:45.082174+00:00 2021-04-06T18:10:48.305680+00:00 0:00:03.223506 14292 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T18:10:42.647104+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T17:00:00+00:00 PythonOperator 2021-04-06T18:10:30.928042+00:00 2021-04-06T18:10:33.709374+00:00 0:00:02.781332 14291 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T18:10:28.583976+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T17:00:00+00:00 TriggerDagRunOperator 2021-04-06T18:10:26.856097+00:00 2021-04-06T18:10:27.280328+00:00 0:00:00.424231 14290 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T18:10:24.496809+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T17:00:00+00:00 TriggerDagRunOperator 2021-04-06T18:10:26.843482+00:00 2021-04-06T18:10:27.372307+00:00 0:00:00.528825 14289 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T18:10:24.496781+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T17:05:00+00:00 EmrJobFlowSensor 2021-04-06T18:05:54.619042+00:00 2021-04-06T18:14:57.319298+00:00 0:09:02.700256 14288 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T18:05:52.101290+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T17:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T18:05:34.359753+00:00 2021-04-06T18:05:36.128726+00:00 0:00:01.768973 14287 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T18:05:32.086849+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T17:05:00+00:00 PythonOperator 2021-04-06T18:05:12.177260+00:00 2021-04-06T18:05:15.072775+00:00 0:00:02.895515 14286 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T18:05:10.013371+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T17:00:00+00:00 EmrJobFlowSensor 2021-04-06T18:01:04.054468+00:00 2021-04-06T18:10:06.887176+00:00 0:09:02.832708 14285 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T18:01:01.655696+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T18:00:30.089162+00:00 2021-04-06T18:00:31.899599+00:00 0:00:01.810437 14284 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T18:00:27.652479+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T17:00:00+00:00 PythonOperator 2021-04-06T18:00:08.400428+00:00 2021-04-06T18:00:11.240143+00:00 0:00:02.839715 14283 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T18:00:05.609970+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T16:00:00+00:00 EmrJobFlowSensor 2021-04-06T17:21:57.969131+00:00 2021-04-06T17:21:59.555228+00:00 0:00:01.586097 14281 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T17:21:55.480395+00:00 3 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T16:00:00+00:00 EmrJobFlowSensor 2021-04-06T17:10:20.607212+00:00 2021-04-06T17:20:23.345215+00:00 0:10:02.738003 14280 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T17:10:18.316811+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T17:09:58.602597+00:00 2021-04-06T17:10:00.317992+00:00 0:00:01.715395 14278 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T17:09:56.284689+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T17:09:54.544355+00:00 2021-04-06T17:09:56.347587+00:00 0:00:01.803232 14277 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T17:09:52.259771+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T16:00:00+00:00 PythonOperator 2021-04-06T17:09:36.526616+00:00 2021-04-06T17:09:39.343406+00:00 0:00:02.816790 14276 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T17:09:34.270785+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T16:00:00+00:00 PythonOperator 2021-04-06T17:09:34.713179+00:00 2021-04-06T17:09:37.671200+00:00 0:00:02.958021 14275 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T17:09:32.238382+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T16:00:00+00:00 TriggerDagRunOperator 2021-04-06T17:09:22.596280+00:00 2021-04-06T17:09:23.124097+00:00 0:00:00.527817 14274 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T17:09:20.229775+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T16:00:00+00:00 TriggerDagRunOperator 2021-04-06T17:09:22.449184+00:00 2021-04-06T17:09:22.908696+00:00 0:00:00.459512 14273 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T17:09:20.229810+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T16:05:00+00:00 EmrJobFlowSensor 2021-04-06T17:05:48.333855+00:00 2021-04-06T17:14:50.925819+00:00 0:09:02.591964 14272 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T17:05:45.984454+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T16:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T17:05:26.193643+00:00 2021-04-06T17:05:27.969801+00:00 0:00:01.776158 14271 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T17:05:23.943042+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T16:05:00+00:00 PythonOperator 2021-04-06T17:05:06.796740+00:00 2021-04-06T17:05:09.520083+00:00 0:00:02.723343 14270 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T17:05:03.922375+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T16:00:00+00:00 EmrJobFlowSensor 2021-04-06T17:00:55.998810+00:00 2021-04-06T17:08:58.407249+00:00 0:08:02.408439 14269 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T17:00:53.666362+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T17:00:36.046022+00:00 2021-04-06T17:00:37.869881+00:00 0:00:01.823859 14268 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T17:00:33.661745+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T16:00:00+00:00 PythonOperator 2021-04-06T17:00:14.452079+00:00 2021-04-06T17:00:17.330953+00:00 0:00:02.878874 14267 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T17:00:11.594035+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T15:00:00+00:00 EmrJobFlowSensor 2021-04-06T16:11:23.923378+00:00 2021-04-06T16:20:26.635369+00:00 0:09:02.711991 14265 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T16:11:21.633525+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T15:00:00+00:00 EmrJobFlowSensor 2021-04-06T16:11:19.807389+00:00 2021-04-06T16:22:22.585867+00:00 0:11:02.778478 14264 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T16:11:17.629138+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T16:11:00.690189+00:00 2021-04-06T16:11:02.442549+00:00 0:00:01.752360 14263 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T16:10:57.609531+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T16:10:58.534729+00:00 2021-04-06T16:11:00.573971+00:00 0:00:02.039242 14262 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T16:10:55.609137+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T15:00:00+00:00 PythonOperator 2021-04-06T16:10:38.256274+00:00 2021-04-06T16:10:41.046097+00:00 0:00:02.789823 14261 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T16:10:35.596332+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T15:00:00+00:00 PythonOperator 2021-04-06T16:10:36.209211+00:00 2021-04-06T16:10:39.118048+00:00 0:00:02.908837 14260 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T16:10:33.596643+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T15:00:00+00:00 TriggerDagRunOperator 2021-04-06T16:10:18.430264+00:00 2021-04-06T16:10:18.961118+00:00 0:00:00.530854 14259 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T16:10:15.543812+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T15:00:00+00:00 TriggerDagRunOperator 2021-04-06T16:10:18.290923+00:00 2021-04-06T16:10:18.698856+00:00 0:00:00.407933 14258 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T16:10:15.543776+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T15:05:00+00:00 EmrJobFlowSensor 2021-04-06T16:05:59.090882+00:00 2021-04-06T16:15:01.670311+00:00 0:09:02.579429 14257 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T16:05:56.865719+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T15:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T16:05:37.043476+00:00 2021-04-06T16:05:38.671577+00:00 0:00:01.628101 14256 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T16:05:34.853190+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T15:05:00+00:00 PythonOperator 2021-04-06T16:05:17.000403+00:00 2021-04-06T16:05:19.747579+00:00 0:00:02.747176 14255 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T16:05:14.751800+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T15:00:00+00:00 EmrJobFlowSensor 2021-04-06T16:00:54.820690+00:00 2021-04-06T16:09:57.524526+00:00 0:09:02.703836 14254 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T16:00:52.375248+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T16:00:34.525273+00:00 2021-04-06T16:00:36.228858+00:00 0:00:01.703585 14253 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T16:00:32.284725+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T15:00:00+00:00 PythonOperator 2021-04-06T16:00:12.790476+00:00 2021-04-06T16:00:15.538256+00:00 0:00:02.747780 14252 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T16:00:10.220164+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T14:00:00+00:00 EmrJobFlowSensor 2021-04-06T15:12:16.702987+00:00 2021-04-06T15:21:19.400771+00:00 0:09:02.697784 14250 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T15:12:14.451403+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T14:00:00+00:00 EmrJobFlowSensor 2021-04-06T15:12:00.802148+00:00 2021-04-06T15:22:03.723409+00:00 0:10:02.921261 14249 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T15:11:58.363768+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T15:11:56.637432+00:00 2021-04-06T15:11:58.333016+00:00 0:00:01.695584 14248 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T15:11:54.351086+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T15:11:40.536019+00:00 2021-04-06T15:11:42.330713+00:00 0:00:01.794694 14247 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T15:11:38.241960+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T14:00:00+00:00 PythonOperator 2021-04-06T15:11:34.514044+00:00 2021-04-06T15:11:37.217243+00:00 0:00:02.703199 14246 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T15:11:32.237346+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T14:00:00+00:00 PythonOperator 2021-04-06T15:11:18.850361+00:00 2021-04-06T15:11:21.947405+00:00 0:00:03.097044 14245 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T15:11:16.221693+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T14:00:00+00:00 TriggerDagRunOperator 2021-04-06T15:11:12.741542+00:00 2021-04-06T15:11:13.169844+00:00 0:00:00.428302 14244 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T15:11:10.216527+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T14:00:00+00:00 TriggerDagRunOperator 2021-04-06T15:11:12.438966+00:00 2021-04-06T15:11:12.975269+00:00 0:00:00.536303 14243 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T15:11:10.216563+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T14:05:00+00:00 EmrJobFlowSensor 2021-04-06T15:05:57.955832+00:00 2021-04-06T15:14:00.598378+00:00 0:08:02.642546 14242 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T15:05:55.640079+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T14:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T15:05:35.857612+00:00 2021-04-06T15:05:37.529784+00:00 0:00:01.672172 14241 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T15:05:33.622115+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T14:05:00+00:00 PythonOperator 2021-04-06T15:05:13.657102+00:00 2021-04-06T15:05:16.350798+00:00 0:00:02.693696 14240 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T15:05:11.545690+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T14:00:00+00:00 EmrJobFlowSensor 2021-04-06T15:01:03.403842+00:00 2021-04-06T15:11:06.241145+00:00 0:10:02.837303 14239 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T15:01:01.209764+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T15:00:41.295407+00:00 2021-04-06T15:00:42.973155+00:00 0:00:01.677748 14238 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T15:00:39.191796+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T14:00:00+00:00 PythonOperator 2021-04-06T15:00:19.708132+00:00 2021-04-06T15:00:22.419543+00:00 0:00:02.711411 14237 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T15:00:17.167560+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T13:00:00+00:00 EmrJobFlowSensor 2021-04-06T14:11:37.702023+00:00 2021-04-06T14:20:40.435679+00:00 0:09:02.733656 14235 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T14:11:35.407838+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T13:00:00+00:00 EmrJobFlowSensor 2021-04-06T14:11:19.990950+00:00 2021-04-06T14:23:23.038103+00:00 0:12:03.047153 14234 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T14:11:17.402139+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T14:11:07.566834+00:00 2021-04-06T14:11:09.253877+00:00 0:00:01.687043 14233 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T14:11:05.380210+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T14:10:57.645076+00:00 2021-04-06T14:10:59.509995+00:00 0:00:01.864919 14232 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T14:10:55.323019+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T13:00:00+00:00 PythonOperator 2021-04-06T14:10:47.708358+00:00 2021-04-06T14:10:50.390425+00:00 0:00:02.682067 14231 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T14:10:45.321883+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T13:00:00+00:00 PythonOperator 2021-04-06T14:10:37.667718+00:00 2021-04-06T14:10:40.539356+00:00 0:00:02.871638 14230 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T14:10:35.303939+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T13:00:00+00:00 TriggerDagRunOperator 2021-04-06T14:10:21.902817+00:00 2021-04-06T14:10:22.348604+00:00 0:00:00.445787 14229 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T14:10:19.293274+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T13:00:00+00:00 TriggerDagRunOperator 2021-04-06T14:10:21.516489+00:00 2021-04-06T14:10:22.081194+00:00 0:00:00.564705 14228 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T14:10:19.293308+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T13:05:00+00:00 EmrJobFlowSensor 2021-04-06T14:05:50.780128+00:00 2021-04-06T14:14:53.292870+00:00 0:09:02.512742 14227 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T14:05:48.600053+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T13:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T14:05:30.946557+00:00 2021-04-06T14:05:32.684429+00:00 0:00:01.737872 14226 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T14:05:28.641330+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T13:05:00+00:00 PythonOperator 2021-04-06T14:05:08.901528+00:00 2021-04-06T14:05:11.580640+00:00 0:00:02.679112 14225 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T14:05:06.570771+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T13:00:00+00:00 EmrJobFlowSensor 2021-04-06T14:01:04.476420+00:00 2021-04-06T14:10:07.215175+00:00 0:09:02.738755 14224 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T14:01:02.182357+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T14:00:42.376226+00:00 2021-04-06T14:00:44.233770+00:00 0:00:01.857544 14223 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T14:00:40.110709+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T13:00:00+00:00 PythonOperator 2021-04-06T14:00:20.629453+00:00 2021-04-06T14:00:23.373684+00:00 0:00:02.744231 14222 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T14:00:18.152110+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T12:00:00+00:00 EmrJobFlowSensor 2021-04-06T13:11:56.658264+00:00 2021-04-06T13:23:59.847305+00:00 0:12:03.189041 14220 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T13:11:54.293840+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T12:00:00+00:00 EmrJobFlowSensor 2021-04-06T13:11:52.553133+00:00 2021-04-06T13:20:55.264757+00:00 0:09:02.711624 14219 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T13:11:50.254267+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T13:11:36.406616+00:00 2021-04-06T13:11:38.090325+00:00 0:00:01.683709 14218 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T13:11:34.242379+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T13:11:30.777047+00:00 2021-04-06T13:11:32.552962+00:00 0:00:01.775915 14217 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T13:11:28.257558+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T12:00:00+00:00 PythonOperator 2021-04-06T13:11:10.548814+00:00 2021-04-06T13:11:13.616251+00:00 0:00:03.067437 14216 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T13:11:08.221384+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T12:00:00+00:00 PythonOperator 2021-04-06T13:11:02.642332+00:00 2021-04-06T13:11:05.402402+00:00 0:00:02.760070 14215 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T13:11:00.220496+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T12:00:00+00:00 TriggerDagRunOperator 2021-04-06T13:10:58.635597+00:00 2021-04-06T13:10:59.105489+00:00 0:00:00.469892 14214 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T13:10:56.217300+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T12:00:00+00:00 TriggerDagRunOperator 2021-04-06T13:10:58.606947+00:00 2021-04-06T13:10:59.153463+00:00 0:00:00.546516 14213 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T13:10:56.217351+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T12:05:00+00:00 EmrJobFlowSensor 2021-04-06T13:06:05.981667+00:00 2021-04-06T13:15:08.664138+00:00 0:09:02.682471 14212 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T13:06:03.751939+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T12:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T13:05:39.994546+00:00 2021-04-06T13:05:41.641734+00:00 0:00:01.647188 14211 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T13:05:37.718258+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T12:05:00+00:00 PythonOperator 2021-04-06T13:05:18.077735+00:00 2021-04-06T13:05:20.827535+00:00 0:00:02.749800 14210 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T13:05:15.756289+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T12:00:00+00:00 EmrJobFlowSensor 2021-04-06T13:00:51.353659+00:00 2021-04-06T13:10:54.116046+00:00 0:10:02.762387 14209 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T13:00:49.187214+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T13:00:31.384569+00:00 2021-04-06T13:00:33.095708+00:00 0:00:01.711139 14208 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T13:00:29.173474+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T12:00:00+00:00 PythonOperator 2021-04-06T13:00:09.612227+00:00 2021-04-06T13:00:12.404216+00:00 0:00:02.791989 14207 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T13:00:07.151790+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T11:00:00+00:00 EmrJobFlowSensor 2021-04-06T12:11:14.345184+00:00 2021-04-06T12:20:17.101980+00:00 0:09:02.756796 14205 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T12:11:11.945166+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T11:00:00+00:00 EmrJobFlowSensor 2021-04-06T12:11:10.338321+00:00 2021-04-06T12:21:13.302120+00:00 0:10:02.963799 14204 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T12:11:07.947877+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T12:10:52.421520+00:00 2021-04-06T12:10:54.210692+00:00 0:00:01.789172 14203 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T12:10:49.985506+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T12:10:48.329957+00:00 2021-04-06T12:10:50.042893+00:00 0:00:01.712936 14202 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T12:10:45.980568+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T11:00:00+00:00 PythonOperator 2021-04-06T12:10:30.631697+00:00 2021-04-06T12:10:33.552829+00:00 0:00:02.921132 14201 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T12:10:28.048211+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T11:00:00+00:00 PythonOperator 2021-04-06T12:10:26.253732+00:00 2021-04-06T12:10:29.102298+00:00 0:00:02.848566 14200 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T12:10:24.040798+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T11:00:00+00:00 TriggerDagRunOperator 2021-04-06T12:10:12.246389+00:00 2021-04-06T12:10:12.695707+00:00 0:00:00.449318 14199 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T12:10:09.946545+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T11:00:00+00:00 TriggerDagRunOperator 2021-04-06T12:10:12.210780+00:00 2021-04-06T12:10:12.785913+00:00 0:00:00.575133 14198 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T12:10:09.946512+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T11:05:00+00:00 EmrJobFlowSensor 2021-04-06T12:06:05.850151+00:00 2021-04-06T12:14:08.323691+00:00 0:08:02.473540 14197 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T12:06:03.492453+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T11:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T12:05:45.774009+00:00 2021-04-06T12:05:47.535312+00:00 0:00:01.761303 14196 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T12:05:43.442326+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T11:05:00+00:00 PythonOperator 2021-04-06T12:05:23.754616+00:00 2021-04-06T12:05:26.524567+00:00 0:00:02.769951 14195 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T12:05:21.423891+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T11:00:00+00:00 EmrJobFlowSensor 2021-04-06T12:00:49.514231+00:00 2021-04-06T12:09:52.177904+00:00 0:09:02.663673 14194 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T12:00:47.051977+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T12:00:29.605969+00:00 2021-04-06T12:00:31.395737+00:00 0:00:01.789768 14193 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T12:00:26.954757+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T11:00:00+00:00 PythonOperator 2021-04-06T12:00:05.416338+00:00 2021-04-06T12:00:08.392730+00:00 0:00:02.976392 14192 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T12:00:02.868626+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T10:00:00+00:00 EmrJobFlowSensor 2021-04-06T11:11:35.309405+00:00 2021-04-06T11:20:37.937591+00:00 0:09:02.628186 14190 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T11:11:32.887352+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T10:00:00+00:00 EmrJobFlowSensor 2021-04-06T11:11:21.088376+00:00 2021-04-06T11:21:24.066081+00:00 0:10:02.977705 14189 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T11:11:18.831926+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T11:11:13.067782+00:00 2021-04-06T11:11:14.866611+00:00 0:00:01.798829 14188 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T11:11:10.825177+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T11:11:01.093203+00:00 2021-04-06T11:11:02.842642+00:00 0:00:01.749439 14187 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T11:10:58.843930+00:00 2 default_pool