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 check_cluster_status 2021-05-10T06:00:00+00:00 EmrJobFlowSensor 2021-05-10T07:00:46.765249+00:00 2021-05-10T07:09:49.514922+00:00 0:09:02.749673 26462 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T07:00:44.601235+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T07:00:24.743587+00:00 2021-05-10T07:00:26.486535+00:00 0:00:01.742948 26461 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T07:00:22.506202+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T06:00:00+00:00 PythonOperator 2021-05-10T07:00:04.784355+00:00 2021-05-10T07:00:07.867073+00:00 0:00:03.082718 26460 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T07:00:02.488908+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-10T05:00:00+00:00 EmrJobFlowSensor 2021-05-10T06:12:01.069425+00:00 2021-05-10T06:22:04.132403+00:00 0:10:03.062978 26458 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T06:11:58.568946+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-10T05:00:00+00:00 EmrJobFlowSensor 2021-05-10T06:11:48.759923+00:00 2021-05-10T06:19:51.278433+00:00 0:08:02.518510 26457 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T06:11:46.375424+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-10T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T06:11:38.930029+00:00 2021-05-10T06:11:40.731102+00:00 0:00:01.801073 26456 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T06:11:36.360690+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-10T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T06:11:28.614425+00:00 2021-05-10T06:11:30.404603+00:00 0:00:01.790178 26455 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T06:11:26.391785+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-10T05:00:00+00:00 PythonOperator 2021-05-10T06:11:18.924532+00:00 2021-05-10T06:11:22.364997+00:00 0:00:03.440465 26454 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T06:11:16.374986+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-10T05:00:00+00:00 PythonOperator 2021-05-10T06:11:06.530177+00:00 2021-05-10T06:11:09.653648+00:00 0:00:03.123471 26453 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T06:11:04.356723+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T05:00:00+00:00 TriggerDagRunOperator 2021-05-10T06:11:01.224149+00:00 2021-05-10T06:11:01.639287+00:00 0:00:00.415138 26452 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T06:10:58.280773+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T05:00:00+00:00 TriggerDagRunOperator 2021-05-10T06:11:00.847457+00:00 2021-05-10T06:11:01.399097+00:00 0:00:00.551640 26451 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T06:10:58.280817+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-10T05:05:00+00:00 EmrJobFlowSensor 2021-05-10T06:06:05.960266+00:00 2021-05-10T06:15:08.594826+00:00 0:09:02.634560 26450 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T06:06:03.866041+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-10T05:05:00+00:00 EmrCreateJobFlowOperator 2021-05-10T06:05:44.123195+00:00 2021-05-10T06:05:45.865627+00:00 0:00:01.742432 26449 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T06:05:41.832786+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-10T05:05:00+00:00 PythonOperator 2021-05-10T06:05:24.408098+00:00 2021-05-10T06:05:27.501572+00:00 0:00:03.093474 26448 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T06:05:21.851170+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T05:00:00+00:00 EmrJobFlowSensor 2021-05-10T06:00:49.355365+00:00 2021-05-10T06:10:52.302680+00:00 0:10:02.947315 26447 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T06:00:47.157404+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T06:00:27.409499+00:00 2021-05-10T06:00:29.165537+00:00 0:00:01.756038 26446 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T06:00:25.155878+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T05:00:00+00:00 PythonOperator 2021-05-10T06:00:05.822028+00:00 2021-05-10T06:00:08.950425+00:00 0:00:03.128397 26445 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T06:00:03.078093+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-10T04:00:00+00:00 EmrJobFlowSensor 2021-05-10T05:11:24.145603+00:00 2021-05-10T05:21:26.958818+00:00 0:10:02.813215 26443 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T05:11:21.136062+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-10T04:00:00+00:00 EmrJobFlowSensor 2021-05-10T05:11:21.243820+00:00 2021-05-10T05:19:24.243046+00:00 0:08:02.999226 26442 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T05:11:19.131906+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-10T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T05:11:03.405633+00:00 2021-05-10T05:11:05.189713+00:00 0:00:01.784080 26441 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T05:11:01.035623+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-10T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T05:11:01.321059+00:00 2021-05-10T05:11:03.155769+00:00 0:00:01.834710 26440 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T05:10:59.057275+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-10T04:00:00+00:00 PythonOperator 2021-05-10T05:10:41.528900+00:00 2021-05-10T05:10:44.873919+00:00 0:00:03.345019 26439 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T05:10:39.021472+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-10T04:00:00+00:00 PythonOperator 2021-05-10T05:10:39.227394+00:00 2021-05-10T05:10:42.763092+00:00 0:00:03.535698 26438 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T05:10:37.021124+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T04:00:00+00:00 TriggerDagRunOperator 2021-05-10T05:10:25.351178+00:00 2021-05-10T05:10:25.867785+00:00 0:00:00.516607 26437 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T05:10:23.009614+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T04:00:00+00:00 TriggerDagRunOperator 2021-05-10T05:10:25.292880+00:00 2021-05-10T05:10:25.697479+00:00 0:00:00.404599 26436 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T05:10:23.009645+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-10T04:05:00+00:00 EmrJobFlowSensor 2021-05-10T05:05:56.687077+00:00 2021-05-10T05:14:59.385090+00:00 0:09:02.698013 26435 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T05:05:54.456670+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-10T04:05:00+00:00 EmrCreateJobFlowOperator 2021-05-10T05:05:36.911774+00:00 2021-05-10T05:05:38.542001+00:00 0:00:01.630227 26434 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T05:05:34.373516+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-10T04:05:00+00:00 PythonOperator 2021-05-10T05:05:14.708324+00:00 2021-05-10T05:05:17.804452+00:00 0:00:03.096128 26433 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T05:05:12.373374+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T04:00:00+00:00 EmrJobFlowSensor 2021-05-10T05:01:00.119424+00:00 2021-05-10T05:10:03.110664+00:00 0:09:02.991240 26432 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T05:00:57.688511+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T05:00:37.836329+00:00 2021-05-10T05:00:39.582607+00:00 0:00:01.746278 26431 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T05:00:35.658790+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T04:00:00+00:00 PythonOperator 2021-05-10T05:00:16.251784+00:00 2021-05-10T05:00:19.356960+00:00 0:00:03.105176 26430 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T05:00:13.599893+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-10T03:00:00+00:00 EmrJobFlowSensor 2021-05-10T04:12:12.167717+00:00 2021-05-10T04:21:14.879745+00:00 0:09:02.712028 26428 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T04:12:09.966230+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-10T03:00:00+00:00 EmrJobFlowSensor 2021-05-10T04:12:06.198574+00:00 2021-05-10T04:22:09.115934+00:00 0:10:02.917360 26427 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T04:12:03.971527+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-10T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T04:11:50.282160+00:00 2021-05-10T04:11:51.973879+00:00 0:00:01.691719 26426 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T04:11:47.947940+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-10T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T04:11:42.096652+00:00 2021-05-10T04:11:43.944603+00:00 0:00:01.847951 26425 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T04:11:39.890718+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-10T03:00:00+00:00 PythonOperator 2021-05-10T04:11:27.948859+00:00 2021-05-10T04:11:31.263071+00:00 0:00:03.314212 26424 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T04:11:25.837772+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-10T03:00:00+00:00 PythonOperator 2021-05-10T04:11:20.265396+00:00 2021-05-10T04:11:23.323927+00:00 0:00:03.058531 26423 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T04:11:17.832075+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T03:00:00+00:00 TriggerDagRunOperator 2021-05-10T04:11:08.406021+00:00 2021-05-10T04:11:08.969588+00:00 0:00:00.563567 26422 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T04:11:05.822062+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T03:00:00+00:00 TriggerDagRunOperator 2021-05-10T04:11:07.984026+00:00 2021-05-10T04:11:08.414394+00:00 0:00:00.430368 26421 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T04:11:05.822033+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-10T03:05:00+00:00 EmrJobFlowSensor 2021-05-10T04:05:55.619397+00:00 2021-05-10T04:13:58.318539+00:00 0:08:02.699142 26420 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T04:05:53.351562+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-10T03:05:00+00:00 EmrCreateJobFlowOperator 2021-05-10T04:05:33.790165+00:00 2021-05-10T04:05:35.523665+00:00 0:00:01.733500 26419 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T04:05:31.363183+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-10T03:05:00+00:00 PythonOperator 2021-05-10T04:05:11.568873+00:00 2021-05-10T04:05:14.624060+00:00 0:00:03.055187 26418 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T04:05:09.288564+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T03:00:00+00:00 EmrJobFlowSensor 2021-05-10T04:00:46.928584+00:00 2021-05-10T04:10:49.844302+00:00 0:10:02.915718 26417 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T04:00:44.655177+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T04:00:24.646990+00:00 2021-05-10T04:00:26.398621+00:00 0:00:01.751631 26416 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T04:00:22.504248+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T03:00:00+00:00 PythonOperator 2021-05-10T04:00:04.927118+00:00 2021-05-10T04:00:08.096253+00:00 0:00:03.169135 26415 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T04:00:02.485324+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-10T02:00:00+00:00 EmrJobFlowSensor 2021-05-10T03:12:07.842341+00:00 2021-05-10T03:19:10.251333+00:00 0:07:02.408992 26413 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T03:12:05.278532+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-10T02:00:00+00:00 EmrJobFlowSensor 2021-05-10T03:11:09.602801+00:00 2021-05-10T03:20:12.271774+00:00 0:09:02.668973 26412 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T03:11:07.164827+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-10T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T03:10:49.490174+00:00 2021-05-10T03:10:51.193515+00:00 0:00:01.703341 26411 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T03:10:47.176491+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-10T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T03:10:47.474641+00:00 2021-05-10T03:10:49.272494+00:00 0:00:01.797853 26410 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T03:10:45.186607+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-10T02:00:00+00:00 PythonOperator 2021-05-10T03:10:27.454966+00:00 2021-05-10T03:10:30.556815+00:00 0:00:03.101849 26409 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T03:10:25.131015+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-10T02:00:00+00:00 PythonOperator 2021-05-10T03:10:27.409370+00:00 2021-05-10T03:10:30.770856+00:00 0:00:03.361486 26408 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T03:10:25.131040+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T02:00:00+00:00 TriggerDagRunOperator 2021-05-10T03:10:17.393813+00:00 2021-05-10T03:10:17.931915+00:00 0:00:00.538102 26407 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T03:10:15.124933+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T02:00:00+00:00 TriggerDagRunOperator 2021-05-10T03:10:17.178611+00:00 2021-05-10T03:10:17.635028+00:00 0:00:00.456417 26406 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T03:10:15.124999+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-10T02:05:00+00:00 EmrJobFlowSensor 2021-05-10T03:05:50.974403+00:00 2021-05-10T03:13:53.541444+00:00 0:08:02.567041 26405 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T03:05:48.657722+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-10T02:05:00+00:00 EmrCreateJobFlowOperator 2021-05-10T03:05:29.008908+00:00 2021-05-10T03:05:30.659836+00:00 0:00:01.650928 26404 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T03:05:26.561398+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-10T02:05:00+00:00 PythonOperator 2021-05-10T03:05:08.732891+00:00 2021-05-10T03:05:11.812333+00:00 0:00:03.079442 26403 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T03:05:06.455554+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T02:00:00+00:00 EmrJobFlowSensor 2021-05-10T03:00:50.342218+00:00 2021-05-10T03:09:53.117066+00:00 0:09:02.774848 26402 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T03:00:48.037723+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T03:00:28.108485+00:00 2021-05-10T03:00:29.837631+00:00 0:00:01.729146 26401 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T03:00:26.021145+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T02:00:00+00:00 PythonOperator 2021-05-10T03:00:08.609987+00:00 2021-05-10T03:00:11.713471+00:00 0:00:03.103484 26400 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T03:00:06.003618+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-10T01:00:00+00:00 EmrJobFlowSensor 2021-05-10T02:12:28.048308+00:00 2021-05-10T02:21:30.701086+00:00 0:09:02.652778 26398 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T02:12:25.860294+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-10T01:00:00+00:00 EmrJobFlowSensor 2021-05-10T02:12:07.994983+00:00 2021-05-10T02:21:10.607361+00:00 0:09:02.612378 26397 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T02:12:05.814221+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-10T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T02:12:06.444519+00:00 2021-05-10T02:12:08.329780+00:00 0:00:01.885261 26396 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T02:12:03.871788+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-10T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T02:11:46.418520+00:00 2021-05-10T02:11:48.192158+00:00 0:00:01.773638 26395 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T02:11:43.857254+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-10T01:00:00+00:00 PythonOperator 2021-05-10T02:11:44.005115+00:00 2021-05-10T02:11:47.290116+00:00 0:00:03.285001 26394 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T02:11:41.799892+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-10T01:00:00+00:00 PythonOperator 2021-05-10T02:11:23.899995+00:00 2021-05-10T02:11:27.043813+00:00 0:00:03.143818 26393 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T02:11:21.751023+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T01:00:00+00:00 TriggerDagRunOperator 2021-05-10T02:11:20.123028+00:00 2021-05-10T02:11:20.708489+00:00 0:00:00.585461 26392 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T02:11:17.749947+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T01:00:00+00:00 TriggerDagRunOperator 2021-05-10T02:11:19.933560+00:00 2021-05-10T02:11:20.362223+00:00 0:00:00.428663 26391 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T02:11:17.749917+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-10T01:05:00+00:00 EmrJobFlowSensor 2021-05-10T02:06:01.339050+00:00 2021-05-10T02:15:03.956194+00:00 0:09:02.617144 26390 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T02:05:59.052239+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-10T01:05:00+00:00 EmrCreateJobFlowOperator 2021-05-10T02:05:39.216484+00:00 2021-05-10T02:05:40.991468+00:00 0:00:01.774984 26389 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T02:05:36.921748+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-10T01:05:00+00:00 PythonOperator 2021-05-10T02:05:18.990260+00:00 2021-05-10T02:05:22.060432+00:00 0:00:03.070172 26388 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T02:05:16.901625+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T01:00:00+00:00 EmrJobFlowSensor 2021-05-10T02:00:58.850604+00:00 2021-05-10T02:11:01.685978+00:00 0:10:02.835374 26387 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T02:00:56.555660+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T02:00:38.925277+00:00 2021-05-10T02:00:40.749959+00:00 0:00:01.824682 26386 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T02:00:36.543740+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T01:00:00+00:00 PythonOperator 2021-05-10T02:00:10.976586+00:00 2021-05-10T02:00:14.216244+00:00 0:00:03.239658 26385 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T02:00:08.515786+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-10T00:00:00+00:00 EmrJobFlowSensor 2021-05-10T01:11:12.939299+00:00 2021-05-10T01:23:16.102817+00:00 0:12:03.163518 26383 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T01:11:10.596741+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-10T00:00:00+00:00 EmrJobFlowSensor 2021-05-10T01:11:10.889791+00:00 2021-05-10T01:21:13.763559+00:00 0:10:02.873768 26382 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T01:11:08.663530+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-10T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T01:10:52.964560+00:00 2021-05-10T01:10:54.759158+00:00 0:00:01.794598 26381 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T01:10:50.543888+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-10T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T01:10:51.008236+00:00 2021-05-10T01:10:52.680041+00:00 0:00:01.671805 26380 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T01:10:48.571576+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-10T00:00:00+00:00 PythonOperator 2021-05-10T01:10:31.340348+00:00 2021-05-10T01:10:34.640066+00:00 0:00:03.299718 26379 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T01:10:28.466350+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-10T00:00:00+00:00 PythonOperator 2021-05-10T01:10:29.301611+00:00 2021-05-10T01:10:32.827485+00:00 0:00:03.525874 26378 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T01:10:26.417994+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T00:00:00+00:00 TriggerDagRunOperator 2021-05-10T01:10:20.990143+00:00 2021-05-10T01:10:21.542498+00:00 0:00:00.552355 26377 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T01:10:18.408589+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T00:00:00+00:00 TriggerDagRunOperator 2021-05-10T01:10:20.570236+00:00 2021-05-10T01:10:20.952968+00:00 0:00:00.382732 26376 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T01:10:18.408620+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-10T00:05:00+00:00 EmrJobFlowSensor 2021-05-10T01:05:47.977798+00:00 2021-05-10T01:14:50.636022+00:00 0:09:02.658224 26375 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T01:05:45.919061+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-10T00:05:00+00:00 EmrCreateJobFlowOperator 2021-05-10T01:05:26.233764+00:00 2021-05-10T01:05:27.999380+00:00 0:00:01.765616 26374 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T01:05:23.968415+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-10T00:05:00+00:00 PythonOperator 2021-05-10T01:05:04.056666+00:00 2021-05-10T01:05:07.098713+00:00 0:00:03.042047 26373 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T01:05:01.873252+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T00:00:00+00:00 EmrJobFlowSensor 2021-05-10T01:01:09.927305+00:00 2021-05-10T01:10:12.847360+00:00 0:09:02.920055 26372 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T01:01:07.461360+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T01:00:43.646287+00:00 2021-05-10T01:00:45.538793+00:00 0:00:01.892506 26371 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T01:00:41.381290+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T00:00:00+00:00 PythonOperator 2021-05-10T01:00:19.702686+00:00 2021-05-10T01:00:22.797173+00:00 0:00:03.094487 26370 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T01:00:17.362838+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-09T23:00:00+00:00 EmrJobFlowSensor 2021-05-10T00:12:31.098057+00:00 2021-05-10T00:20:33.569652+00:00 0:08:02.471595 26368 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T00:12:28.841256+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-09T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T00:12:11.144695+00:00 2021-05-10T00:12:12.950107+00:00 0:00:01.805412 26367 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T00:12:08.676403+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-09T23:00:00+00:00 EmrJobFlowSensor 2021-05-10T00:11:50.839135+00:00 2021-05-10T00:20:53.589002+00:00 0:09:02.749867 26366 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T00:11:48.649729+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-09T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T00:11:22.690821+00:00 2021-05-10T00:11:24.398123+00:00 0:00:01.707302 26365 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T00:11:20.528761+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-09T23:00:00+00:00 PythonOperator 2021-05-10T00:10:55.117316+00:00 2021-05-10T00:10:58.431876+00:00 0:00:03.314560 26364 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T00:10:52.501147+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-09T23:00:00+00:00 PythonOperator 2021-05-10T00:10:46.574475+00:00 2021-05-10T00:10:49.638569+00:00 0:00:03.064094 26363 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T00:10:44.495996+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T23:00:00+00:00 TriggerDagRunOperator 2021-05-10T00:10:31.021342+00:00 2021-05-10T00:10:31.550564+00:00 0:00:00.529222 26362 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T00:10:28.553361+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T23:00:00+00:00 TriggerDagRunOperator 2021-05-10T00:10:30.874713+00:00 2021-05-10T00:10:31.301561+00:00 0:00:00.426848 26361 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T00:10:28.553407+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-09T23:05:00+00:00 EmrJobFlowSensor 2021-05-10T00:05:48.548823+00:00 2021-05-10T00:14:51.085392+00:00 0:09:02.536569 26360 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T00:05:46.153323+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-09T23:05:00+00:00 EmrCreateJobFlowOperator 2021-05-10T00:05:28.328382+00:00 2021-05-10T00:05:30.130521+00:00 0:00:01.802139 26359 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T00:05:26.028706+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-09T23:05:00+00:00 PythonOperator 2021-05-10T00:05:06.203523+00:00 2021-05-10T00:05:09.251248+00:00 0:00:03.047725 26358 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T00:05:04.008054+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T23:00:00+00:00 EmrJobFlowSensor 2021-05-10T00:01:07.931157+00:00 2021-05-10T00:10:10.796315+00:00 0:09:02.865158 26357 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T00:01:05.689348+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T00:00:43.911916+00:00 2021-05-10T00:00:45.644069+00:00 0:00:01.732153 26356 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T00:00:41.617348+00:00 2 default_pool