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_emr_steps 2021-04-12T09:00:00+00:00 PythonOperator 2021-04-12T10:14:41.025145+00:00 2021-04-12T10:14:44.020278+00:00 0:00:02.995133 16329 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T10:14:38.477765+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T09:00:00+00:00 TriggerDagRunOperator 2021-04-12T10:14:33.382712+00:00 2021-04-12T10:14:33.938494+00:00 0:00:00.555782 16328 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T10:14:30.559399+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T09:00:00+00:00 TriggerDagRunOperator 2021-04-12T10:14:33.187980+00:00 2021-04-12T10:14:33.623253+00:00 0:00:00.435273 16327 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T10:14:30.559454+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-12T09:05:00+00:00 EmrJobFlowSensor 2021-04-12T10:05:48.782498+00:00 2021-04-12T10:14:51.435762+00:00 0:09:02.653264 16325 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T10:05:46.647220+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-12T09:05:00+00:00 EmrCreateJobFlowOperator 2021-04-12T10:05:28.799954+00:00 2021-04-12T10:05:30.443855+00:00 0:00:01.643901 16324 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T10:05:26.622923+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-12T09:05:00+00:00 PythonOperator 2021-04-12T10:05:06.939019+00:00 2021-04-12T10:05:09.664599+00:00 0:00:02.725580 16323 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T10:05:04.666588+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T09:00:00+00:00 EmrJobFlowSensor 2021-04-12T10:00:56.277011+00:00 2021-04-12T10:10:58.964873+00:00 0:10:02.687862 16322 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T10:00:54.172881+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T10:00:34.590222+00:00 2021-04-12T10:00:36.397072+00:00 0:00:01.806850 16321 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T10:00:32.150377+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T09:00:00+00:00 PythonOperator 2021-04-12T10:00:12.499521+00:00 2021-04-12T10:00:15.240625+00:00 0:00:02.741104 16320 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T10:00:10.162560+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-12T08:00:00+00:00 EmrJobFlowSensor 2021-04-12T09:11:41.670735+00:00 2021-04-12T09:20:44.236263+00:00 0:09:02.565528 16319 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T09:11:39.462321+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-12T08:00:00+00:00 EmrJobFlowSensor 2021-04-12T09:11:34.372839+00:00 2021-04-12T09:20:37.021122+00:00 0:09:02.648283 16318 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T09:11:31.469743+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-12T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T09:11:21.738604+00:00 2021-04-12T09:11:23.662046+00:00 0:00:01.923442 16317 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T09:11:19.387159+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-12T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T09:11:13.657898+00:00 2021-04-12T09:11:15.452447+00:00 0:00:01.794549 16316 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T09:11:11.363252+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-12T08:00:00+00:00 PythonOperator 2021-04-12T09:10:59.711098+00:00 2021-04-12T09:11:03.101015+00:00 0:00:03.389917 16315 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T09:10:57.334693+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-12T08:00:00+00:00 PythonOperator 2021-04-12T09:10:51.516349+00:00 2021-04-12T09:10:54.230519+00:00 0:00:02.714170 16314 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T09:10:49.326340+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T08:00:00+00:00 TriggerDagRunOperator 2021-04-12T09:10:37.969875+00:00 2021-04-12T09:10:38.605588+00:00 0:00:00.635713 16313 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T09:10:35.316402+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T08:00:00+00:00 TriggerDagRunOperator 2021-04-12T09:10:37.870961+00:00 2021-04-12T09:10:38.277134+00:00 0:00:00.406173 16312 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T09:10:35.316430+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-12T08:05:00+00:00 EmrJobFlowSensor 2021-04-12T09:06:02.606333+00:00 2021-04-12T09:14:05.289143+00:00 0:08:02.682810 16310 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T09:06:00.251057+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-12T08:05:00+00:00 EmrCreateJobFlowOperator 2021-04-12T09:05:40.486407+00:00 2021-04-12T09:05:42.790753+00:00 0:00:02.304346 16309 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T09:05:38.241322+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-12T08:05:00+00:00 PythonOperator 2021-04-12T09:05:20.364138+00:00 2021-04-12T09:05:23.070219+00:00 0:00:02.706081 16308 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T09:05:18.159984+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T08:00:00+00:00 EmrJobFlowSensor 2021-04-12T09:01:16.082889+00:00 2021-04-12T09:10:18.729926+00:00 0:09:02.647037 16307 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T09:01:13.820183+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T09:00:56.144038+00:00 2021-04-12T09:00:57.826519+00:00 0:00:01.682481 16306 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T09:00:53.803272+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T08:00:00+00:00 PythonOperator 2021-04-12T09:00:34.270020+00:00 2021-04-12T09:00:37.207050+00:00 0:00:02.937030 16305 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T09:00:31.852885+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-12T07:00:00+00:00 EmrJobFlowSensor 2021-04-12T08:12:09.560877+00:00 2021-04-12T08:30:13.334929+00:00 0:18:03.774052 16304 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T08:12:06.605818+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-12T07:00:00+00:00 EmrJobFlowSensor 2021-04-12T08:12:06.849609+00:00 2021-04-12T08:22:10.054526+00:00 0:10:03.204917 16303 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T08:12:04.666869+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-12T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T08:11:47.393561+00:00 2021-04-12T08:11:49.128884+00:00 0:00:01.735323 16302 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T08:11:44.654738+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-12T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T08:11:45.164601+00:00 2021-04-12T08:11:47.218088+00:00 0:00:02.053487 16301 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T08:11:42.655184+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-12T07:00:00+00:00 PythonOperator 2021-04-12T08:11:27.286984+00:00 2021-04-12T08:11:29.982992+00:00 0:00:02.696008 16300 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T08:11:24.587367+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-12T07:00:00+00:00 PythonOperator 2021-04-12T08:11:23.399727+00:00 2021-04-12T08:11:26.938176+00:00 0:00:03.538449 16299 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T08:11:20.570227+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T07:00:00+00:00 TriggerDagRunOperator 2021-04-12T08:11:09.302844+00:00 2021-04-12T08:11:09.807151+00:00 0:00:00.504307 16298 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T08:11:06.495436+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T07:00:00+00:00 TriggerDagRunOperator 2021-04-12T08:11:09.055266+00:00 2021-04-12T08:11:09.467584+00:00 0:00:00.412318 16297 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T08:11:06.495463+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-12T07:05:00+00:00 EmrJobFlowSensor 2021-04-12T08:05:56.607462+00:00 2021-04-12T08:14:59.381659+00:00 0:09:02.774197 16295 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T08:05:54.359570+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-12T07:05:00+00:00 EmrCreateJobFlowOperator 2021-04-12T08:05:34.730276+00:00 2021-04-12T08:05:36.471992+00:00 0:00:01.741716 16294 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T08:05:32.336191+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-12T07:05:00+00:00 PythonOperator 2021-04-12T08:05:12.610973+00:00 2021-04-12T08:05:15.354704+00:00 0:00:02.743731 16293 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T08:05:10.371889+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T07:00:00+00:00 EmrJobFlowSensor 2021-04-12T08:00:46.203963+00:00 2021-04-12T08:10:48.995373+00:00 0:10:02.791410 16292 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T08:00:43.877027+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T08:00:26.119037+00:00 2021-04-12T08:00:27.804472+00:00 0:00:01.685435 16291 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T08:00:23.863687+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T07:00:00+00:00 PythonOperator 2021-04-12T08:00:04.087806+00:00 2021-04-12T08:00:06.936356+00:00 0:00:02.848550 16290 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T08:00:01.735308+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-12T06:00:00+00:00 EmrJobFlowSensor 2021-04-12T07:12:27.530557+00:00 2021-04-12T07:22:30.246457+00:00 0:10:02.715900 16289 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T07:12:25.240921+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-12T06:00:00+00:00 EmrJobFlowSensor 2021-04-12T07:12:23.730608+00:00 2021-04-12T07:21:26.358450+00:00 0:09:02.627842 16288 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T07:12:21.180322+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-12T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T07:12:05.595357+00:00 2021-04-12T07:12:07.320932+00:00 0:00:01.725575 16287 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T07:12:03.156619+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-12T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T07:12:01.479303+00:00 2021-04-12T07:12:03.306421+00:00 0:00:01.827118 16286 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T07:11:59.166290+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-12T06:00:00+00:00 PythonOperator 2021-04-12T07:11:43.356428+00:00 2021-04-12T07:11:46.508371+00:00 0:00:03.151943 16285 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T07:11:41.085818+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-12T06:00:00+00:00 PythonOperator 2021-04-12T07:11:41.307879+00:00 2021-04-12T07:11:44.094287+00:00 0:00:02.786408 16284 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T07:11:39.084117+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T06:00:00+00:00 TriggerDagRunOperator 2021-04-12T07:11:28.018687+00:00 2021-04-12T07:11:28.558904+00:00 0:00:00.540217 16283 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T07:11:25.027613+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T06:00:00+00:00 TriggerDagRunOperator 2021-04-12T07:11:27.739034+00:00 2021-04-12T07:11:28.207296+00:00 0:00:00.468262 16282 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T07:11:25.027585+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-12T06:05:00+00:00 EmrJobFlowSensor 2021-04-12T07:06:04.025842+00:00 2021-04-12T07:15:06.681338+00:00 0:09:02.655496 16280 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T07:06:01.812278+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-12T06:05:00+00:00 EmrCreateJobFlowOperator 2021-04-12T07:05:41.918899+00:00 2021-04-12T07:05:43.559131+00:00 0:00:01.640232 16279 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T07:05:39.793718+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-12T06:05:00+00:00 PythonOperator 2021-04-12T07:05:15.955844+00:00 2021-04-12T07:05:18.604709+00:00 0:00:02.648865 16278 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T07:05:13.752013+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T06:00:00+00:00 EmrJobFlowSensor 2021-04-12T07:01:07.272402+00:00 2021-04-12T07:11:09.996582+00:00 0:10:02.724180 16277 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T07:01:05.017257+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T07:00:45.521731+00:00 2021-04-12T07:00:47.237995+00:00 0:00:01.716264 16276 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T07:00:42.995760+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T06:00:00+00:00 PythonOperator 2021-04-12T07:00:23.279793+00:00 2021-04-12T07:00:26.175024+00:00 0:00:02.895231 16275 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T07:00:20.922280+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-12T05:00:00+00:00 EmrJobFlowSensor 2021-04-12T06:10:08.404735+00:00 2021-04-12T06:18:10.840406+00:00 0:08:02.435671 16274 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T06:10:06.155411+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-12T05:00:00+00:00 EmrJobFlowSensor 2021-04-12T06:09:58.582182+00:00 2021-04-12T06:20:01.407414+00:00 0:10:02.825232 16273 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T06:09:56.080744+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-12T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T06:09:48.422150+00:00 2021-04-12T06:09:50.180057+00:00 0:00:01.757907 16272 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T06:09:46.071045+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-12T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T06:09:38.491934+00:00 2021-04-12T06:09:40.296714+00:00 0:00:01.804780 16271 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T06:09:36.046834+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-12T05:00:00+00:00 PythonOperator 2021-04-12T06:09:26.392695+00:00 2021-04-12T06:09:29.103211+00:00 0:00:02.710516 16270 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T06:09:24.061981+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-12T05:00:00+00:00 PythonOperator 2021-04-12T06:09:16.434895+00:00 2021-04-12T06:09:19.444938+00:00 0:00:03.010043 16269 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T06:09:14.056020+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T05:00:00+00:00 TriggerDagRunOperator 2021-04-12T06:09:10.374984+00:00 2021-04-12T06:09:10.949575+00:00 0:00:00.574591 16268 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T06:09:07.950204+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T05:00:00+00:00 TriggerDagRunOperator 2021-04-12T06:09:10.169923+00:00 2021-04-12T06:09:10.595335+00:00 0:00:00.425412 16267 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T06:09:07.950238+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-12T05:05:00+00:00 EmrJobFlowSensor 2021-04-12T06:08:08.112960+00:00 2021-04-12T06:17:10.603327+00:00 0:09:02.490367 16266 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T06:08:05.890851+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-12T05:05:00+00:00 EmrCreateJobFlowOperator 2021-04-12T06:07:42.035030+00:00 2021-04-12T06:07:43.763434+00:00 0:00:01.728404 16265 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T06:07:39.866985+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-12T05:05:00+00:00 PythonOperator 2021-04-12T06:07:22.245951+00:00 2021-04-12T06:07:25.127667+00:00 0:00:02.881716 16264 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T06:07:19.846843+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T05:00:00+00:00 EmrJobFlowSensor 2021-04-12T06:00:58.416856+00:00 2021-04-12T06:09:00.887035+00:00 0:08:02.470179 16262 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T06:00:56.059289+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T06:00:38.781749+00:00 2021-04-12T06:00:40.630007+00:00 0:00:01.848258 16261 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T06:00:36.044439+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T05:00:00+00:00 PythonOperator 2021-04-12T06:00:16.400456+00:00 2021-04-12T06:00:19.106973+00:00 0:00:02.706517 16260 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T06:00:14.081162+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-12T04:00:00+00:00 EmrJobFlowSensor 2021-04-12T05:12:01.745198+00:00 2021-04-12T05:21:04.369911+00:00 0:09:02.624713 16259 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T05:11:59.510013+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-12T04:00:00+00:00 EmrJobFlowSensor 2021-04-12T05:11:57.633302+00:00 2021-04-12T05:21:00.246742+00:00 0:09:02.613440 16258 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T05:11:55.510465+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-12T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T05:11:40.038081+00:00 2021-04-12T05:11:41.838582+00:00 0:00:01.800501 16257 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T05:11:37.498226+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-12T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T05:11:35.893418+00:00 2021-04-12T05:11:37.761061+00:00 0:00:01.867643 16256 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T05:11:33.546310+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-12T04:00:00+00:00 PythonOperator 2021-04-12T05:11:18.769731+00:00 2021-04-12T05:11:22.282177+00:00 0:00:03.512446 16255 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T05:11:15.403829+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-12T04:00:00+00:00 PythonOperator 2021-04-12T05:11:16.303945+00:00 2021-04-12T05:11:19.322943+00:00 0:00:03.018998 16254 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T05:11:13.473198+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T04:00:00+00:00 TriggerDagRunOperator 2021-04-12T05:11:07.699189+00:00 2021-04-12T05:11:08.268647+00:00 0:00:00.569458 16253 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T05:11:05.391475+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T04:00:00+00:00 TriggerDagRunOperator 2021-04-12T05:11:07.631499+00:00 2021-04-12T05:11:08.102382+00:00 0:00:00.470883 16252 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T05:11:05.391444+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-12T04:05:00+00:00 EmrJobFlowSensor 2021-04-12T05:05:53.338203+00:00 2021-04-12T05:13:55.750287+00:00 0:08:02.412084 16251 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T05:05:50.926848+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-12T04:05:00+00:00 EmrCreateJobFlowOperator 2021-04-12T05:05:31.285385+00:00 2021-04-12T05:05:33.016287+00:00 0:00:01.730902 16250 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T05:05:28.974205+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-12T04:05:00+00:00 PythonOperator 2021-04-12T05:05:09.623006+00:00 2021-04-12T05:05:12.329451+00:00 0:00:02.706445 16249 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T05:05:06.968029+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T04:00:00+00:00 EmrJobFlowSensor 2021-04-12T05:00:50.824929+00:00 2021-04-12T05:10:53.706300+00:00 0:10:02.881371 16247 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T05:00:48.625904+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T05:00:31.286383+00:00 2021-04-12T05:00:33.102904+00:00 0:00:01.816521 16246 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T05:00:28.753672+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T04:00:00+00:00 PythonOperator 2021-04-12T05:00:08.751782+00:00 2021-04-12T05:00:11.500707+00:00 0:00:02.748925 16245 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T05:00:06.535969+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-12T03:00:00+00:00 EmrJobFlowSensor 2021-04-12T04:12:33.980581+00:00 2021-04-12T04:21:36.602029+00:00 0:09:02.621448 16244 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T04:12:31.650094+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-12T03:00:00+00:00 EmrJobFlowSensor 2021-04-12T04:12:18.153829+00:00 2021-04-12T04:21:20.793743+00:00 0:09:02.639914 16243 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T04:12:15.662698+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-12T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T04:12:11.906620+00:00 2021-04-12T04:12:13.649646+00:00 0:00:01.743026 16242 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T04:12:09.643795+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-12T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T04:11:58.002541+00:00 2021-04-12T04:11:59.634803+00:00 0:00:01.632262 16241 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T04:11:55.557117+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-12T03:00:00+00:00 PythonOperator 2021-04-12T04:11:49.798730+00:00 2021-04-12T04:11:52.729811+00:00 0:00:02.931081 16240 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T04:11:47.550149+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-12T03:00:00+00:00 PythonOperator 2021-04-12T04:11:35.897653+00:00 2021-04-12T04:11:38.825974+00:00 0:00:02.928321 16239 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T04:11:33.534985+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T03:00:00+00:00 TriggerDagRunOperator 2021-04-12T04:11:26.273431+00:00 2021-04-12T04:11:26.861185+00:00 0:00:00.587754 16238 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T04:11:23.677021+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T03:00:00+00:00 TriggerDagRunOperator 2021-04-12T04:11:26.110339+00:00 2021-04-12T04:11:26.550617+00:00 0:00:00.440278 16237 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T04:11:23.677057+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-12T03:05:00+00:00 EmrJobFlowSensor 2021-04-12T04:06:05.271606+00:00 2021-04-12T04:15:07.767816+00:00 0:09:02.496210 16236 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T04:06:03.066097+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-12T03:05:00+00:00 EmrCreateJobFlowOperator 2021-04-12T04:05:45.270333+00:00 2021-04-12T04:05:47.009452+00:00 0:00:01.739119 16235 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T04:05:43.050179+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-12T03:05:00+00:00 PythonOperator 2021-04-12T04:05:23.818460+00:00 2021-04-12T04:05:26.965217+00:00 0:00:03.146757 16234 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T04:05:21.030825+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T03:00:00+00:00 EmrJobFlowSensor 2021-04-12T04:01:05.328866+00:00 2021-04-12T04:11:08.095948+00:00 0:10:02.767082 16232 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T04:01:03.040461+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T04:00:41.791404+00:00 2021-04-12T04:00:43.518074+00:00 0:00:01.726670 16231 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T04:00:39.005236+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T03:00:00+00:00 PythonOperator 2021-04-12T04:00:21.159254+00:00 2021-04-12T04:00:23.953687+00:00 0:00:02.794433 16230 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T04:00:18.990777+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-12T02:00:00+00:00 EmrJobFlowSensor 2021-04-12T03:11:26.397064+00:00 2021-04-12T03:21:29.152228+00:00 0:10:02.755164 16229 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T03:11:24.051402+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-12T02:00:00+00:00 EmrJobFlowSensor 2021-04-12T03:11:22.244830+00:00 2021-04-12T03:22:25.385204+00:00 0:11:03.140374 16228 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T03:11:19.952896+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-12T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T03:11:04.289022+00:00 2021-04-12T03:11:06.191278+00:00 0:00:01.902256 16227 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T03:11:01.916987+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-12T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T03:11:00.401981+00:00 2021-04-12T03:11:02.334636+00:00 0:00:01.932655 16226 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T03:10:58.051665+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-12T02:00:00+00:00 PythonOperator 2021-04-12T03:10:42.477136+00:00 2021-04-12T03:10:45.225365+00:00 0:00:02.748229 16225 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T03:10:39.865472+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-12T02:00:00+00:00 PythonOperator 2021-04-12T03:10:38.626834+00:00 2021-04-12T03:10:42.111174+00:00 0:00:03.484340 16224 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T03:10:35.946675+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T02:00:00+00:00 TriggerDagRunOperator 2021-04-12T03:10:18.521337+00:00 2021-04-12T03:10:19.043496+00:00 0:00:00.522159 16223 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T03:10:15.893970+00:00 2 default_pool