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-history-job_v002 create_cluster_and_add_emr_steps 2021-05-04T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T18:11:37.071919+00:00 2021-05-04T18:11:38.862269+00:00 0:00:01.790350 24459 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T18:11:34.646967+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-04T17:00:00+00:00 PythonOperator 2021-05-04T18:11:20.632101+00:00 2021-05-04T18:11:23.932787+00:00 0:00:03.300686 24458 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T18:11:18.406366+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-04T17:00:00+00:00 PythonOperator 2021-05-04T18:11:15.053542+00:00 2021-05-04T18:11:18.135660+00:00 0:00:03.082118 24457 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T18:11:12.546213+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T17:00:00+00:00 TriggerDagRunOperator 2021-05-04T18:10:57.352321+00:00 2021-05-04T18:10:57.866621+00:00 0:00:00.514300 24456 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T18:10:54.458872+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T17:00:00+00:00 TriggerDagRunOperator 2021-05-04T18:10:56.921537+00:00 2021-05-04T18:10:57.375664+00:00 0:00:00.454127 24455 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T18:10:54.458919+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-04T17:05:00+00:00 EmrJobFlowSensor 2021-05-04T18:05:54.277198+00:00 2021-05-04T18:14:56.827144+00:00 0:09:02.549946 24454 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T18:05:51.844685+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-04T17:05:00+00:00 EmrCreateJobFlowOperator 2021-05-04T18:05:33.912760+00:00 2021-05-04T18:05:35.647097+00:00 0:00:01.734337 24453 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T18:05:31.734482+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-04T17:05:00+00:00 PythonOperator 2021-05-04T18:05:11.858438+00:00 2021-05-04T18:05:14.870251+00:00 0:00:03.011813 24452 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T18:05:09.714158+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T17:00:00+00:00 EmrJobFlowSensor 2021-05-04T18:00:47.504869+00:00 2021-05-04T18:10:50.364431+00:00 0:10:02.859562 24451 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T18:00:45.162113+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T18:00:25.513551+00:00 2021-05-04T18:00:27.309917+00:00 0:00:01.796366 24450 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T18:00:23.085210+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T17:00:00+00:00 PythonOperator 2021-05-04T18:00:05.443274+00:00 2021-05-04T18:00:08.607420+00:00 0:00:03.164146 24449 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T18:00:03.019169+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-04T16:00:00+00:00 EmrJobFlowSensor 2021-05-04T17:12:40.315146+00:00 2021-05-04T17:21:42.845603+00:00 0:09:02.530457 24447 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T17:12:37.940563+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-04T16:00:00+00:00 EmrJobFlowSensor 2021-05-04T17:12:28.348019+00:00 2021-05-04T17:21:31.008940+00:00 0:09:02.660921 24446 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T17:12:25.955183+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-04T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T17:12:16.019329+00:00 2021-05-04T17:12:17.749549+00:00 0:00:01.730220 24445 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T17:12:13.792333+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-04T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T17:12:08.405052+00:00 2021-05-04T17:12:10.204282+00:00 0:00:01.799230 24444 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T17:12:05.870452+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-04T16:00:00+00:00 PythonOperator 2021-05-04T17:11:53.997173+00:00 2021-05-04T17:11:57.319320+00:00 0:00:03.322147 24443 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T17:11:51.719253+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-04T16:00:00+00:00 PythonOperator 2021-05-04T17:11:35.905194+00:00 2021-05-04T17:11:39.018118+00:00 0:00:03.112924 24442 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T17:11:33.704476+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T16:00:00+00:00 TriggerDagRunOperator 2021-05-04T17:11:21.976206+00:00 2021-05-04T17:11:22.506801+00:00 0:00:00.530595 24441 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T17:11:19.695099+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T16:00:00+00:00 TriggerDagRunOperator 2021-05-04T17:11:21.887024+00:00 2021-05-04T17:11:22.325218+00:00 0:00:00.438194 24440 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T17:11:19.695133+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-04T16:05:00+00:00 EmrJobFlowSensor 2021-05-04T17:05:57.111642+00:00 2021-05-04T17:14:59.689645+00:00 0:09:02.578003 24439 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T17:05:54.961099+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-04T16:05:00+00:00 EmrCreateJobFlowOperator 2021-05-04T17:05:35.175355+00:00 2021-05-04T17:05:36.931134+00:00 0:00:01.755779 24438 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T17:05:32.893686+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-04T16:05:00+00:00 PythonOperator 2021-05-04T17:05:13.032365+00:00 2021-05-04T17:05:16.035088+00:00 0:00:03.002723 24437 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T17:05:10.833436+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T16:00:00+00:00 EmrJobFlowSensor 2021-05-04T17:01:00.590060+00:00 2021-05-04T17:11:03.448069+00:00 0:10:02.858009 24436 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T17:00:58.050689+00:00 2 default_pool
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