Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T17:00:40.348555+00:00 2021-05-04T17:00:42.050921+00:00 0:00:01.702366 24435 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T17:00:37.864424+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T16:00:00+00:00 PythonOperator 2021-05-04T17:00:18.381723+00:00 2021-05-04T17:00:21.452541+00:00 0:00:03.070818 24434 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T17:00:15.697545+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-04T15:00:00+00:00 EmrJobFlowSensor 2021-05-04T16:11:06.053470+00:00 2021-05-04T16:19:08.690220+00:00 0:08:02.636750 24432 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T16:11:03.146001+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-04T15:00:00+00:00 EmrJobFlowSensor 2021-05-04T16:11:03.676714+00:00 2021-05-04T16:20:06.723110+00:00 0:09:03.046396 24431 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T16:11:01.157488+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-04T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T16:10:44.044175+00:00 2021-05-04T16:10:45.736365+00:00 0:00:01.692190 24430 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T16:10:41.041814+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-04T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T16:10:41.397492+00:00 2021-05-04T16:10:43.664747+00:00 0:00:02.267255 24429 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T16:10:39.045818+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-04T15:00:00+00:00 PythonOperator 2021-05-04T16:10:23.942349+00:00 2021-05-04T16:10:27.283201+00:00 0:00:03.340852 24428 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T16:10:21.023677+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-04T15:00:00+00:00 PythonOperator 2021-05-04T16:10:19.357662+00:00 2021-05-04T16:10:23.452475+00:00 0:00:04.094813 24427 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T16:10:17.033163+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T15:00:00+00:00 TriggerDagRunOperator 2021-05-04T16:10:05.629688+00:00 2021-05-04T16:10:06.129509+00:00 0:00:00.499821 24426 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T16:10:03.073697+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T15:00:00+00:00 TriggerDagRunOperator 2021-05-04T16:10:05.481563+00:00 2021-05-04T16:10:05.873642+00:00 0:00:00.392079 24425 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T16:10:03.073742+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-04T15:05:00+00:00 EmrJobFlowSensor 2021-05-04T16:05:56.658027+00:00 2021-05-04T16:14:59.271033+00:00 0:09:02.613006 24424 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T16:05:54.435844+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-04T15:05:00+00:00 EmrCreateJobFlowOperator 2021-05-04T16:05:34.691303+00:00 2021-05-04T16:05:36.379457+00:00 0:00:01.688154 24423 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T16:05:32.420233+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-04T15:05:00+00:00 PythonOperator 2021-05-04T16:05:12.781154+00:00 2021-05-04T16:05:15.772013+00:00 0:00:02.990859 24422 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T16:05:10.357273+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T15:00:00+00:00 EmrJobFlowSensor 2021-05-04T16:00:48.044714+00:00 2021-05-04T16:09:50.779689+00:00 0:09:02.734975 24421 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T16:00:45.790736+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T16:00:28.039480+00:00 2021-05-04T16:00:29.916614+00:00 0:00:01.877134 24420 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T16:00:25.700503+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T15:00:00+00:00 PythonOperator 2021-05-04T16:00:05.984854+00:00 2021-05-04T16:00:09.179958+00:00 0:00:03.195104 24419 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T16:00:03.662449+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-04T14:00:00+00:00 EmrJobFlowSensor 2021-05-04T15:11:11.147361+00:00 2021-05-04T15:20:13.869723+00:00 0:09:02.722362 24417 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T15:11:08.888508+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-04T14:00:00+00:00 EmrJobFlowSensor 2021-05-04T15:11:05.505546+00:00 2021-05-04T15:20:08.132880+00:00 0:09:02.627334 24416 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T15:11:02.957986+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-04T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T15:10:49.236314+00:00 2021-05-04T15:10:51.080162+00:00 0:00:01.843848 24415 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T15:10:46.843946+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-04T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T15:10:39.150156+00:00 2021-05-04T15:10:40.820179+00:00 0:00:01.670023 24414 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T15:10:36.822069+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-04T14:00:00+00:00 PythonOperator 2021-05-04T15:10:23.122935+00:00 2021-05-04T15:10:26.456328+00:00 0:00:03.333393 24413 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T15:10:20.797138+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-04T14:00:00+00:00 PythonOperator 2021-05-04T15:10:14.999841+00:00 2021-05-04T15:10:18.060796+00:00 0:00:03.060955 24412 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T15:10:12.796520+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T14:00:00+00:00 TriggerDagRunOperator 2021-05-04T15:10:01.515593+00:00 2021-05-04T15:10:02.017194+00:00 0:00:00.501601 24411 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T15:09:58.264265+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T14:00:00+00:00 TriggerDagRunOperator 2021-05-04T15:10:01.330353+00:00 2021-05-04T15:10:01.742793+00:00 0:00:00.412440 24410 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T15:09:58.264210+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-04T14:05:00+00:00 EmrJobFlowSensor 2021-05-04T15:06:06.386737+00:00 2021-05-04T15:15:09.095504+00:00 0:09:02.708767 24409 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T15:06:03.863989+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-04T14:05:00+00:00 EmrCreateJobFlowOperator 2021-05-04T15:05:44.335932+00:00 2021-05-04T15:05:45.972477+00:00 0:00:01.636545 24408 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T15:05:41.856042+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-04T14:05:00+00:00 PythonOperator 2021-05-04T15:05:21.910000+00:00 2021-05-04T15:05:24.964830+00:00 0:00:03.054830 24407 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T15:05:19.703358+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T14:00:00+00:00 EmrJobFlowSensor 2021-05-04T15:00:47.828185+00:00 2021-05-04T15:09:50.491608+00:00 0:09:02.663423 24406 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T15:00:45.162887+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T15:00:25.331545+00:00 2021-05-04T15:00:27.190156+00:00 0:00:01.858611 24405 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T15:00:23.009702+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T14:00:00+00:00 PythonOperator 2021-05-04T15:00:05.439049+00:00 2021-05-04T15:00:08.662416+00:00 0:00:03.223367 24404 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T15:00:02.989388+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-04T13:00:00+00:00 EmrJobFlowSensor 2021-05-04T14:11:19.026719+00:00 2021-05-04T14:21:21.876570+00:00 0:10:02.849851 24402 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T14:11:16.662494+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-04T13:00:00+00:00 EmrJobFlowSensor 2021-05-04T14:11:08.845567+00:00 2021-05-04T14:21:11.719092+00:00 0:10:02.873525 24401 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T14:11:06.619080+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-04T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T14:10:58.807779+00:00 2021-05-04T14:11:00.480067+00:00 0:00:01.672288 24400 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T14:10:56.614065+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-04T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T14:10:46.864295+00:00 2021-05-04T14:10:48.673561+00:00 0:00:01.809266 24399 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T14:10:44.569678+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-04T13:00:00+00:00 PythonOperator 2021-05-04T14:10:36.780939+00:00 2021-05-04T14:10:39.823790+00:00 0:00:03.042851 24398 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T14:10:34.559453+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-04T13:00:00+00:00 PythonOperator 2021-05-04T14:10:26.976645+00:00 2021-05-04T14:10:30.234740+00:00 0:00:03.258095 24397 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T14:10:24.515156+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T13:00:00+00:00 TriggerDagRunOperator 2021-05-04T14:10:20.846297+00:00 2021-05-04T14:10:21.371908+00:00 0:00:00.525611 24396 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T14:10:18.511865+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T13:00:00+00:00 TriggerDagRunOperator 2021-05-04T14:10:20.791878+00:00 2021-05-04T14:10:21.222323+00:00 0:00:00.430445 24395 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T14:10:18.511917+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-04T13:05:00+00:00 EmrJobFlowSensor 2021-05-04T14:05:56.285447+00:00 2021-05-04T14:14:59.186163+00:00 0:09:02.900716 24394 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T14:05:54.046217+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-04T13:05:00+00:00 EmrCreateJobFlowOperator 2021-05-04T14:05:34.385023+00:00 2021-05-04T14:05:36.040566+00:00 0:00:01.655543 24393 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T14:05:32.024418+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-04T13:05:00+00:00 PythonOperator 2021-05-04T14:05:12.175293+00:00 2021-05-04T14:05:15.235443+00:00 0:00:03.060150 24392 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T14:05:10.016223+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T13:00:00+00:00 EmrJobFlowSensor 2021-05-04T14:01:06.017161+00:00 2021-05-04T14:10:08.775294+00:00 0:09:02.758133 24391 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T14:01:03.555670+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T14:00:43.925019+00:00 2021-05-04T14:00:45.733679+00:00 0:00:01.808660 24390 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T14:00:41.549800+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T13:00:00+00:00 PythonOperator 2021-05-04T14:00:11.814245+00:00 2021-05-04T14:00:14.847431+00:00 0:00:03.033186 24389 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T14:00:09.448828+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-04T12:00:00+00:00 EmrJobFlowSensor 2021-05-04T13:10:16.366798+00:00 2021-05-04T13:19:19.213281+00:00 0:09:02.846483 24387 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T13:10:14.060033+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-04T12:00:00+00:00 EmrJobFlowSensor 2021-05-04T13:10:10.377010+00:00 2021-05-04T13:20:13.150373+00:00 0:10:02.773363 24386 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T13:10:08.071498+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-04T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T13:09:54.344508+00:00 2021-05-04T13:09:56.056405+00:00 0:00:01.711897 24385 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T13:09:51.999497+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-04T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T13:09:48.289547+00:00 2021-05-04T13:09:50.144569+00:00 0:00:01.855022 24384 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T13:09:45.994363+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-04T12:00:00+00:00 PythonOperator 2021-05-04T13:09:32.763010+00:00 2021-05-04T13:09:36.052223+00:00 0:00:03.289213 24383 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T13:09:30.054458+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-04T12:00:00+00:00 PythonOperator 2021-05-04T13:09:26.534498+00:00 2021-05-04T13:09:29.695219+00:00 0:00:03.160721 24382 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T13:09:23.986654+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T12:00:00+00:00 TriggerDagRunOperator 2021-05-04T13:09:22.699289+00:00 2021-05-04T13:09:23.238105+00:00 0:00:00.538816 24381 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T13:09:19.962601+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T12:00:00+00:00 TriggerDagRunOperator 2021-05-04T13:09:22.565997+00:00 2021-05-04T13:09:22.999645+00:00 0:00:00.433648 24380 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T13:09:19.962557+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-04T12:05:00+00:00 EmrJobFlowSensor 2021-05-04T13:06:05.767295+00:00 2021-05-04T13:15:08.310780+00:00 0:09:02.543485 24379 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T13:06:03.459695+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-04T12:05:00+00:00 EmrCreateJobFlowOperator 2021-05-04T13:05:43.469856+00:00 2021-05-04T13:05:45.225697+00:00 0:00:01.755841 24378 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T13:05:41.234334+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-04T12:05:00+00:00 PythonOperator 2021-05-04T13:05:21.394985+00:00 2021-05-04T13:05:24.465136+00:00 0:00:03.070151 24377 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T13:05:19.202975+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T12:00:00+00:00 EmrJobFlowSensor 2021-05-04T13:01:13.150821+00:00 2021-05-04T13:09:15.747780+00:00 0:08:02.596959 24376 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T13:01:10.570125+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T13:00:50.702183+00:00 2021-05-04T13:00:52.395820+00:00 0:00:01.693637 24375 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T13:00:48.512193+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T12:00:00+00:00 PythonOperator 2021-05-04T13:00:22.842333+00:00 2021-05-04T13:00:25.915190+00:00 0:00:03.072857 24374 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T13:00:20.419295+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-04T11:00:00+00:00 EmrJobFlowSensor 2021-05-04T12:10:10.183960+00:00 2021-05-04T12:20:13.042931+00:00 0:10:02.858971 24372 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T12:10:07.960649+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-04T11:00:00+00:00 EmrJobFlowSensor 2021-05-04T12:09:56.245028+00:00 2021-05-04T12:18:59.068094+00:00 0:09:02.823066 24371 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T12:09:53.891929+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-04T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T12:09:48.128382+00:00 2021-05-04T12:09:49.865183+00:00 0:00:01.736801 24370 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T12:09:45.835778+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-04T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T12:09:36.095654+00:00 2021-05-04T12:09:37.874166+00:00 0:00:01.778512 24369 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T12:09:33.824671+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-04T11:00:00+00:00 PythonOperator 2021-05-04T12:09:28.010946+00:00 2021-05-04T12:09:31.338519+00:00 0:00:03.327573 24368 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T12:09:25.811632+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-04T11:00:00+00:00 PythonOperator 2021-05-04T12:09:12.291743+00:00 2021-05-04T12:09:15.357937+00:00 0:00:03.066194 24367 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T12:09:09.864206+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T11:00:00+00:00 TriggerDagRunOperator 2021-05-04T12:09:08.631075+00:00 2021-05-04T12:09:09.168954+00:00 0:00:00.537879 24366 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T12:09:05.846515+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T11:00:00+00:00 TriggerDagRunOperator 2021-05-04T12:09:08.217763+00:00 2021-05-04T12:09:08.658755+00:00 0:00:00.440992 24365 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T12:09:05.846469+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-04T11:05:00+00:00 EmrJobFlowSensor 2021-05-04T12:05:49.725783+00:00 2021-05-04T12:13:52.188885+00:00 0:08:02.463102 24364 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T12:05:47.508230+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-04T11:05:00+00:00 EmrCreateJobFlowOperator 2021-05-04T12:05:27.697401+00:00 2021-05-04T12:05:29.445640+00:00 0:00:01.748239 24363 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T12:05:25.429874+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-04T11:05:00+00:00 PythonOperator 2021-05-04T12:05:05.803140+00:00 2021-05-04T12:05:09.048407+00:00 0:00:03.245267 24362 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T12:05:03.449316+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T11:00:00+00:00 EmrJobFlowSensor 2021-05-04T12:00:53.353450+00:00 2021-05-04T12:08:55.905906+00:00 0:08:02.552456 24361 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T12:00:51.006868+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T12:00:31.497963+00:00 2021-05-04T12:00:33.335606+00:00 0:00:01.837643 24360 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T12:00:29.066109+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T11:00:00+00:00 PythonOperator 2021-05-04T12:00:09.906240+00:00 2021-05-04T12:00:13.023080+00:00 0:00:03.116840 24359 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T12:00:06.975466+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-04T10:00:00+00:00 EmrJobFlowSensor 2021-05-04T11:11:18.135931+00:00 2021-05-04T11:20:20.835574+00:00 0:09:02.699643 24357 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T11:11:15.646937+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-04T10:00:00+00:00 EmrJobFlowSensor 2021-05-04T11:11:00.054858+00:00 2021-05-04T11:21:02.948867+00:00 0:10:02.894009 24356 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T11:10:57.556011+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-04T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T11:10:55.700887+00:00 2021-05-04T11:10:57.460243+00:00 0:00:01.759356 24355 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T11:10:53.526592+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-04T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T11:10:40.323895+00:00 2021-05-04T11:10:42.103505+00:00 0:00:01.779610 24354 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T11:10:37.529419+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-04T10:00:00+00:00 PythonOperator 2021-05-04T11:10:35.788015+00:00 2021-05-04T11:10:39.131558+00:00 0:00:03.343543 24353 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T11:10:33.512746+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-04T10:00:00+00:00 PythonOperator 2021-05-04T11:10:16.425510+00:00 2021-05-04T11:10:19.676238+00:00 0:00:03.250728 24352 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T11:10:13.575735+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T10:00:00+00:00 TriggerDagRunOperator 2021-05-04T11:10:08.133116+00:00 2021-05-04T11:10:08.557077+00:00 0:00:00.423961 24351 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T11:10:05.556049+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T10:00:00+00:00 TriggerDagRunOperator 2021-05-04T11:10:08.008472+00:00 2021-05-04T11:10:08.584744+00:00 0:00:00.576272 24350 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T11:10:05.556094+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-04T10:05:00+00:00 EmrJobFlowSensor 2021-05-04T11:06:27.320994+00:00 2021-05-04T11:15:29.985098+00:00 0:09:02.664104 24349 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T11:06:25.132933+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-04T10:05:00+00:00 EmrCreateJobFlowOperator 2021-05-04T11:06:05.280767+00:00 2021-05-04T11:06:06.999468+00:00 0:00:01.718701 24348 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T11:06:03.108840+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-04T10:05:00+00:00 PythonOperator 2021-05-04T11:05:43.418697+00:00 2021-05-04T11:05:46.465560+00:00 0:00:03.046863 24347 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T11:05:41.092646+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T10:00:00+00:00 EmrJobFlowSensor 2021-05-04T11:00:46.691819+00:00 2021-05-04T11:09:49.514783+00:00 0:09:02.822964 24346 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T11:00:44.438624+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T11:00:24.788608+00:00 2021-05-04T11:00:26.531720+00:00 0:00:01.743112 24345 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T11:00:22.460174+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T10:00:00+00:00 PythonOperator 2021-05-04T11:00:05.050808+00:00 2021-05-04T11:00:08.175938+00:00 0:00:03.125130 24344 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T11:00:01.992920+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-04T09:00:00+00:00 EmrJobFlowSensor 2021-05-04T10:11:19.808483+00:00 2021-05-04T10:20:22.452093+00:00 0:09:02.643610 24342 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T10:11:17.647714+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-04T09:00:00+00:00 EmrJobFlowSensor 2021-05-04T10:11:15.911696+00:00 2021-05-04T10:20:18.684657+00:00 0:09:02.772961 24341 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T10:11:13.640050+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-04T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T10:10:57.859589+00:00 2021-05-04T10:10:59.519446+00:00 0:00:01.659857 24340 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T10:10:55.626494+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-04T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T10:10:53.809746+00:00 2021-05-04T10:10:55.516301+00:00 0:00:01.706555 24339 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T10:10:51.619872+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-04T09:00:00+00:00 PythonOperator 2021-05-04T10:10:36.109893+00:00 2021-05-04T10:10:39.131867+00:00 0:00:03.021974 24338 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T10:10:33.665580+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-04T09:00:00+00:00 PythonOperator 2021-05-04T10:10:32.195830+00:00 2021-05-04T10:10:35.551048+00:00 0:00:03.355218 24337 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T10:10:29.742809+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T09:00:00+00:00 TriggerDagRunOperator 2021-05-04T10:10:10.198515+00:00 2021-05-04T10:10:10.645633+00:00 0:00:00.447118 24336 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T10:10:07.589146+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T09:00:00+00:00 TriggerDagRunOperator 2021-05-04T10:10:10.211502+00:00 2021-05-04T10:10:10.766440+00:00 0:00:00.554938 24335 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T10:10:07.589189+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-04T09:05:00+00:00 EmrJobFlowSensor 2021-05-04T10:05:51.181885+00:00 2021-05-04T10:14:53.795917+00:00 0:09:02.614032 24334 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T10:05:49.035592+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-04T09:05:00+00:00 EmrCreateJobFlowOperator 2021-05-04T10:05:29.587218+00:00 2021-05-04T10:05:31.223801+00:00 0:00:01.636583 24333 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T10:05:27.068678+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-04T09:05:00+00:00 PythonOperator 2021-05-04T10:05:07.245877+00:00 2021-05-04T10:05:10.258257+00:00 0:00:03.012380 24332 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T10:05:04.994389+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T09:00:00+00:00 EmrJobFlowSensor 2021-05-04T10:00:56.814727+00:00 2021-05-04T10:09:59.518972+00:00 0:09:02.704245 24331 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T10:00:54.446672+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T10:00:34.670866+00:00 2021-05-04T10:00:36.402337+00:00 0:00:01.731471 24330 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T10:00:32.346350+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T09:00:00+00:00 PythonOperator 2021-05-04T10:00:12.782824+00:00 2021-05-04T10:00:15.864897+00:00 0:00:03.082073 24329 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T10:00:10.316992+00:00 2 default_pool