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-06T23:05:00+00:00 EmrCreateJobFlowOperator 2021-04-07T00:05:41.444680+00:00 2021-04-07T00:05:43.073871+00:00 0:00:01.629191 14377 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T00:05:39.289068+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T23:05:00+00:00 PythonOperator 2021-04-07T00:05:21.393959+00:00 2021-04-07T00:05:24.213762+00:00 0:00:02.819803 14376 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T00:05:19.226813+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T23:00:00+00:00 EmrJobFlowSensor 2021-04-07T00:01:05.264674+00:00 2021-04-07T00:10:07.938612+00:00 0:09:02.673938 14375 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T00:01:02.910477+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T00:00:45.129125+00:00 2021-04-07T00:00:46.878677+00:00 0:00:01.749552 14374 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T00:00:42.891691+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T23:00:00+00:00 PythonOperator 2021-04-07T00:00:23.263202+00:00 2021-04-07T00:00:26.221567+00:00 0:00:02.958365 14373 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T00:00:20.817701+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T22:00:00+00:00 EmrJobFlowSensor 2021-04-06T23:12:27.329230+00:00 2021-04-06T23:20:29.833127+00:00 0:08:02.503897 14371 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T23:12:25.149561+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T22:00:00+00:00 EmrJobFlowSensor 2021-04-06T23:11:29.464833+00:00 2021-04-06T23:29:33.385948+00:00 0:18:03.921115 14370 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T23:11:27.108635+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T23:11:09.436650+00:00 2021-04-06T23:11:11.230909+00:00 0:00:01.794259 14369 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T23:11:07.095643+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T23:11:07.221866+00:00 2021-04-06T23:11:08.928467+00:00 0:00:01.706601 14368 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T23:11:05.061658+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T22:00:00+00:00 PythonOperator 2021-04-06T23:10:49.337008+00:00 2021-04-06T23:10:52.250826+00:00 0:00:02.913818 14367 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T23:10:47.024344+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T22:00:00+00:00 PythonOperator 2021-04-06T23:10:45.538519+00:00 2021-04-06T23:10:48.308302+00:00 0:00:02.769783 14366 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T23:10:43.022657+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T22:00:00+00:00 TriggerDagRunOperator 2021-04-06T23:10:33.441296+00:00 2021-04-06T23:10:34.004279+00:00 0:00:00.562983 14365 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T23:10:31.016177+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T22:00:00+00:00 TriggerDagRunOperator 2021-04-06T23:10:33.278624+00:00 2021-04-06T23:10:33.720065+00:00 0:00:00.441441 14364 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T23:10:31.016213+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T22:05:00+00:00 EmrJobFlowSensor 2021-04-06T23:05:58.884281+00:00 2021-04-06T23:15:01.545061+00:00 0:09:02.660780 14363 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T23:05:56.537682+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T22:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T23:05:37.003254+00:00 2021-04-06T23:05:38.722652+00:00 0:00:01.719398 14362 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T23:05:34.646515+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T22:05:00+00:00 PythonOperator 2021-04-06T23:05:16.759033+00:00 2021-04-06T23:05:19.458997+00:00 0:00:02.699964 14361 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T23:05:14.558614+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T22:00:00+00:00 EmrJobFlowSensor 2021-04-06T23:01:06.481665+00:00 2021-04-06T23:10:09.176994+00:00 0:09:02.695329 14360 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T23:01:04.195763+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T23:00:46.474989+00:00 2021-04-06T23:00:48.311760+00:00 0:00:01.836771 14359 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T23:00:44.153667+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T22:00:00+00:00 PythonOperator 2021-04-06T23:00:25.046294+00:00 2021-04-06T23:00:27.768465+00:00 0:00:02.722171 14358 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T23:00:22.132487+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T21:00:00+00:00 EmrJobFlowSensor 2021-04-06T22:10:27.608107+00:00 2021-04-06T22:20:30.227143+00:00 0:10:02.619036 14356 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T22:10:25.394159+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T21:00:00+00:00 EmrJobFlowSensor 2021-04-06T22:10:20.003367+00:00 2021-04-06T22:19:22.519077+00:00 0:09:02.515710 14355 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T22:10:17.384367+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T22:10:07.729767+00:00 2021-04-06T22:10:09.502966+00:00 0:00:01.773199 14354 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T22:10:05.355694+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T22:09:59.592753+00:00 2021-04-06T22:10:01.265500+00:00 0:00:01.672747 14353 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T22:09:57.353201+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T21:00:00+00:00 PythonOperator 2021-04-06T22:09:45.568907+00:00 2021-04-06T22:09:48.544426+00:00 0:00:02.975519 14352 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T22:09:43.339155+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T21:00:00+00:00 PythonOperator 2021-04-06T22:09:31.530363+00:00 2021-04-06T22:09:34.319619+00:00 0:00:02.789256 14351 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T22:09:29.325672+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T21:00:00+00:00 TriggerDagRunOperator 2021-04-06T22:09:17.759744+00:00 2021-04-06T22:09:18.364132+00:00 0:00:00.604388 14350 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T22:09:15.317947+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T21:00:00+00:00 TriggerDagRunOperator 2021-04-06T22:09:17.506103+00:00 2021-04-06T22:09:17.922635+00:00 0:00:00.416532 14349 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T22:09:15.317910+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T21:05:00+00:00 EmrJobFlowSensor 2021-04-06T22:05:55.175137+00:00 2021-04-06T22:14:57.793072+00:00 0:09:02.617935 14348 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T22:05:53.006350+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T21:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T22:05:33.393812+00:00 2021-04-06T22:05:35.172867+00:00 0:00:01.779055 14347 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T22:05:31.059026+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T21:05:00+00:00 PythonOperator 2021-04-06T22:05:11.197248+00:00 2021-04-06T22:05:13.973222+00:00 0:00:02.775974 14346 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T22:05:09.048495+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T21:00:00+00:00 EmrJobFlowSensor 2021-04-06T22:01:06.979253+00:00 2021-04-06T22:09:09.567298+00:00 0:08:02.588045 14345 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T22:01:04.553060+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T22:00:44.919184+00:00 2021-04-06T22:00:46.724077+00:00 0:00:01.804893 14344 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T22:00:42.548679+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T21:00:00+00:00 PythonOperator 2021-04-06T22:00:24.747489+00:00 2021-04-06T22:00:27.542703+00:00 0:00:02.795214 14343 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T22:00:22.411275+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T20:00:00+00:00 EmrJobFlowSensor 2021-04-06T21:11:27.819540+00:00 2021-04-06T21:21:30.576393+00:00 0:10:02.756853 14341 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T21:11:25.610917+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T20:00:00+00:00 EmrJobFlowSensor 2021-04-06T21:11:19.995365+00:00 2021-04-06T21:19:22.510747+00:00 0:08:02.515382 14340 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T21:11:17.667108+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T21:11:06.087291+00:00 2021-04-06T21:11:07.909766+00:00 0:00:01.822475 14339 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T21:11:03.668130+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T21:10:57.942388+00:00 2021-04-06T21:10:59.618432+00:00 0:00:01.676044 14338 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T21:10:55.590312+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T20:00:00+00:00 PythonOperator 2021-04-06T21:10:45.860479+00:00 2021-04-06T21:10:48.935319+00:00 0:00:03.074840 14337 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T21:10:43.546821+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T20:00:00+00:00 PythonOperator 2021-04-06T21:10:38.160865+00:00 2021-04-06T21:10:40.919445+00:00 0:00:02.758580 14336 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T21:10:35.522341+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T20:00:00+00:00 TriggerDagRunOperator 2021-04-06T21:10:25.927584+00:00 2021-04-06T21:10:26.495444+00:00 0:00:00.567860 14335 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T21:10:23.613054+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T20:00:00+00:00 TriggerDagRunOperator 2021-04-06T21:10:25.908191+00:00 2021-04-06T21:10:26.328119+00:00 0:00:00.419928 14334 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T21:10:23.613023+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T20:05:00+00:00 EmrJobFlowSensor 2021-04-06T21:05:55.349373+00:00 2021-04-06T21:15:58.141572+00:00 0:10:02.792199 14333 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T21:05:53.156642+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T20:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T21:05:27.382942+00:00 2021-04-06T21:05:29.158597+00:00 0:00:01.775655 14332 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T21:05:25.134810+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T20:05:00+00:00 PythonOperator 2021-04-06T21:05:05.372797+00:00 2021-04-06T21:05:08.051537+00:00 0:00:02.678740 14331 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T21:05:03.113050+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T20:00:00+00:00 EmrJobFlowSensor 2021-04-06T21:01:05.266487+00:00 2021-04-06T21:10:07.903192+00:00 0:09:02.636705 14330 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T21:01:02.773883+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T21:00:42.946132+00:00 2021-04-06T21:00:44.749600+00:00 0:00:01.803468 14329 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T21:00:40.688721+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T20:00:00+00:00 PythonOperator 2021-04-06T21:00:23.135839+00:00 2021-04-06T21:00:26.487466+00:00 0:00:03.351627 14328 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T21:00:20.658486+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T19:00:00+00:00 EmrJobFlowSensor 2021-04-06T20:11:34.456746+00:00 2021-04-06T20:20:37.036689+00:00 0:09:02.579943 14326 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T20:11:32.185886+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T19:00:00+00:00 EmrJobFlowSensor 2021-04-06T20:11:24.629561+00:00 2021-04-06T20:21:27.345376+00:00 0:10:02.715815 14325 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T20:11:22.160623+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T20:11:12.328214+00:00 2021-04-06T20:11:14.055337+00:00 0:00:01.727123 14324 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T20:11:10.149672+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T20:11:04.458799+00:00 2021-04-06T20:11:06.319965+00:00 0:00:01.861166 14323 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T20:11:02.140671+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T19:00:00+00:00 PythonOperator 2021-04-06T20:10:50.514855+00:00 2021-04-06T20:10:53.327306+00:00 0:00:02.812451 14322 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T20:10:48.147521+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T19:00:00+00:00 PythonOperator 2021-04-06T20:10:40.802213+00:00 2021-04-06T20:10:43.766265+00:00 0:00:02.964052 14321 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T20:10:38.071801+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T19:00:00+00:00 TriggerDagRunOperator 2021-04-06T20:10:28.612786+00:00 2021-04-06T20:10:29.131088+00:00 0:00:00.518302 14320 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T20:10:26.071178+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T19:00:00+00:00 TriggerDagRunOperator 2021-04-06T20:10:28.413455+00:00 2021-04-06T20:10:28.862405+00:00 0:00:00.448950 14319 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T20:10:26.071217+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T19:05:00+00:00 EmrJobFlowSensor 2021-04-06T20:06:01.968956+00:00 2021-04-06T20:15:04.586909+00:00 0:09:02.617953 14318 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T20:05:59.687286+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T19:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T20:05:39.878073+00:00 2021-04-06T20:05:41.649652+00:00 0:00:01.771579 14317 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T20:05:37.634282+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T19:05:00+00:00 PythonOperator 2021-04-06T20:05:19.883632+00:00 2021-04-06T20:05:22.647945+00:00 0:00:02.764313 14316 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T20:05:17.617152+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T19:00:00+00:00 EmrJobFlowSensor 2021-04-06T20:01:07.370937+00:00 2021-04-06T20:10:10.125106+00:00 0:09:02.754169 14315 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T20:01:05.167627+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T20:00:43.376481+00:00 2021-04-06T20:00:45.192442+00:00 0:00:01.815961 14314 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T20:00:41.105375+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T19:00:00+00:00 PythonOperator 2021-04-06T20:00:15.911929+00:00 2021-04-06T20:00:18.640750+00:00 0:00:02.728821 14313 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T20:00:13.152395+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T18:00:00+00:00 EmrJobFlowSensor 2021-04-06T19:12:19.426417+00:00 2021-04-06T19:21:22.145232+00:00 0:09:02.718815 14311 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T19:12:17.040991+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T18:00:00+00:00 EmrJobFlowSensor 2021-04-06T19:12:13.252896+00:00 2021-04-06T19:24:16.385089+00:00 0:12:03.132193 14310 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T19:12:10.916864+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T19:11:57.300303+00:00 2021-04-06T19:11:59.095930+00:00 0:00:01.795627 14309 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T19:11:54.967402+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T19:11:51.399893+00:00 2021-04-06T19:11:53.086959+00:00 0:00:01.687066 14308 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T19:11:48.960588+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T18:00:00+00:00 PythonOperator 2021-04-06T19:11:37.208154+00:00 2021-04-06T19:11:39.946597+00:00 0:00:02.738443 14307 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T19:11:34.895291+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T18:00:00+00:00 PythonOperator 2021-04-06T19:11:31.846844+00:00 2021-04-06T19:11:34.732633+00:00 0:00:02.885789 14306 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T19:11:28.974500+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T18:00:00+00:00 TriggerDagRunOperator 2021-04-06T19:11:19.312315+00:00 2021-04-06T19:11:19.756437+00:00 0:00:00.444122 14305 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T19:11:16.844691+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T18:00:00+00:00 TriggerDagRunOperator 2021-04-06T19:11:19.222396+00:00 2021-04-06T19:11:19.779832+00:00 0:00:00.557436 14304 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T19:11:16.844720+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T18:05:00+00:00 EmrJobFlowSensor 2021-04-06T19:05:58.397769+00:00 2021-04-06T19:15:00.958204+00:00 0:09:02.560435 14303 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T19:05:56.215583+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T19:05:36.358825+00:00 2021-04-06T19:05:38.019731+00:00 0:00:01.660906 14302 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T19:05:34.198266+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T18:05:00+00:00 PythonOperator 2021-04-06T19:05:12.373639+00:00 2021-04-06T19:05:15.094922+00:00 0:00:02.721283 14301 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T19:05:10.176130+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T18:00:00+00:00 EmrJobFlowSensor 2021-04-06T19:00:56.151334+00:00 2021-04-06T19:10:59.060697+00:00 0:10:02.909363 14300 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T19:00:53.883008+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T19:00:36.113845+00:00 2021-04-06T19:00:37.777288+00:00 0:00:01.663443 14299 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T19:00:33.857345+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T18:00:00+00:00 PythonOperator 2021-04-06T19:00:12.597726+00:00 2021-04-06T19:00:15.488982+00:00 0:00:02.891256 14298 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T19:00:09.790649+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T17:00:00+00:00 EmrJobFlowSensor 2021-04-06T18:11:28.922500+00:00 2021-04-06T18:21:31.765915+00:00 0:10:02.843415 14296 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T18:11:26.618998+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T17:00:00+00:00 EmrJobFlowSensor 2021-04-06T18:11:14.934629+00:00 2021-04-06T18:20:17.483130+00:00 0:09:02.548501 14295 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T18:11:12.607938+00:00 2 default_pool
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