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 check_cluster_status 2021-04-21T01:05:00+00:00 EmrJobFlowSensor 2021-04-21T02:06:00.094019+00:00 2021-04-21T02:15:03.081372+00:00 0:09:02.987353 19470 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T02:05:57.857139+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-21T01:05:00+00:00 EmrCreateJobFlowOperator 2021-04-21T02:05:31.983926+00:00 2021-04-21T02:05:33.771946+00:00 0:00:01.788020 19469 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T02:05:29.809770+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-21T01:05:00+00:00 PythonOperator 2021-04-21T02:05:10.112696+00:00 2021-04-21T02:05:12.996005+00:00 0:00:02.883309 19468 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T02:05:07.852778+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-21T01:00:00+00:00 EmrJobFlowSensor 2021-04-21T02:00:57.941704+00:00 2021-04-21T02:10:00.553552+00:00 0:09:02.611848 19467 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T02:00:55.432587+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-21T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T02:00:35.664246+00:00 2021-04-21T02:00:37.346225+00:00 0:00:01.681979 19466 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-21T02:00:33.415683+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-21T01:00:00+00:00 PythonOperator 2021-04-21T02:00:15.928408+00:00 2021-04-21T02:00:18.923427+00:00 0:00:02.995019 19465 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-21T02:00:13.397278+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-21T00:00:00+00:00 EmrJobFlowSensor 2021-04-21T01:11:17.759317+00:00 2021-04-21T01:21:20.510684+00:00 0:10:02.751367 19463 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T01:11:14.722987+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-21T00:00:00+00:00 EmrJobFlowSensor 2021-04-21T01:11:15.695692+00:00 2021-04-21T01:20:18.614864+00:00 0:09:02.919172 19462 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T01:11:12.769236+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-21T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T01:10:57.340873+00:00 2021-04-21T01:10:59.224409+00:00 0:00:01.883536 19461 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T01:10:54.705333+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-21T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T01:10:54.900502+00:00 2021-04-21T01:10:56.897528+00:00 0:00:01.997026 19460 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T01:10:52.706265+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-21T00:00:00+00:00 PythonOperator 2021-04-21T01:10:35.402128+00:00 2021-04-21T01:10:38.539466+00:00 0:00:03.137338 19459 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T01:10:32.685138+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-21T00:00:00+00:00 PythonOperator 2021-04-21T01:10:32.828231+00:00 2021-04-21T01:10:36.193821+00:00 0:00:03.365590 19458 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T01:10:30.685745+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-21T00:00:00+00:00 TriggerDagRunOperator 2021-04-21T01:10:16.926074+00:00 2021-04-21T01:10:17.491486+00:00 0:00:00.565412 19457 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T01:10:14.648443+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-21T00:00:00+00:00 TriggerDagRunOperator 2021-04-21T01:10:16.855581+00:00 2021-04-21T01:10:17.358276+00:00 0:00:00.502695 19456 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T01:10:14.648416+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-21T00:05:00+00:00 EmrJobFlowSensor 2021-04-21T01:05:56.363230+00:00 2021-04-21T01:14:58.896745+00:00 0:09:02.533515 19455 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T01:05:54.230064+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-21T00:05:00+00:00 EmrCreateJobFlowOperator 2021-04-21T01:05:34.556412+00:00 2021-04-21T01:05:36.334624+00:00 0:00:01.778212 19454 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T01:05:32.207428+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-21T00:05:00+00:00 PythonOperator 2021-04-21T01:05:14.468841+00:00 2021-04-21T01:05:17.382282+00:00 0:00:02.913441 19453 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T01:05:12.191620+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-21T00:00:00+00:00 EmrJobFlowSensor 2021-04-21T01:00:55.944809+00:00 2021-04-21T01:09:58.620648+00:00 0:09:02.675839 19452 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T01:00:53.777485+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-21T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T01:00:36.046097+00:00 2021-04-21T01:00:37.935606+00:00 0:00:01.889509 19451 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-21T01:00:33.752465+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-21T00:00:00+00:00 PythonOperator 2021-04-21T01:00:14.988561+00:00 2021-04-21T01:00:17.957492+00:00 0:00:02.968931 19450 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-21T01:00:11.725140+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-20T23:00:00+00:00 EmrJobFlowSensor 2021-04-21T00:10:04.253990+00:00 2021-04-21T00:19:07.131426+00:00 0:09:02.877436 19448 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T00:10:01.886707+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-20T23:00:00+00:00 EmrJobFlowSensor 2021-04-21T00:09:54.363266+00:00 2021-04-21T00:18:56.978808+00:00 0:09:02.615542 19447 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T00:09:51.850235+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-20T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T00:09:32.018665+00:00 2021-04-21T00:09:33.815010+00:00 0:00:01.796345 19446 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T00:09:29.825445+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-20T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T00:09:30.229268+00:00 2021-04-21T00:09:31.900220+00:00 0:00:01.670952 19445 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T00:09:27.841881+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-20T23:00:00+00:00 PythonOperator 2021-04-21T00:09:12.006410+00:00 2021-04-21T00:09:15.197827+00:00 0:00:03.191417 19444 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T00:09:09.809698+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-20T23:00:00+00:00 PythonOperator 2021-04-21T00:09:06.298357+00:00 2021-04-21T00:09:09.256201+00:00 0:00:02.957844 19443 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T00:09:03.861229+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-20T23:00:00+00:00 TriggerDagRunOperator 2021-04-21T00:09:00.291751+00:00 2021-04-21T00:09:00.850974+00:00 0:00:00.559223 19442 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T00:08:57.864674+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-20T23:00:00+00:00 TriggerDagRunOperator 2021-04-21T00:09:00.181958+00:00 2021-04-21T00:09:00.615075+00:00 0:00:00.433117 19441 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T00:08:57.864722+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-20T23:05:00+00:00 EmrJobFlowSensor 2021-04-21T00:05:53.577489+00:00 2021-04-21T00:14:56.146940+00:00 0:09:02.569451 19440 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T00:05:51.402244+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-20T23:05:00+00:00 EmrCreateJobFlowOperator 2021-04-21T00:05:33.473891+00:00 2021-04-21T00:05:35.140209+00:00 0:00:01.666318 19439 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T00:05:31.338268+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-20T23:05:00+00:00 PythonOperator 2021-04-21T00:05:11.409149+00:00 2021-04-21T00:05:14.713879+00:00 0:00:03.304730 19438 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T00:05:09.284350+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-20T23:00:00+00:00 EmrJobFlowSensor 2021-04-21T00:00:46.959490+00:00 2021-04-21T00:08:49.514699+00:00 0:08:02.555209 19437 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T00:00:44.693817+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-20T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T00:00:25.236261+00:00 2021-04-21T00:00:27.048080+00:00 0:00:01.811819 19436 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-21T00:00:22.664656+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-20T23:00:00+00:00 PythonOperator 2021-04-21T00:00:05.097248+00:00 2021-04-21T00:00:08.167859+00:00 0:00:03.070611 19435 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-21T00:00:02.534264+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-20T22:00:00+00:00 EmrJobFlowSensor 2021-04-20T23:11:04.416577+00:00 2021-04-20T23:21:07.427467+00:00 0:10:03.010890 19433 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T23:11:01.891749+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-20T22:00:00+00:00 EmrJobFlowSensor 2021-04-20T23:11:04.286753+00:00 2021-04-20T23:21:07.275030+00:00 0:10:02.988277 19432 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T23:11:01.891781+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-20T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T23:10:44.279052+00:00 2021-04-20T23:10:46.119032+00:00 0:00:01.839980 19431 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T23:10:41.847342+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-20T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T23:10:42.702537+00:00 2021-04-20T23:10:44.380422+00:00 0:00:01.677885 19430 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T23:10:39.851333+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-20T22:00:00+00:00 PythonOperator 2021-04-20T23:10:22.961744+00:00 2021-04-20T23:10:25.903380+00:00 0:00:02.941636 19429 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T23:10:19.831552+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-20T22:00:00+00:00 PythonOperator 2021-04-20T23:10:20.944498+00:00 2021-04-20T23:10:24.690403+00:00 0:00:03.745905 19428 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T23:10:17.828035+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-20T22:00:00+00:00 TriggerDagRunOperator 2021-04-20T23:10:12.046773+00:00 2021-04-20T23:10:12.480017+00:00 0:00:00.433244 19427 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T23:10:09.822970+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-20T22:00:00+00:00 TriggerDagRunOperator 2021-04-20T23:10:12.025626+00:00 2021-04-20T23:10:12.634817+00:00 0:00:00.609191 19426 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T23:10:09.823004+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-20T22:05:00+00:00 EmrJobFlowSensor 2021-04-20T23:06:01.558844+00:00 2021-04-20T23:15:04.184543+00:00 0:09:02.625699 19425 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T23:05:59.417719+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-20T22:05:00+00:00 EmrCreateJobFlowOperator 2021-04-20T23:05:41.745748+00:00 2021-04-20T23:05:43.423453+00:00 0:00:01.677705 19424 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T23:05:39.393485+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-20T22:05:00+00:00 PythonOperator 2021-04-20T23:05:19.447002+00:00 2021-04-20T23:05:22.521155+00:00 0:00:03.074153 19423 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T23:05:17.329585+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-20T22:00:00+00:00 EmrJobFlowSensor 2021-04-20T23:00:51.040703+00:00 2021-04-20T23:09:53.958581+00:00 0:09:02.917878 19422 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T23:00:48.833066+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-20T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T23:00:29.240688+00:00 2021-04-20T23:00:30.942981+00:00 0:00:01.702293 19421 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-20T23:00:26.808053+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-20T22:00:00+00:00 PythonOperator 2021-04-20T23:00:09.300496+00:00 2021-04-20T23:00:12.214475+00:00 0:00:02.913979 19420 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-20T23:00:06.788366+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-20T21:00:00+00:00 EmrJobFlowSensor 2021-04-20T22:11:19.564061+00:00 2021-04-20T22:21:22.242942+00:00 0:10:02.678881 19418 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T22:11:17.398146+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-20T21:00:00+00:00 EmrJobFlowSensor 2021-04-20T22:11:15.701798+00:00 2021-04-20T22:21:18.525255+00:00 0:10:02.823457 19417 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T22:11:13.397351+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-20T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T22:10:59.806153+00:00 2021-04-20T22:11:01.772999+00:00 0:00:01.966846 19416 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T22:10:57.346333+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-20T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T22:10:55.687044+00:00 2021-04-20T22:10:57.368372+00:00 0:00:01.681328 19415 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T22:10:53.337095+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-20T21:00:00+00:00 PythonOperator 2021-04-20T22:10:37.712939+00:00 2021-04-20T22:10:40.932763+00:00 0:00:03.219824 19414 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T22:10:35.293186+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-20T21:00:00+00:00 PythonOperator 2021-04-20T22:10:33.898373+00:00 2021-04-20T22:10:37.142974+00:00 0:00:03.244601 19413 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T22:10:31.291315+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-20T21:00:00+00:00 TriggerDagRunOperator 2021-04-20T22:10:17.931316+00:00 2021-04-20T22:10:18.473216+00:00 0:00:00.541900 19412 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T22:10:15.246775+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-20T21:00:00+00:00 TriggerDagRunOperator 2021-04-20T22:10:17.484144+00:00 2021-04-20T22:10:17.915801+00:00 0:00:00.431657 19411 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T22:10:15.246745+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-20T21:05:00+00:00 EmrJobFlowSensor 2021-04-20T22:06:05.303904+00:00 2021-04-20T22:15:07.944071+00:00 0:09:02.640167 19410 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T22:06:02.952063+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-20T21:05:00+00:00 EmrCreateJobFlowOperator 2021-04-20T22:05:43.074406+00:00 2021-04-20T22:05:44.775662+00:00 0:00:01.701256 19409 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T22:05:40.859967+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-20T21:05:00+00:00 PythonOperator 2021-04-20T22:05:20.866594+00:00 2021-04-20T22:05:23.838548+00:00 0:00:02.971954 19408 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T22:05:18.686937+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-20T21:00:00+00:00 EmrJobFlowSensor 2021-04-20T22:00:58.595309+00:00 2021-04-20T22:10:01.328167+00:00 0:09:02.732858 19407 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T22:00:56.200240+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-20T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T22:00:36.401921+00:00 2021-04-20T22:00:38.199826+00:00 0:00:01.797905 19406 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-20T22:00:34.153946+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-20T21:00:00+00:00 PythonOperator 2021-04-20T22:00:16.529897+00:00 2021-04-20T22:00:19.744329+00:00 0:00:03.214432 19405 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-20T22:00:14.138503+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-20T20:00:00+00:00 EmrJobFlowSensor 2021-04-20T21:11:29.088701+00:00 2021-04-20T21:21:31.833952+00:00 0:10:02.745251 19403 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T21:11:26.408386+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-20T20:00:00+00:00 EmrJobFlowSensor 2021-04-20T21:11:24.710878+00:00 2021-04-20T21:21:27.330545+00:00 0:10:02.619667 19402 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T21:11:22.415113+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-20T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T21:11:08.745680+00:00 2021-04-20T21:11:10.558347+00:00 0:00:01.812667 19401 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T21:11:06.390881+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-20T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T21:11:02.667790+00:00 2021-04-20T21:11:04.506105+00:00 0:00:01.838315 19400 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T21:11:00.382473+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-20T20:00:00+00:00 PythonOperator 2021-04-20T21:10:46.487290+00:00 2021-04-20T21:10:49.622309+00:00 0:00:03.135019 19399 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T21:10:44.310549+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-20T20:00:00+00:00 PythonOperator 2021-04-20T21:10:40.735251+00:00 2021-04-20T21:10:43.751677+00:00 0:00:03.016426 19398 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T21:10:38.368590+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-20T20:00:00+00:00 TriggerDagRunOperator 2021-04-20T21:10:25.095937+00:00 2021-04-20T21:10:25.617486+00:00 0:00:00.521549 19397 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T21:10:22.377149+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-20T20:00:00+00:00 TriggerDagRunOperator 2021-04-20T21:10:24.836593+00:00 2021-04-20T21:10:25.255274+00:00 0:00:00.418681 19396 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T21:10:22.377071+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-20T20:05:00+00:00 EmrJobFlowSensor 2021-04-20T21:05:54.171351+00:00 2021-04-20T21:14:56.802257+00:00 0:09:02.630906 19395 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T21:05:51.952687+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-20T20:05:00+00:00 EmrCreateJobFlowOperator 2021-04-20T21:05:34.093355+00:00 2021-04-20T21:05:35.823811+00:00 0:00:01.730456 19394 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T21:05:31.855121+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-20T20:05:00+00:00 PythonOperator 2021-04-20T21:05:12.143790+00:00 2021-04-20T21:05:15.039271+00:00 0:00:02.895481 19393 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T21:05:09.835285+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-20T20:00:00+00:00 EmrJobFlowSensor 2021-04-20T21:01:07.801834+00:00 2021-04-20T21:10:10.631008+00:00 0:09:02.829174 19392 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T21:01:05.487856+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-20T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T21:00:45.905233+00:00 2021-04-20T21:00:47.708223+00:00 0:00:01.802990 19391 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-20T21:00:43.475931+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-20T20:00:00+00:00 PythonOperator 2021-04-20T21:00:26.105056+00:00 2021-04-20T21:00:29.356324+00:00 0:00:03.251268 19390 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-20T21:00:23.422562+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-20T19:00:00+00:00 EmrJobFlowSensor 2021-04-20T20:10:12.917143+00:00 2021-04-20T20:18:15.516255+00:00 0:08:02.599112 19388 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T20:10:10.492280+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-20T19:00:00+00:00 EmrJobFlowSensor 2021-04-20T20:10:12.677475+00:00 2021-04-20T20:20:15.479235+00:00 0:10:02.801760 19387 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T20:10:10.492248+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-20T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T20:09:50.919810+00:00 2021-04-20T20:09:52.746937+00:00 0:00:01.827127 19386 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T20:09:48.469357+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-20T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T20:09:50.840594+00:00 2021-04-20T20:09:52.557722+00:00 0:00:01.717128 19385 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T20:09:48.469384+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-20T19:00:00+00:00 PythonOperator 2021-04-20T20:09:29.132383+00:00 2021-04-20T20:09:32.108998+00:00 0:00:02.976615 19384 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T20:09:26.456401+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-20T19:00:00+00:00 PythonOperator 2021-04-20T20:09:29.140486+00:00 2021-04-20T20:09:32.531701+00:00 0:00:03.391215 19383 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T20:09:26.456446+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-20T19:00:00+00:00 TriggerDagRunOperator 2021-04-20T20:09:08.849138+00:00 2021-04-20T20:09:09.412357+00:00 0:00:00.563219 19382 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T20:09:06.341008+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-20T19:00:00+00:00 TriggerDagRunOperator 2021-04-20T20:09:08.644691+00:00 2021-04-20T20:09:09.116256+00:00 0:00:00.471565 19381 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T20:09:06.341035+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-20T19:05:00+00:00 EmrJobFlowSensor 2021-04-20T20:05:56.188351+00:00 2021-04-20T20:13:58.683436+00:00 0:08:02.495085 19380 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T20:05:54.040937+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-20T19:05:00+00:00 EmrCreateJobFlowOperator 2021-04-20T20:05:34.388895+00:00 2021-04-20T20:05:36.131528+00:00 0:00:01.742633 19379 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T20:05:32.021860+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-20T19:05:00+00:00 PythonOperator 2021-04-20T20:05:12.196116+00:00 2021-04-20T20:05:15.097912+00:00 0:00:02.901796 19378 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T20:05:10.011432+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-20T19:00:00+00:00 EmrJobFlowSensor 2021-04-20T20:00:53.854258+00:00 2021-04-20T20:08:56.413817+00:00 0:08:02.559559 19377 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T20:00:51.501186+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-20T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T20:00:27.728744+00:00 2021-04-20T20:00:29.411923+00:00 0:00:01.683179 19376 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-20T20:00:25.546792+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-20T19:00:00+00:00 PythonOperator 2021-04-20T20:00:06.095496+00:00 2021-04-20T20:00:09.047033+00:00 0:00:02.951537 19375 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-20T20:00:03.406205+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-20T18:00:00+00:00 EmrJobFlowSensor 2021-04-20T19:12:05.378605+00:00 2021-04-20T19:20:07.979091+00:00 0:08:02.600486 19373 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T19:12:02.619101+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-20T18:00:00+00:00 EmrJobFlowSensor 2021-04-20T19:11:51.112385+00:00 2021-04-20T19:21:53.890903+00:00 0:10:02.778518 19372 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T19:11:48.671918+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-20T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T19:11:42.841365+00:00 2021-04-20T19:11:44.502787+00:00 0:00:01.661422 19371 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T19:11:40.591170+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-20T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T19:11:31.630648+00:00 2021-04-20T19:11:33.392945+00:00 0:00:01.762297 19370 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T19:11:28.664787+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-20T18:00:00+00:00 PythonOperator 2021-04-20T19:11:22.792926+00:00 2021-04-20T19:11:25.709575+00:00 0:00:02.916649 19369 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T19:11:20.510678+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-20T18:00:00+00:00 PythonOperator 2021-04-20T19:11:09.358769+00:00 2021-04-20T19:11:12.621925+00:00 0:00:03.263156 19368 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T19:11:06.500378+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-20T18:00:00+00:00 TriggerDagRunOperator 2021-04-20T19:10:58.836771+00:00 2021-04-20T19:10:59.348861+00:00 0:00:00.512090 19367 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T19:10:56.492299+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-20T18:00:00+00:00 TriggerDagRunOperator 2021-04-20T19:10:58.716728+00:00 2021-04-20T19:10:59.124345+00:00 0:00:00.407617 19366 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T19:10:56.492336+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-20T18:05:00+00:00 EmrJobFlowSensor 2021-04-20T19:05:52.164375+00:00 2021-04-20T19:14:54.754147+00:00 0:09:02.589772 19365 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T19:05:50.034245+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-20T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-20T19:05:30.226293+00:00 2021-04-20T19:05:31.854838+00:00 0:00:01.628545 19364 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T19:05:28.012875+00:00 2 default_pool