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_campaign-history-job_v002 2021-04-01T18:00:00+00:00 TriggerDagRunOperator 2021-04-01T19:10:36.098678+00:00 2021-04-01T19:10:36.508638+00:00 0:00:00.409960 12499 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T19:10:33.895391+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T18:05:00+00:00 EmrJobFlowSensor 2021-04-01T19:05:55.663379+00:00 2021-04-01T19:14:58.316432+00:00 0:09:02.653053 12498 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T19:05:53.520980+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T19:05:33.898078+00:00 2021-04-01T19:05:35.618737+00:00 0:00:01.720659 12497 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T19:05:31.518858+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T18:05:00+00:00 PythonOperator 2021-04-01T19:05:11.948713+00:00 2021-04-01T19:05:14.633504+00:00 0:00:02.684791 12496 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T19:05:09.554670+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T18:00:00+00:00 EmrJobFlowSensor 2021-04-01T19:01:07.107809+00:00 2021-04-01T19:10:09.764630+00:00 0:09:02.656821 12495 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T19:01:04.908687+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T19:00:45.281939+00:00 2021-04-01T19:00:46.988306+00:00 0:00:01.706367 12494 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T19:00:42.901150+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T18:00:00+00:00 PythonOperator 2021-04-01T19:00:25.104855+00:00 2021-04-01T19:00:27.874495+00:00 0:00:02.769640 12493 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T19:00:22.845482+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T17:00:00+00:00 EmrJobFlowSensor 2021-04-01T18:11:40.298330+00:00 2021-04-01T18:21:43.090368+00:00 0:10:02.792038 12491 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T18:11:38.057053+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T17:00:00+00:00 EmrJobFlowSensor 2021-04-01T18:11:36.422225+00:00 2021-04-01T18:20:39.209546+00:00 0:09:02.787321 12490 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T18:11:34.045183+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T18:11:18.288186+00:00 2021-04-01T18:11:20.017102+00:00 0:00:01.728916 12489 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T18:11:15.919951+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T18:11:14.349614+00:00 2021-04-01T18:11:16.203143+00:00 0:00:01.853529 12488 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T18:11:11.916838+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T17:00:00+00:00 PythonOperator 2021-04-01T18:10:56.580374+00:00 2021-04-01T18:10:59.267561+00:00 0:00:02.687187 12487 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T18:10:53.967573+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T17:00:00+00:00 PythonOperator 2021-04-01T18:10:52.516737+00:00 2021-04-01T18:10:55.620894+00:00 0:00:03.104157 12486 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T18:10:49.960906+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T17:00:00+00:00 TriggerDagRunOperator 2021-04-01T18:10:40.542926+00:00 2021-04-01T18:10:41.044391+00:00 0:00:00.501465 12485 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T18:10:37.891882+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T17:00:00+00:00 TriggerDagRunOperator 2021-04-01T18:10:40.193413+00:00 2021-04-01T18:10:40.617768+00:00 0:00:00.424355 12484 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T18:10:37.891851+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T17:05:00+00:00 EmrJobFlowSensor 2021-04-01T18:05:55.675487+00:00 2021-04-01T18:14:58.264953+00:00 0:09:02.589466 12483 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T18:05:53.325300+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T17:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T18:05:33.491679+00:00 2021-04-01T18:05:35.131946+00:00 0:00:01.640267 12482 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T18:05:31.307279+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T17:05:00+00:00 PythonOperator 2021-04-01T18:05:11.602951+00:00 2021-04-01T18:05:14.285767+00:00 0:00:02.682816 12481 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T18:05:09.289775+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T17:00:00+00:00 EmrJobFlowSensor 2021-04-01T18:01:15.151390+00:00 2021-04-01T18:10:18.005557+00:00 0:09:02.854167 12480 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T18:01:12.801517+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T18:00:52.994750+00:00 2021-04-01T18:00:54.673818+00:00 0:00:01.679068 12479 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T18:00:50.786472+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T17:00:00+00:00 PythonOperator 2021-04-01T18:00:21.151002+00:00 2021-04-01T18:00:24.018348+00:00 0:00:02.867346 12478 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T18:00:18.758794+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T16:00:00+00:00 EmrJobFlowSensor 2021-04-01T17:10:10.647198+00:00 2021-04-01T17:20:13.403656+00:00 0:10:02.756458 12476 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T17:10:07.932068+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T16:00:00+00:00 EmrJobFlowSensor 2021-04-01T17:10:08.214430+00:00 2021-04-01T17:20:11.369806+00:00 0:10:03.155376 12475 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T17:10:05.934346+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T17:09:48.421902+00:00 2021-04-01T17:09:50.198345+00:00 0:00:01.776443 12474 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T17:09:45.957309+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T17:09:46.458194+00:00 2021-04-01T17:09:48.265773+00:00 0:00:01.807579 12473 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T17:09:43.995540+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T16:00:00+00:00 PythonOperator 2021-04-01T17:09:26.484690+00:00 2021-04-01T17:09:29.356431+00:00 0:00:02.871741 12472 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T17:09:23.977387+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T16:00:00+00:00 PythonOperator 2021-04-01T17:09:24.339645+00:00 2021-04-01T17:09:27.317214+00:00 0:00:02.977569 12471 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T17:09:21.963354+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T16:00:00+00:00 TriggerDagRunOperator 2021-04-01T17:09:20.327845+00:00 2021-04-01T17:09:20.847089+00:00 0:00:00.519244 12470 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T17:09:17.958607+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T16:00:00+00:00 TriggerDagRunOperator 2021-04-01T17:09:20.217956+00:00 2021-04-01T17:09:20.648227+00:00 0:00:00.430271 12469 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T17:09:17.958561+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T16:05:00+00:00 EmrJobFlowSensor 2021-04-01T17:06:03.768299+00:00 2021-04-01T17:14:06.250794+00:00 0:08:02.482495 12468 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T17:06:01.560532+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T16:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T17:05:41.828894+00:00 2021-04-01T17:05:43.556935+00:00 0:00:01.728041 12467 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T17:05:39.515636+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T16:05:00+00:00 PythonOperator 2021-04-01T17:05:21.685649+00:00 2021-04-01T17:05:24.386700+00:00 0:00:02.701051 12466 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T17:05:19.500671+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T16:00:00+00:00 EmrJobFlowSensor 2021-04-01T17:01:05.380202+00:00 2021-04-01T17:09:07.933639+00:00 0:08:02.553437 12465 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T17:01:02.982073+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T17:00:31.256483+00:00 2021-04-01T17:00:32.931915+00:00 0:00:01.675432 12464 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T17:00:28.970215+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T16:00:00+00:00 PythonOperator 2021-04-01T17:00:11.193451+00:00 2021-04-01T17:00:13.968223+00:00 0:00:02.774772 12463 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T17:00:08.919901+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T15:00:00+00:00 EmrJobFlowSensor 2021-04-01T16:12:29.801454+00:00 2021-04-01T16:22:32.556587+00:00 0:10:02.755133 12461 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T16:12:27.390565+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T15:00:00+00:00 EmrJobFlowSensor 2021-04-01T16:12:17.696966+00:00 2021-04-01T16:21:20.343419+00:00 0:09:02.646453 12460 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T16:12:15.378979+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T16:12:07.776763+00:00 2021-04-01T16:12:09.516407+00:00 0:00:01.739644 12459 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T16:12:05.369177+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T16:11:55.621782+00:00 2021-04-01T16:11:57.290970+00:00 0:00:01.669188 12458 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T16:11:53.315117+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T15:00:00+00:00 PythonOperator 2021-04-01T16:11:47.725519+00:00 2021-04-01T16:11:50.695384+00:00 0:00:02.969865 12457 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T16:11:45.355534+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T15:00:00+00:00 PythonOperator 2021-04-01T16:11:33.864587+00:00 2021-04-01T16:11:36.659505+00:00 0:00:02.794918 12456 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T16:11:31.288673+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T15:00:00+00:00 TriggerDagRunOperator 2021-04-01T16:11:27.557851+00:00 2021-04-01T16:11:28.064071+00:00 0:00:00.506220 12455 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T16:11:25.189808+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T15:00:00+00:00 TriggerDagRunOperator 2021-04-01T16:11:27.401747+00:00 2021-04-01T16:11:27.830050+00:00 0:00:00.428303 12454 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T16:11:25.189780+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T15:05:00+00:00 EmrJobFlowSensor 2021-04-01T16:06:01.179657+00:00 2021-04-01T16:15:03.826067+00:00 0:09:02.646410 12453 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T16:05:58.670770+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T15:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T16:05:39.009286+00:00 2021-04-01T16:05:40.708846+00:00 0:00:01.699560 12452 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T16:05:36.546294+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T15:05:00+00:00 PythonOperator 2021-04-01T16:05:18.770784+00:00 2021-04-01T16:05:21.519066+00:00 0:00:02.748282 12451 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T16:05:16.445497+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T15:00:00+00:00 EmrJobFlowSensor 2021-04-01T16:01:04.366110+00:00 2021-04-01T16:11:07.230000+00:00 0:10:02.863890 12450 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T16:01:02.031050+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T16:00:42.177087+00:00 2021-04-01T16:00:44.005050+00:00 0:00:01.827963 12449 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T16:00:40.011944+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T15:00:00+00:00 PythonOperator 2021-04-01T16:00:20.297333+00:00 2021-04-01T16:00:23.012639+00:00 0:00:02.715306 12448 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T16:00:17.994733+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T14:00:00+00:00 EmrJobFlowSensor 2021-04-01T15:12:26.898661+00:00 2021-04-01T15:21:29.536119+00:00 0:09:02.637458 12446 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T15:12:24.552355+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T14:00:00+00:00 EmrJobFlowSensor 2021-04-01T15:12:25.066052+00:00 2021-04-01T15:21:27.649545+00:00 0:09:02.583493 12445 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T15:12:22.642126+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T15:12:06.602372+00:00 2021-04-01T15:12:08.321389+00:00 0:00:01.719017 12444 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T15:12:04.398499+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T15:12:02.644178+00:00 2021-04-01T15:12:04.364220+00:00 0:00:01.720042 12443 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T15:12:00.381962+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T14:00:00+00:00 PythonOperator 2021-04-01T15:11:44.709844+00:00 2021-04-01T15:11:47.680970+00:00 0:00:02.971126 12442 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T15:11:42.256577+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T14:00:00+00:00 PythonOperator 2021-04-01T15:11:40.531187+00:00 2021-04-01T15:11:43.355742+00:00 0:00:02.824555 12441 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T15:11:38.253889+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T14:00:00+00:00 TriggerDagRunOperator 2021-04-01T15:11:18.824887+00:00 2021-04-01T15:11:19.354302+00:00 0:00:00.529415 12440 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T15:11:16.234401+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T14:00:00+00:00 TriggerDagRunOperator 2021-04-01T15:11:18.696824+00:00 2021-04-01T15:11:19.119119+00:00 0:00:00.422295 12439 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T15:11:16.234432+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T14:05:00+00:00 EmrJobFlowSensor 2021-04-01T15:05:57.982446+00:00 2021-04-01T15:15:00.735862+00:00 0:09:02.753416 12438 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T15:05:55.789233+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T14:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T15:05:36.092495+00:00 2021-04-01T15:05:37.841666+00:00 0:00:01.749171 12437 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T15:05:33.727664+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T14:05:00+00:00 PythonOperator 2021-04-01T15:05:14.117314+00:00 2021-04-01T15:05:16.892941+00:00 0:00:02.775627 12436 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T15:05:11.751221+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T14:00:00+00:00 EmrJobFlowSensor 2021-04-01T15:00:59.503258+00:00 2021-04-01T15:11:02.394667+00:00 0:10:02.891409 12435 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T15:00:57.111371+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T15:00:37.321488+00:00 2021-04-01T15:00:39.110182+00:00 0:00:01.788694 12434 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T15:00:35.085979+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T14:00:00+00:00 PythonOperator 2021-04-01T15:00:17.449253+00:00 2021-04-01T15:00:20.302947+00:00 0:00:02.853694 12433 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T15:00:15.011662+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T13:00:00+00:00 EmrJobFlowSensor 2021-04-01T14:12:24.322999+00:00 2021-04-01T14:20:26.805187+00:00 0:08:02.482188 12431 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T14:12:21.963873+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T13:00:00+00:00 EmrJobFlowSensor 2021-04-01T14:12:08.484070+00:00 2021-04-01T14:23:11.605377+00:00 0:11:03.121307 12430 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T14:12:05.958317+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T14:12:04.315523+00:00 2021-04-01T14:12:06.001254+00:00 0:00:01.685731 12429 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T14:12:01.945874+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T14:11:48.177484+00:00 2021-04-01T14:11:49.997361+00:00 0:00:01.819877 12428 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T14:11:45.844735+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T13:00:00+00:00 PythonOperator 2021-04-01T14:11:42.074276+00:00 2021-04-01T14:11:44.897010+00:00 0:00:02.822734 12427 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T14:11:39.840105+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T13:00:00+00:00 PythonOperator 2021-04-01T14:11:26.081499+00:00 2021-04-01T14:11:29.029730+00:00 0:00:02.948231 12426 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T14:11:23.825711+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T13:00:00+00:00 TriggerDagRunOperator 2021-04-01T14:11:20.231327+00:00 2021-04-01T14:11:20.762993+00:00 0:00:00.531666 12425 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T14:11:17.822796+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T13:00:00+00:00 TriggerDagRunOperator 2021-04-01T14:11:20.034925+00:00 2021-04-01T14:11:20.459459+00:00 0:00:00.424534 12424 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T14:11:17.822762+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T13:05:00+00:00 EmrJobFlowSensor 2021-04-01T14:06:05.579545+00:00 2021-04-01T14:14:08.130773+00:00 0:08:02.551228 12423 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T14:06:03.290693+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T13:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T14:05:45.670537+00:00 2021-04-01T14:05:47.383531+00:00 0:00:01.712994 12422 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T14:05:43.236368+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T13:05:00+00:00 PythonOperator 2021-04-01T14:05:23.367536+00:00 2021-04-01T14:05:26.138936+00:00 0:00:02.771400 12421 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T14:05:21.217753+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T13:00:00+00:00 EmrJobFlowSensor 2021-04-01T14:00:53.587444+00:00 2021-04-01T14:10:56.540986+00:00 0:10:02.953542 12420 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T14:00:50.808850+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T14:00:31.355619+00:00 2021-04-01T14:00:33.090568+00:00 0:00:01.734949 12419 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T14:00:28.867647+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T13:00:00+00:00 PythonOperator 2021-04-01T14:00:09.189853+00:00 2021-04-01T14:00:11.931412+00:00 0:00:02.741559 12418 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T14:00:06.743017+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T12:00:00+00:00 EmrJobFlowSensor 2021-04-01T13:11:13.506861+00:00 2021-04-01T13:28:17.149649+00:00 0:17:03.642788 12416 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T13:11:11.292990+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T12:00:00+00:00 EmrJobFlowSensor 2021-04-01T13:11:09.629469+00:00 2021-04-01T13:19:12.150971+00:00 0:08:02.521502 12415 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T13:11:07.298787+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T13:10:53.619186+00:00 2021-04-01T13:10:55.459752+00:00 0:00:01.840566 12414 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T13:10:51.260248+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T13:10:49.636884+00:00 2021-04-01T13:10:51.414962+00:00 0:00:01.778078 12413 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T13:10:47.257114+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T12:00:00+00:00 PythonOperator 2021-04-01T13:10:31.620718+00:00 2021-04-01T13:10:34.604014+00:00 0:00:02.983296 12412 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T13:10:29.245636+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T12:00:00+00:00 PythonOperator 2021-04-01T13:10:27.404798+00:00 2021-04-01T13:10:30.216663+00:00 0:00:02.811865 12411 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T13:10:25.240356+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T12:00:00+00:00 TriggerDagRunOperator 2021-04-01T13:10:07.762268+00:00 2021-04-01T13:10:08.181959+00:00 0:00:00.419691 12410 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T13:10:05.271701+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T12:00:00+00:00 TriggerDagRunOperator 2021-04-01T13:10:07.774630+00:00 2021-04-01T13:10:08.334627+00:00 0:00:00.559997 12409 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T13:10:05.271744+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T12:05:00+00:00 EmrJobFlowSensor 2021-04-01T13:05:55.144177+00:00 2021-04-01T13:14:57.729072+00:00 0:09:02.584895 12408 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T13:05:52.823950+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T12:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T13:05:33.284402+00:00 2021-04-01T13:05:34.910977+00:00 0:00:01.626575 12407 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T13:05:30.863250+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T12:05:00+00:00 PythonOperator 2021-04-01T13:05:10.970056+00:00 2021-04-01T13:05:13.653966+00:00 0:00:02.683910 12406 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T13:05:08.776713+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T12:00:00+00:00 EmrJobFlowSensor 2021-04-01T13:00:46.661684+00:00 2021-04-01T13:09:49.506042+00:00 0:09:02.844358 12405 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T13:00:44.286616+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T13:00:26.419977+00:00 2021-04-01T13:00:28.147306+00:00 0:00:01.727329 12404 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T13:00:24.260821+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T12:00:00+00:00 PythonOperator 2021-04-01T13:00:04.704856+00:00 2021-04-01T13:00:07.478682+00:00 0:00:02.773826 12403 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T13:00:02.203530+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T11:00:00+00:00 EmrJobFlowSensor 2021-04-01T12:12:37.713404+00:00 2021-04-01T12:24:40.978214+00:00 0:12:03.264810 12401 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T12:12:35.068306+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T11:00:00+00:00 EmrJobFlowSensor 2021-04-01T12:12:37.410270+00:00 2021-04-01T12:20:39.951397+00:00 0:08:02.541127 12400 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T12:12:35.068255+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T12:12:15.727088+00:00 2021-04-01T12:12:17.560930+00:00 0:00:01.833842 12399 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T12:12:13.058875+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T12:12:15.596575+00:00 2021-04-01T12:12:17.329539+00:00 0:00:01.732964 12398 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T12:12:13.058826+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T11:00:00+00:00 PythonOperator 2021-04-01T12:11:55.317538+00:00 2021-04-01T12:11:58.191893+00:00 0:00:02.874355 12397 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T12:11:52.944470+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T11:00:00+00:00 PythonOperator 2021-04-01T12:11:55.225828+00:00 2021-04-01T12:11:58.223425+00:00 0:00:02.997597 12396 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T12:11:52.944505+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T11:00:00+00:00 TriggerDagRunOperator 2021-04-01T12:11:37.330750+00:00 2021-04-01T12:11:37.859843+00:00 0:00:00.529093 12395 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T12:11:34.930157+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T11:00:00+00:00 TriggerDagRunOperator 2021-04-01T12:11:37.246206+00:00 2021-04-01T12:11:37.660640+00:00 0:00:00.414434 12394 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T12:11:34.930123+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T11:05:00+00:00 EmrJobFlowSensor 2021-04-01T12:06:08.665271+00:00 2021-04-01T12:15:11.244140+00:00 0:09:02.578869 12393 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T12:06:06.433832+00:00 2 default_pool