Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T10:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T11:05:42.000714+00:00 2021-04-01T11:05:43.643395+00:00 0:00:01.642681 12377 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T11:05:39.744059+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T10:05:00+00:00 PythonOperator 2021-04-01T11:05:21.820004+00:00 2021-04-01T11:05:24.498884+00:00 0:00:02.678880 12376 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T11:05:19.655118+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T10:00:00+00:00 EmrJobFlowSensor 2021-04-01T11:01:09.888907+00:00 2021-04-01T11:11:12.758761+00:00 0:10:02.869854 12375 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T11:01:07.279039+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T11:00:47.414007+00:00 2021-04-01T11:00:49.127735+00:00 0:00:01.713728 12374 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T11:00:45.189350+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T10:00:00+00:00 PythonOperator 2021-04-01T11:00:21.548792+00:00 2021-04-01T11:00:24.257195+00:00 0:00:02.708403 12373 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T11:00:19.126588+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T09:00:00+00:00 EmrJobFlowSensor 2021-04-01T10:11:28.920231+00:00 2021-04-01T10:21:31.701658+00:00 0:10:02.781427 12371 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T10:11:26.787337+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T09:00:00+00:00 EmrJobFlowSensor 2021-04-01T10:11:23.187923+00:00 2021-04-01T10:28:27.013439+00:00 0:17:03.825516 12370 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T10:11:20.855409+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T10:11:09.293658+00:00 2021-04-01T10:11:11.216683+00:00 0:00:01.923025 12369 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T10:11:06.770426+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T10:11:03.192120+00:00 2021-04-01T10:11:05.047773+00:00 0:00:01.855653 12368 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T10:11:00.759093+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T09:00:00+00:00 PythonOperator 2021-04-01T10:10:46.888433+00:00 2021-04-01T10:10:49.886665+00:00 0:00:02.998232 12367 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T10:10:44.690199+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T09:00:00+00:00 PythonOperator 2021-04-01T10:10:40.983317+00:00 2021-04-01T10:10:43.668587+00:00 0:00:02.685270 12366 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T10:10:38.752291+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T09:00:00+00:00 TriggerDagRunOperator 2021-04-01T10:10:23.011850+00:00 2021-04-01T10:10:23.689301+00:00 0:00:00.677451 12365 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T10:10:20.664280+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T09:00:00+00:00 TriggerDagRunOperator 2021-04-01T10:10:22.931966+00:00 2021-04-01T10:10:23.379518+00:00 0:00:00.447552 12364 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T10:10:20.664307+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T09:05:00+00:00 EmrJobFlowSensor 2021-04-01T10:05:46.604993+00:00 2021-04-01T10:16:49.649406+00:00 0:11:03.044413 12363 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T10:05:44.225202+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T09:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T10:05:24.399747+00:00 2021-04-01T10:05:26.064773+00:00 0:00:01.665026 12362 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T10:05:22.240855+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T09:05:00+00:00 PythonOperator 2021-04-01T10:05:04.644706+00:00 2021-04-01T10:05:07.530875+00:00 0:00:02.886169 12361 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T10:05:02.186644+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T09:00:00+00:00 EmrJobFlowSensor 2021-04-01T10:01:00.458125+00:00 2021-04-01T10:10:03.259011+00:00 0:09:02.800886 12360 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T10:00:57.963177+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T10:00:40.081698+00:00 2021-04-01T10:00:41.781964+00:00 0:00:01.700266 12359 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T10:00:37.846007+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T09:00:00+00:00 PythonOperator 2021-04-01T10:00:18.466506+00:00 2021-04-01T10:00:21.302408+00:00 0:00:02.835902 12358 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T10:00:15.882955+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T08:00:00+00:00 EmrJobFlowSensor 2021-04-01T09:19:04.609106+00:00 2021-04-01T09:29:07.431863+00:00 0:10:02.822757 12357 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T09:19:02.169047+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T08:00:00+00:00 EmrJobFlowSensor 2021-04-01T09:18:48.270356+00:00 2021-04-01T09:27:51.008467+00:00 0:09:02.738111 12356 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T09:18:46.022987+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T09:18:42.374822+00:00 2021-04-01T09:18:44.119288+00:00 0:00:01.744466 12355 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T09:18:40.075282+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T09:18:28.394708+00:00 2021-04-01T09:18:30.208779+00:00 0:00:01.814071 12354 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T09:18:26.007291+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T08:00:00+00:00 PythonOperator 2021-04-01T09:18:22.230527+00:00 2021-04-01T09:18:25.343353+00:00 0:00:03.112826 12353 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T09:18:20.003139+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T08:00:00+00:00 PythonOperator 2021-04-01T09:18:06.263009+00:00 2021-04-01T09:18:08.978303+00:00 0:00:02.715294 12352 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T09:18:03.987713+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T08:00:00+00:00 TriggerDagRunOperator 2021-04-01T09:18:00.670337+00:00 2021-04-01T09:18:01.096632+00:00 0:00:00.426295 12351 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T09:17:57.983193+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T08:00:00+00:00 TriggerDagRunOperator 2021-04-01T09:18:00.679113+00:00 2021-04-01T09:18:01.203499+00:00 0:00:00.524386 12350 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T09:17:57.983220+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T08:05:00+00:00 EmrJobFlowSensor 2021-04-01T09:05:46.263712+00:00 2021-04-01T09:14:48.944140+00:00 0:09:02.680428 12348 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T09:05:44.056240+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T08:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T09:05:24.457841+00:00 2021-04-01T09:05:26.099384+00:00 0:00:01.641543 12347 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T09:05:21.967059+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T08:05:00+00:00 PythonOperator 2021-04-01T09:05:04.453509+00:00 2021-04-01T09:05:07.249122+00:00 0:00:02.795613 12346 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T09:05:01.948047+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T08:00:00+00:00 EmrJobFlowSensor 2021-04-01T09:01:03.918941+00:00 2021-04-01T09:15:07.350870+00:00 0:14:03.431929 12345 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T09:01:01.591451+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T09:00:41.709460+00:00 2021-04-01T09:00:43.423402+00:00 0:00:01.713942 12344 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T09:00:39.549774+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T08:00:00+00:00 PythonOperator 2021-04-01T09:00:19.673721+00:00 2021-04-01T09:00:22.383540+00:00 0:00:02.709819 12343 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T09:00:17.477691+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T07:00:00+00:00 EmrJobFlowSensor 2021-04-01T08:18:21.202904+00:00 2021-04-01T08:27:23.733949+00:00 0:09:02.531045 12342 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T08:18:19.007414+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T07:00:00+00:00 EmrJobFlowSensor 2021-04-01T08:18:05.346721+00:00 2021-04-01T08:28:08.193912+00:00 0:10:02.847191 12341 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T08:18:02.985876+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T08:17:59.177267+00:00 2021-04-01T08:18:00.903995+00:00 0:00:01.726728 12340 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T08:17:56.915918+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T08:17:43.301890+00:00 2021-04-01T08:17:45.167285+00:00 0:00:01.865395 12339 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T08:17:40.904496+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T07:00:00+00:00 PythonOperator 2021-04-01T08:17:37.452178+00:00 2021-04-01T08:17:40.231940+00:00 0:00:02.779762 12338 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T08:17:34.960291+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T07:00:00+00:00 PythonOperator 2021-04-01T08:17:17.515425+00:00 2021-04-01T08:17:20.496481+00:00 0:00:02.981056 12337 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T08:17:14.944413+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T07:00:00+00:00 TriggerDagRunOperator 2021-04-01T08:17:05.620360+00:00 2021-04-01T08:17:06.067764+00:00 0:00:00.447404 12336 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T08:17:02.832208+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T07:00:00+00:00 TriggerDagRunOperator 2021-04-01T08:17:05.408787+00:00 2021-04-01T08:17:06.005191+00:00 0:00:00.596404 12335 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T08:17:02.832179+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T07:05:00+00:00 EmrJobFlowSensor 2021-04-01T08:05:54.132880+00:00 2021-04-01T08:14:56.717317+00:00 0:09:02.584437 12333 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T08:05:51.564154+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T07:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T08:05:33.900809+00:00 2021-04-01T08:05:35.568514+00:00 0:00:01.667705 12332 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T08:05:31.555848+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T07:05:00+00:00 PythonOperator 2021-04-01T08:05:11.572698+00:00 2021-04-01T08:05:14.262561+00:00 0:00:02.689863 12331 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T08:05:09.397704+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T07:00:00+00:00 EmrJobFlowSensor 2021-04-01T08:00:55.241494+00:00 2021-04-01T08:16:58.760596+00:00 0:16:03.519102 12330 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T08:00:52.900154+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T08:00:33.149024+00:00 2021-04-01T08:00:34.830519+00:00 0:00:01.681495 12329 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T08:00:30.866082+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T07:00:00+00:00 PythonOperator 2021-04-01T08:00:11.209819+00:00 2021-04-01T08:00:13.990249+00:00 0:00:02.780430 12328 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T08:00:08.863725+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T06:00:00+00:00 EmrJobFlowSensor 2021-04-01T07:14:00.337951+00:00 2021-04-01T07:23:03.191587+00:00 0:09:02.853636 12327 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T07:13:57.893347+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T06:00:00+00:00 EmrJobFlowSensor 2021-04-01T07:13:58.303041+00:00 2021-04-01T07:24:01.063142+00:00 0:10:02.760101 12326 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T07:13:55.957973+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T07:13:40.458050+00:00 2021-04-01T07:13:42.127757+00:00 0:00:01.669707 12325 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T07:13:37.848745+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T07:13:38.128503+00:00 2021-04-01T07:13:40.142673+00:00 0:00:02.014170 12324 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T07:13:35.846295+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T06:00:00+00:00 PythonOperator 2021-04-01T07:13:18.747837+00:00 2021-04-01T07:13:21.495206+00:00 0:00:02.747369 12323 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T07:13:15.832681+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T06:00:00+00:00 PythonOperator 2021-04-01T07:13:16.255157+00:00 2021-04-01T07:13:19.527968+00:00 0:00:03.272811 12322 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T07:13:13.829952+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T06:00:00+00:00 TriggerDagRunOperator 2021-04-01T07:12:56.263666+00:00 2021-04-01T07:12:56.786369+00:00 0:00:00.522703 12321 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T07:12:53.810978+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T06:00:00+00:00 TriggerDagRunOperator 2021-04-01T07:12:56.045751+00:00 2021-04-01T07:12:56.459134+00:00 0:00:00.413383 12320 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T07:12:53.811007+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T06:05:00+00:00 EmrJobFlowSensor 2021-04-01T07:06:12.040054+00:00 2021-04-01T07:15:14.663571+00:00 0:09:02.623517 12318 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T07:06:09.767713+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T06:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T07:05:51.810132+00:00 2021-04-01T07:05:53.464343+00:00 0:00:01.654211 12317 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T07:05:49.638015+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T06:05:00+00:00 PythonOperator 2021-04-01T07:05:15.804078+00:00 2021-04-01T07:05:18.578100+00:00 0:00:02.774022 12316 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T07:05:13.604579+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T06:00:00+00:00 EmrJobFlowSensor 2021-04-01T07:01:15.576380+00:00 2021-04-01T07:11:18.444671+00:00 0:10:02.868291 12315 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T07:01:13.290033+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T07:00:51.570536+00:00 2021-04-01T07:00:53.373486+00:00 0:00:01.802950 12314 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T07:00:49.269788+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T06:00:00+00:00 PythonOperator 2021-04-01T07:00:27.548746+00:00 2021-04-01T07:00:30.266755+00:00 0:00:02.718009 12313 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T07:00:25.275233+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T05:00:00+00:00 EmrJobFlowSensor 2021-04-01T06:11:28.937377+00:00 2021-04-01T06:22:31.825661+00:00 0:11:02.888284 12312 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T06:11:26.459646+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T05:00:00+00:00 EmrJobFlowSensor 2021-04-01T06:11:22.804909+00:00 2021-04-01T06:20:25.419204+00:00 0:09:02.614295 12311 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T06:11:20.461582+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T06:11:06.675035+00:00 2021-04-01T06:11:08.552543+00:00 0:00:01.877508 12310 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T06:11:04.381586+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T06:11:02.678825+00:00 2021-04-01T06:11:04.508526+00:00 0:00:01.829701 12309 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T06:11:00.378953+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T05:00:00+00:00 PythonOperator 2021-04-01T06:10:46.685630+00:00 2021-04-01T06:10:49.647037+00:00 0:00:02.961407 12308 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T06:10:44.330377+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T05:00:00+00:00 PythonOperator 2021-04-01T06:10:41.025456+00:00 2021-04-01T06:10:43.742256+00:00 0:00:02.716800 12307 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T06:10:38.449870+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T05:00:00+00:00 TriggerDagRunOperator 2021-04-01T06:10:29.128092+00:00 2021-04-01T06:10:29.675417+00:00 0:00:00.547325 12306 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T06:10:26.310664+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T05:00:00+00:00 TriggerDagRunOperator 2021-04-01T06:10:28.925518+00:00 2021-04-01T06:10:29.347993+00:00 0:00:00.422475 12305 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T06:10:26.310637+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T05:05:00+00:00 EmrJobFlowSensor 2021-04-01T06:05:55.275123+00:00 2021-04-01T06:14:57.936372+00:00 0:09:02.661249 12303 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T06:05:52.967156+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T05:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T06:05:33.267128+00:00 2021-04-01T06:05:34.892441+00:00 0:00:01.625313 12302 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T06:05:30.884753+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T05:05:00+00:00 PythonOperator 2021-04-01T06:05:10.889679+00:00 2021-04-01T06:05:13.630980+00:00 0:00:02.741301 12301 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T06:05:08.742623+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T05:00:00+00:00 EmrJobFlowSensor 2021-04-01T06:01:02.631103+00:00 2021-04-01T06:10:05.327143+00:00 0:09:02.696040 12300 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T06:01:00.380715+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T06:00:40.565336+00:00 2021-04-01T06:00:42.375533+00:00 0:00:01.810197 12299 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T06:00:38.296448+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T05:00:00+00:00 PythonOperator 2021-04-01T06:00:20.529161+00:00 2021-04-01T06:00:23.249023+00:00 0:00:02.719862 12298 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T06:00:18.241804+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T04:00:00+00:00 EmrJobFlowSensor 2021-04-01T05:11:07.930559+00:00 2021-04-01T05:21:10.762210+00:00 0:10:02.831651 12297 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T05:11:05.363544+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T04:00:00+00:00 EmrJobFlowSensor 2021-04-01T05:11:07.859910+00:00 2021-04-01T05:20:10.620858+00:00 0:09:02.760948 12296 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T05:11:05.363492+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T05:10:45.714621+00:00 2021-04-01T05:10:47.418623+00:00 0:00:01.704002 12295 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T05:10:43.343692+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T05:10:45.730377+00:00 2021-04-01T05:10:47.558743+00:00 0:00:01.828366 12294 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T05:10:43.343661+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T04:00:00+00:00 PythonOperator 2021-04-01T05:10:25.635346+00:00 2021-04-01T05:10:28.511227+00:00 0:00:02.875881 12293 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T05:10:23.222302+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T04:00:00+00:00 PythonOperator 2021-04-01T05:10:23.784962+00:00 2021-04-01T05:10:26.793558+00:00 0:00:03.008596 12292 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T05:10:21.221875+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T04:00:00+00:00 TriggerDagRunOperator 2021-04-01T05:10:17.943409+00:00 2021-04-01T05:10:18.482341+00:00 0:00:00.538932 12291 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T05:10:15.270693+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T04:00:00+00:00 TriggerDagRunOperator 2021-04-01T05:10:17.636372+00:00 2021-04-01T05:10:18.050885+00:00 0:00:00.414513 12290 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T05:10:15.270731+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T04:05:00+00:00 EmrJobFlowSensor 2021-04-01T05:09:27.278359+00:00 2021-04-01T05:18:29.771708+00:00 0:09:02.493349 12289 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T05:09:25.124463+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T04:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T05:09:07.280445+00:00 2021-04-01T05:09:08.942166+00:00 0:00:01.661721 12288 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T05:09:05.105630+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T04:05:00+00:00 PythonOperator 2021-04-01T05:08:45.817740+00:00 2021-04-01T05:08:48.590787+00:00 0:00:02.773047 12287 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T05:08:43.037511+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T04:00:00+00:00 EmrJobFlowSensor 2021-04-01T05:01:03.568998+00:00 2021-04-01T05:10:06.306620+00:00 0:09:02.737622 12285 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T05:01:01.154968+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T05:00:39.703760+00:00 2021-04-01T05:00:41.481725+00:00 0:00:01.777965 12284 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T05:00:37.175350+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T04:00:00+00:00 PythonOperator 2021-04-01T05:00:19.641469+00:00 2021-04-01T05:00:22.367466+00:00 0:00:02.725997 12283 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T05:00:17.093780+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T03:00:00+00:00 EmrJobFlowSensor 2021-04-01T04:13:24.817601+00:00 2021-04-01T04:23:27.627582+00:00 0:10:02.809981 12282 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T04:13:22.560527+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T03:00:00+00:00 EmrJobFlowSensor 2021-04-01T04:13:15.150973+00:00 2021-04-01T04:23:17.911833+00:00 0:10:02.760860 12281 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T04:13:12.549158+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T04:13:04.698729+00:00 2021-04-01T04:13:06.418563+00:00 0:00:01.719834 12280 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T04:13:02.422876+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T04:12:55.039146+00:00 2021-04-01T04:12:56.745812+00:00 0:00:01.706666 12279 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T04:12:52.412664+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T03:00:00+00:00 PythonOperator 2021-04-01T04:12:42.674885+00:00 2021-04-01T04:12:45.581067+00:00 0:00:02.906182 12278 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T04:12:40.391585+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T03:00:00+00:00 PythonOperator 2021-04-01T04:12:33.018377+00:00 2021-04-01T04:12:35.756072+00:00 0:00:02.737695 12277 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T04:12:30.385731+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T03:00:00+00:00 TriggerDagRunOperator 2021-04-01T04:12:20.920521+00:00 2021-04-01T04:12:21.332754+00:00 0:00:00.412233 12276 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T04:12:18.356273+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T03:00:00+00:00 TriggerDagRunOperator 2021-04-01T04:12:20.727973+00:00 2021-04-01T04:12:21.253699+00:00 0:00:00.525726 12275 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T04:12:18.356349+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T03:05:00+00:00 EmrJobFlowSensor 2021-04-01T04:06:10.159976+00:00 2021-04-01T04:15:12.800931+00:00 0:09:02.640955 12274 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T04:06:07.846565+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T03:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T04:05:43.911140+00:00 2021-04-01T04:05:45.574095+00:00 0:00:01.662955 12273 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T04:05:41.747497+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T03:05:00+00:00 PythonOperator 2021-04-01T04:05:21.880470+00:00 2021-04-01T04:05:24.569499+00:00 0:00:02.689029 12272 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T04:05:19.727321+00:00 2 default_pool