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-05-07T08:05:00+00:00 EmrJobFlowSensor 2021-05-07T09:05:58.138851+00:00 2021-05-07T09:16:00.890104+00:00 0:10:02.751253 25409 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T09:05:56.055046+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-07T08:05:00+00:00 EmrCreateJobFlowOperator 2021-05-07T09:05:38.349383+00:00 2021-05-07T09:05:40.075158+00:00 0:00:01.725775 25408 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T09:05:36.036478+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-07T08:05:00+00:00 PythonOperator 2021-05-07T09:05:16.400742+00:00 2021-05-07T09:05:19.417933+00:00 0:00:03.017191 25407 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T09:05:14.073338+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T08:00:00+00:00 EmrJobFlowSensor 2021-05-07T09:01:16.027149+00:00 2021-05-07T09:10:18.775389+00:00 0:09:02.748240 25406 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T09:01:13.679405+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T09:00:53.863479+00:00 2021-05-07T09:00:55.582387+00:00 0:00:01.718908 25405 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T09:00:51.588588+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T08:00:00+00:00 PythonOperator 2021-05-07T09:00:34.289691+00:00 2021-05-07T09:00:37.391899+00:00 0:00:03.102208 25404 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T09:00:31.571000+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-07T07:00:00+00:00 EmrJobFlowSensor 2021-05-07T08:12:08.282821+00:00 2021-05-07T08:22:11.065288+00:00 0:10:02.782467 25402 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T08:12:06.007129+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-07T07:00:00+00:00 EmrJobFlowSensor 2021-05-07T08:12:06.094942+00:00 2021-05-07T08:22:08.860167+00:00 0:10:02.765225 25401 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T08:12:04.006443+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-07T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T08:11:46.301320+00:00 2021-05-07T08:11:47.979141+00:00 0:00:01.677821 25400 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T08:11:43.989880+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-07T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T08:11:42.101010+00:00 2021-05-07T08:11:43.921654+00:00 0:00:01.820644 25399 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T08:11:39.900272+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-07T07:00:00+00:00 PythonOperator 2021-05-07T08:11:26.991442+00:00 2021-05-07T08:11:30.141215+00:00 0:00:03.149773 25398 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T08:11:23.954166+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-07T07:00:00+00:00 PythonOperator 2021-05-07T08:11:22.101420+00:00 2021-05-07T08:11:25.856886+00:00 0:00:03.755466 25397 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T08:11:19.943764+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T07:00:00+00:00 TriggerDagRunOperator 2021-05-07T08:11:02.433763+00:00 2021-05-07T08:11:02.947156+00:00 0:00:00.513393 25396 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T08:10:59.657931+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T07:00:00+00:00 TriggerDagRunOperator 2021-05-07T08:11:02.088719+00:00 2021-05-07T08:11:02.484423+00:00 0:00:00.395704 25395 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T08:10:59.657879+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-07T07:05:00+00:00 EmrJobFlowSensor 2021-05-07T08:05:57.181940+00:00 2021-05-07T08:14:59.879161+00:00 0:09:02.697221 25394 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T08:05:54.941654+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-07T07:05:00+00:00 EmrCreateJobFlowOperator 2021-05-07T08:05:35.363338+00:00 2021-05-07T08:05:37.089090+00:00 0:00:01.725752 25393 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T08:05:32.953712+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-07T07:05:00+00:00 PythonOperator 2021-05-07T08:05:11.162887+00:00 2021-05-07T08:05:14.278114+00:00 0:00:03.115227 25392 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T08:05:08.879312+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T07:00:00+00:00 EmrJobFlowSensor 2021-05-07T08:00:46.442689+00:00 2021-05-07T08:10:49.471396+00:00 0:10:03.028707 25391 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T08:00:44.143292+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T08:00:26.656598+00:00 2021-05-07T08:00:28.522026+00:00 0:00:01.865428 25390 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T08:00:24.180432+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T07:00:00+00:00 PythonOperator 2021-05-07T08:00:04.493408+00:00 2021-05-07T08:00:07.565589+00:00 0:00:03.072181 25389 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T08:00:02.090033+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-07T06:00:00+00:00 EmrJobFlowSensor 2021-05-07T07:11:45.192376+00:00 2021-05-07T07:23:48.160138+00:00 0:12:02.967762 25387 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T07:11:42.904838+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-07T06:00:00+00:00 EmrJobFlowSensor 2021-05-07T07:11:27.035937+00:00 2021-05-07T07:20:29.668825+00:00 0:09:02.632888 25386 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T07:11:24.879110+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-07T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T07:11:23.005324+00:00 2021-05-07T07:11:24.730614+00:00 0:00:01.725290 25385 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T07:11:20.852542+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-07T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T07:11:01.080327+00:00 2021-05-07T07:11:02.928373+00:00 0:00:01.848046 25384 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T07:10:58.832252+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-07T06:00:00+00:00 PythonOperator 2021-05-07T07:10:50.974978+00:00 2021-05-07T07:10:54.304728+00:00 0:00:03.329750 25383 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T07:10:48.827377+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-07T06:00:00+00:00 PythonOperator 2021-05-07T07:10:35.442017+00:00 2021-05-07T07:10:38.504215+00:00 0:00:03.062198 25382 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T07:10:32.942437+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T06:00:00+00:00 TriggerDagRunOperator 2021-05-07T07:10:25.315842+00:00 2021-05-07T07:10:25.824651+00:00 0:00:00.508809 25381 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T07:10:22.808117+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T06:00:00+00:00 TriggerDagRunOperator 2021-05-07T07:10:25.006759+00:00 2021-05-07T07:10:25.441742+00:00 0:00:00.434983 25380 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T07:10:22.808151+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-07T06:05:00+00:00 EmrJobFlowSensor 2021-05-07T07:06:00.369132+00:00 2021-05-07T07:14:02.950126+00:00 0:08:02.580994 25379 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T07:05:58.055852+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-07T06:05:00+00:00 EmrCreateJobFlowOperator 2021-05-07T07:05:30.291483+00:00 2021-05-07T07:05:31.916572+00:00 0:00:01.625089 25378 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T07:05:27.970564+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-07T06:05:00+00:00 PythonOperator 2021-05-07T07:05:10.176686+00:00 2021-05-07T07:05:13.175563+00:00 0:00:02.998877 25377 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T07:05:07.907586+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T06:00:00+00:00 EmrJobFlowSensor 2021-05-07T07:00:57.688425+00:00 2021-05-07T07:10:00.309939+00:00 0:09:02.621514 25376 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T07:00:55.560381+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T07:00:33.839200+00:00 2021-05-07T07:00:35.594256+00:00 0:00:01.755056 25375 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T07:00:31.585904+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T06:00:00+00:00 PythonOperator 2021-05-07T07:00:11.898842+00:00 2021-05-07T07:00:15.073346+00:00 0:00:03.174504 25374 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T07:00:09.485481+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-07T05:00:00+00:00 EmrJobFlowSensor 2021-05-07T06:10:58.450278+00:00 2021-05-07T06:21:01.244709+00:00 0:10:02.794431 25372 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T06:10:56.190667+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-07T05:00:00+00:00 EmrJobFlowSensor 2021-05-07T06:10:48.615178+00:00 2021-05-07T06:18:51.084319+00:00 0:08:02.469141 25371 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T06:10:46.261566+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-07T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T06:10:36.498318+00:00 2021-05-07T06:10:38.166135+00:00 0:00:01.667817 25370 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T06:10:34.249074+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-07T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T06:10:26.581821+00:00 2021-05-07T06:10:28.366211+00:00 0:00:01.784390 25369 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T06:10:24.244208+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-07T05:00:00+00:00 PythonOperator 2021-05-07T06:10:16.465931+00:00 2021-05-07T06:10:19.712342+00:00 0:00:03.246411 25368 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T06:10:14.128051+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-07T05:00:00+00:00 PythonOperator 2021-05-07T06:10:06.639879+00:00 2021-05-07T06:10:09.691289+00:00 0:00:03.051410 25367 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T06:10:04.121500+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T05:00:00+00:00 TriggerDagRunOperator 2021-05-07T06:09:59.210699+00:00 2021-05-07T06:09:59.724251+00:00 0:00:00.513552 25366 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T06:09:56.165160+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T05:00:00+00:00 TriggerDagRunOperator 2021-05-07T06:09:58.589006+00:00 2021-05-07T06:09:59.002864+00:00 0:00:00.413858 25365 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T06:09:56.165203+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-07T05:05:00+00:00 EmrJobFlowSensor 2021-05-07T06:05:54.131547+00:00 2021-05-07T06:14:56.792783+00:00 0:09:02.661236 25364 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T06:05:51.570339+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-07T05:05:00+00:00 EmrCreateJobFlowOperator 2021-05-07T06:05:31.762788+00:00 2021-05-07T06:05:33.399602+00:00 0:00:01.636814 25363 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T06:05:29.444646+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-07T05:05:00+00:00 PythonOperator 2021-05-07T06:05:09.667379+00:00 2021-05-07T06:05:12.706316+00:00 0:00:03.038937 25362 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T06:05:07.255123+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T05:00:00+00:00 EmrJobFlowSensor 2021-05-07T06:00:46.933166+00:00 2021-05-07T06:09:49.750901+00:00 0:09:02.817735 25361 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T06:00:44.692807+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T06:00:25.077608+00:00 2021-05-07T06:00:26.904323+00:00 0:00:01.826715 25360 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T06:00:22.621857+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T05:00:00+00:00 PythonOperator 2021-05-07T06:00:04.822809+00:00 2021-05-07T06:00:07.941189+00:00 0:00:03.118380 25359 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T06:00:02.607341+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-07T04:00:00+00:00 EmrJobFlowSensor 2021-05-07T05:12:32.865126+00:00 2021-05-07T05:23:35.769827+00:00 0:11:02.904701 25357 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T05:12:30.450032+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-07T04:00:00+00:00 EmrJobFlowSensor 2021-05-07T05:12:26.733378+00:00 2021-05-07T05:22:29.353522+00:00 0:10:02.620144 25356 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T05:12:24.462048+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-07T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T05:12:10.814121+00:00 2021-05-07T05:12:12.612690+00:00 0:00:01.798569 25355 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T05:12:08.398575+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-07T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T05:12:06.492320+00:00 2021-05-07T05:12:08.226319+00:00 0:00:01.733999 25354 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T05:12:04.386407+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-07T04:00:00+00:00 PythonOperator 2021-05-07T05:11:50.811400+00:00 2021-05-07T05:11:53.888596+00:00 0:00:03.077196 25353 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T05:11:48.377084+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-07T04:00:00+00:00 PythonOperator 2021-05-07T05:11:44.601840+00:00 2021-05-07T05:11:47.998818+00:00 0:00:03.396978 25352 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T05:11:42.351778+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T04:00:00+00:00 TriggerDagRunOperator 2021-05-07T05:11:27.012111+00:00 2021-05-07T05:11:27.523150+00:00 0:00:00.511039 25351 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T05:11:24.339160+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T04:00:00+00:00 TriggerDagRunOperator 2021-05-07T05:11:26.759392+00:00 2021-05-07T05:11:27.180772+00:00 0:00:00.421380 25350 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T05:11:24.339130+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-07T04:05:00+00:00 EmrJobFlowSensor 2021-05-07T05:06:00.317400+00:00 2021-05-07T05:16:03.273654+00:00 0:10:02.956254 25349 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T05:05:57.850296+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-07T04:05:00+00:00 EmrCreateJobFlowOperator 2021-05-07T05:05:37.940424+00:00 2021-05-07T05:05:39.591646+00:00 0:00:01.651222 25348 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T05:05:35.693104+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-07T04:05:00+00:00 PythonOperator 2021-05-07T05:05:15.746423+00:00 2021-05-07T05:05:18.801419+00:00 0:00:03.054996 25347 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T05:05:13.540279+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T04:00:00+00:00 EmrJobFlowSensor 2021-05-07T05:00:59.393348+00:00 2021-05-07T05:11:02.313360+00:00 0:10:02.920012 25346 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T05:00:56.961134+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T05:00:39.265709+00:00 2021-05-07T05:00:40.914060+00:00 0:00:01.648351 25345 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T05:00:36.963648+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T04:00:00+00:00 PythonOperator 2021-05-07T05:00:17.026915+00:00 2021-05-07T05:00:20.154244+00:00 0:00:03.127329 25344 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T05:00:14.837603+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-07T03:00:00+00:00 EmrJobFlowSensor 2021-05-07T04:23:16.393203+00:00 2021-05-07T04:23:17.855220+00:00 0:00:01.462017 25342 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T04:23:14.245462+00:00 3 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-07T03:00:00+00:00 EmrJobFlowSensor 2021-05-07T04:23:10.631063+00:00 2021-05-07T04:23:12.196636+00:00 0:00:01.565573 25341 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T04:23:08.245812+00:00 3 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-07T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T04:12:03.490447+00:00 2021-05-07T04:12:05.202964+00:00 0:00:01.712517 25338 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T04:12:01.335767+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-07T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T04:11:49.704468+00:00 2021-05-07T04:11:51.541838+00:00 0:00:01.837370 25337 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T04:11:47.332730+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-07T03:00:00+00:00 PythonOperator 2021-05-07T04:11:39.800912+00:00 2021-05-07T04:11:42.984752+00:00 0:00:03.183840 25336 airflow-worker-2.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T04:11:37.316352+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-07T03:00:00+00:00 PythonOperator 2021-05-07T04:11:29.984032+00:00 2021-05-07T04:11:32.976595+00:00 0:00:02.992563 25335 airflow-worker-2.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T04:11:27.307661+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T03:00:00+00:00 TriggerDagRunOperator 2021-05-07T04:11:13.937430+00:00 2021-05-07T04:11:14.497234+00:00 0:00:00.559804 25334 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T04:11:11.345227+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T03:00:00+00:00 TriggerDagRunOperator 2021-05-07T04:11:13.806010+00:00 2021-05-07T04:11:14.321919+00:00 0:00:00.515909 25333 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T04:11:11.345194+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-07T03:05:00+00:00 EmrJobFlowSensor 2021-05-07T04:06:04.898533+00:00 2021-05-07T04:15:07.491819+00:00 0:09:02.593286 25332 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T04:06:02.571661+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-07T03:05:00+00:00 EmrCreateJobFlowOperator 2021-05-07T04:05:42.769464+00:00 2021-05-07T04:05:44.503343+00:00 0:00:01.733879 25331 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T04:05:40.495512+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-07T03:05:00+00:00 PythonOperator 2021-05-07T04:05:20.547170+00:00 2021-05-07T04:05:23.558172+00:00 0:00:03.011002 25330 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T04:05:18.468339+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T03:00:00+00:00 EmrJobFlowSensor 2021-05-07T04:00:46.147926+00:00 2021-05-07T04:10:49.158819+00:00 0:10:03.010893 25329 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T04:00:43.881917+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T04:00:26.125169+00:00 2021-05-07T04:00:27.955789+00:00 0:00:01.830620 25328 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T04:00:23.847428+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T03:00:00+00:00 PythonOperator 2021-05-07T04:00:04.484715+00:00 2021-05-07T04:00:07.545168+00:00 0:00:03.060453 25327 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T04:00:01.810792+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-07T02:00:00+00:00 EmrJobFlowSensor 2021-05-07T03:12:11.491308+00:00 2021-05-07T03:21:14.169723+00:00 0:09:02.678415 25325 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T03:12:09.352907+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-07T02:00:00+00:00 EmrJobFlowSensor 2021-05-07T03:12:09.822257+00:00 2021-05-07T03:21:12.597592+00:00 0:09:02.775335 25324 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T03:12:07.362011+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-07T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T03:11:49.470646+00:00 2021-05-07T03:11:51.137042+00:00 0:00:01.666396 25323 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T03:11:47.286648+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-07T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T03:11:47.519952+00:00 2021-05-07T03:11:49.346255+00:00 0:00:01.826303 25322 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T03:11:45.227368+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-07T02:00:00+00:00 PythonOperator 2021-05-07T03:11:29.727823+00:00 2021-05-07T03:11:32.973365+00:00 0:00:03.245542 25321 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T03:11:27.215393+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-07T02:00:00+00:00 PythonOperator 2021-05-07T03:11:27.313440+00:00 2021-05-07T03:11:30.736165+00:00 0:00:03.422725 25320 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T03:11:25.203905+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T02:00:00+00:00 TriggerDagRunOperator 2021-05-07T03:11:03.829552+00:00 2021-05-07T03:11:04.347639+00:00 0:00:00.518087 25319 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T03:11:01.187317+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T02:00:00+00:00 TriggerDagRunOperator 2021-05-07T03:11:03.725992+00:00 2021-05-07T03:11:04.135619+00:00 0:00:00.409627 25318 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T03:11:01.187349+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-07T02:05:00+00:00 EmrJobFlowSensor 2021-05-07T03:05:52.655014+00:00 2021-05-07T03:13:55.143642+00:00 0:08:02.488628 25317 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T03:05:50.532131+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-07T02:05:00+00:00 EmrCreateJobFlowOperator 2021-05-07T03:05:30.946660+00:00 2021-05-07T03:05:32.623144+00:00 0:00:01.676484 25316 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T03:05:28.668764+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-07T02:05:00+00:00 PythonOperator 2021-05-07T03:05:10.655622+00:00 2021-05-07T03:05:13.691216+00:00 0:00:03.035594 25315 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T03:05:08.490682+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T02:00:00+00:00 EmrJobFlowSensor 2021-05-07T03:00:48.552064+00:00 2021-05-07T03:10:51.515806+00:00 0:10:02.963742 25314 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T03:00:46.027837+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T03:00:26.374933+00:00 2021-05-07T03:00:28.145154+00:00 0:00:01.770221 25313 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T03:00:24.077616+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T02:00:00+00:00 PythonOperator 2021-05-07T03:00:06.763984+00:00 2021-05-07T03:00:09.832872+00:00 0:00:03.068888 25312 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T03:00:04.044405+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-07T01:00:00+00:00 EmrJobFlowSensor 2021-05-07T02:11:56.395053+00:00 2021-05-07T02:21:59.244630+00:00 0:10:02.849577 25310 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T02:11:53.785760+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-07T01:00:00+00:00 EmrJobFlowSensor 2021-05-07T02:11:50.318668+00:00 2021-05-07T02:21:53.248150+00:00 0:10:02.929482 25309 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T02:11:47.846530+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-07T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T02:11:35.998108+00:00 2021-05-07T02:11:37.756773+00:00 0:00:01.758665 25308 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T02:11:33.713176+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-07T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T02:11:27.894498+00:00 2021-05-07T02:11:29.563275+00:00 0:00:01.668777 25307 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T02:11:25.697824+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-07T01:00:00+00:00 PythonOperator 2021-05-07T02:11:13.909192+00:00 2021-05-07T02:11:17.201954+00:00 0:00:03.292762 25306 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T02:11:11.687651+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-07T01:00:00+00:00 PythonOperator 2021-05-07T02:11:07.880346+00:00 2021-05-07T02:11:10.893746+00:00 0:00:03.013400 25305 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T02:11:05.680218+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T01:00:00+00:00 TriggerDagRunOperator 2021-05-07T02:10:46.000975+00:00 2021-05-07T02:10:46.560726+00:00 0:00:00.559751 25304 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T02:10:43.605637+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T01:00:00+00:00 TriggerDagRunOperator 2021-05-07T02:10:45.958512+00:00 2021-05-07T02:10:46.399890+00:00 0:00:00.441378 25303 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T02:10:43.605607+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-07T01:05:00+00:00 EmrJobFlowSensor 2021-05-07T02:05:55.149320+00:00 2021-05-07T02:14:57.790950+00:00 0:09:02.641630 25302 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T02:05:52.926754+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-07T01:05:00+00:00 EmrCreateJobFlowOperator 2021-05-07T02:05:33.322889+00:00 2021-05-07T02:05:35.066427+00:00 0:00:01.743538 25301 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T02:05:30.910417+00:00 2 default_pool