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 create_cluster_and_add_emr_steps 2021-04-07T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T02:00:43.244637+00:00 2021-04-07T02:00:44.939789+00:00 0:00:01.695152 14404 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T02:00:40.861729+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T01:00:00+00:00 PythonOperator 2021-04-07T02:00:23.281330+00:00 2021-04-07T02:00:26.174917+00:00 0:00:02.893587 14403 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T02:00:20.751910+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-07T00:00:00+00:00 EmrJobFlowSensor 2021-04-07T01:12:04.162183+00:00 2021-04-07T01:21:06.797802+00:00 0:09:02.635619 14401 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T01:12:01.834788+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-07T00:00:00+00:00 EmrJobFlowSensor 2021-04-07T01:11:54.340106+00:00 2021-04-07T01:21:57.196954+00:00 0:10:02.856848 14400 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T01:11:51.826110+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-07T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T01:11:41.948780+00:00 2021-04-07T01:11:43.616991+00:00 0:00:01.668211 14399 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T01:11:39.816669+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-07T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T01:11:34.529546+00:00 2021-04-07T01:11:36.314698+00:00 0:00:01.785152 14398 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T01:11:31.809104+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-07T00:00:00+00:00 PythonOperator 2021-04-07T01:11:22.048572+00:00 2021-04-07T01:11:24.878897+00:00 0:00:02.830325 14397 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T01:11:19.799889+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-07T00:00:00+00:00 PythonOperator 2021-04-07T01:11:10.340380+00:00 2021-04-07T01:11:13.269814+00:00 0:00:02.929434 14396 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T01:11:07.857703+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T00:00:00+00:00 TriggerDagRunOperator 2021-04-07T01:11:00.841463+00:00 2021-04-07T01:11:01.349191+00:00 0:00:00.507728 14395 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T01:10:57.865665+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T00:00:00+00:00 TriggerDagRunOperator 2021-04-07T01:11:00.414675+00:00 2021-04-07T01:11:00.895462+00:00 0:00:00.480787 14394 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T01:10:57.865617+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-07T00:05:00+00:00 EmrJobFlowSensor 2021-04-07T01:05:47.348938+00:00 2021-04-07T01:14:49.959470+00:00 0:09:02.610532 14393 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T01:05:45.128328+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-07T00:05:00+00:00 EmrCreateJobFlowOperator 2021-04-07T01:05:27.415900+00:00 2021-04-07T01:05:29.147829+00:00 0:00:01.731929 14392 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T01:05:25.104754+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-07T00:05:00+00:00 PythonOperator 2021-04-07T01:05:05.386668+00:00 2021-04-07T01:05:08.069305+00:00 0:00:02.682637 14391 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T01:05:03.155407+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T00:00:00+00:00 EmrJobFlowSensor 2021-04-07T01:00:51.019454+00:00 2021-04-07T01:10:53.954185+00:00 0:10:02.934731 14390 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T01:00:48.605201+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T01:00:29.026822+00:00 2021-04-07T01:00:30.708903+00:00 0:00:01.682081 14389 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T01:00:26.578250+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T00:00:00+00:00 PythonOperator 2021-04-07T01:00:09.146184+00:00 2021-04-07T01:00:11.991896+00:00 0:00:02.845712 14388 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T01:00:06.579285+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T23:00:00+00:00 EmrJobFlowSensor 2021-04-07T00:11:22.020505+00:00 2021-04-07T00:19:24.555889+00:00 0:08:02.535384 14386 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T00:11:19.799410+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T23:00:00+00:00 EmrJobFlowSensor 2021-04-07T00:11:16.136355+00:00 2021-04-07T00:21:18.985348+00:00 0:10:02.848993 14385 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T00:11:13.807870+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T00:11:00.187899+00:00 2021-04-07T00:11:01.943730+00:00 0:00:01.755831 14384 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T00:10:57.844127+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T00:10:54.245792+00:00 2021-04-07T00:10:56.044421+00:00 0:00:01.798629 14383 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T00:10:51.775828+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T23:00:00+00:00 PythonOperator 2021-04-07T00:10:40.109230+00:00 2021-04-07T00:10:42.925187+00:00 0:00:02.815957 14382 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T00:10:37.764214+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T23:00:00+00:00 PythonOperator 2021-04-07T00:10:34.036865+00:00 2021-04-07T00:10:37.157057+00:00 0:00:03.120192 14381 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T00:10:31.758551+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T23:00:00+00:00 TriggerDagRunOperator 2021-04-07T00:10:24.393230+00:00 2021-04-07T00:10:24.970999+00:00 0:00:00.577769 14380 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T00:10:21.757638+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T23:00:00+00:00 TriggerDagRunOperator 2021-04-07T00:10:24.205991+00:00 2021-04-07T00:10:24.718727+00:00 0:00:00.512736 14379 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T00:10:21.757667+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T23:05:00+00:00 EmrJobFlowSensor 2021-04-07T00:06:03.602312+00:00 2021-04-07T00:15:06.420687+00:00 0:09:02.818375 14378 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T00:06:01.308907+00:00 2 default_pool
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