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 booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T18:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T19:09:50.797963+00:00 2021-03-25T19:09:52.575686+00:00 0:00:01.777723 11660 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T19:09:48.444102+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T18:00:00+00:00 PythonOperator 2021-03-25T19:09:31.127307+00:00 2021-03-25T19:09:34.033010+00:00 0:00:02.905703 11659 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T19:09:28.357140+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T18:00:00+00:00 TriggerDagRunOperator 2021-03-25T19:09:18.449915+00:00 2021-03-25T19:09:18.977263+00:00 0:00:00.527348 11658 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T19:09:16.195283+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T18:00:00+00:00 TriggerDagRunOperator 2021-03-25T19:09:18.412976+00:00 2021-03-25T19:09:18.888433+00:00 0:00:00.475457 11657 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T19:09:16.195311+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T18:05:00+00:00 EmrJobFlowSensor 2021-03-25T19:06:04.046495+00:00 2021-03-25T19:15:06.687821+00:00 0:09:02.641326 11656 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T19:06:01.769919+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T18:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T19:05:41.781290+00:00 2021-03-25T19:05:43.434898+00:00 0:00:01.653608 11655 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T19:05:39.684900+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T18:05:00+00:00 PythonOperator 2021-03-25T19:05:19.855518+00:00 2021-03-25T19:05:22.649306+00:00 0:00:02.793788 11654 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T19:05:17.661154+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T18:00:00+00:00 EmrJobFlowSensor 2021-03-25T19:00:55.515475+00:00 2021-03-25T19:08:57.921628+00:00 0:08:02.406153 11653 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T19:00:53.333643+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T18:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T19:00:33.885152+00:00 2021-03-25T19:00:35.654976+00:00 0:00:01.769824 11652 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T19:00:31.375853+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T18:00:00+00:00 PythonOperator 2021-03-25T19:00:11.979176+00:00 2021-03-25T19:00:14.740453+00:00 0:00:02.761277 11651 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T19:00:09.366675+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T17:00:00+00:00 EmrJobFlowSensor 2021-03-25T18:11:36.317743+00:00 2021-03-25T18:21:39.064901+00:00 0:10:02.747158 11649 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T18:11:34.066056+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T17:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T18:11:16.248556+00:00 2021-03-25T18:11:18.056998+00:00 0:00:01.808442 11648 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T18:11:14.012374+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T17:00:00+00:00 PythonOperator 2021-03-25T18:10:54.497954+00:00 2021-03-25T18:10:57.528105+00:00 0:00:03.030151 11647 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T18:10:51.993055+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T17:00:00+00:00 TriggerDagRunOperator 2021-03-25T18:10:32.401679+00:00 2021-03-25T18:10:32.916342+00:00 0:00:00.514663 11646 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T18:10:30.041026+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T17:00:00+00:00 TriggerDagRunOperator 2021-03-25T18:10:32.334309+00:00 2021-03-25T18:10:32.813024+00:00 0:00:00.478715 11645 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T18:10:30.041077+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T17:05:00+00:00 EmrJobFlowSensor 2021-03-25T18:05:47.835632+00:00 2021-03-25T18:14:50.415332+00:00 0:09:02.579700 11644 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T18:05:45.659409+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T17:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T18:05:25.850214+00:00 2021-03-25T18:05:27.586663+00:00 0:00:01.736449 11643 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T18:05:23.638332+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T17:05:00+00:00 PythonOperator 2021-03-25T18:05:03.855025+00:00 2021-03-25T18:05:06.579467+00:00 0:00:02.724442 11642 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T18:05:01.608507+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T17:00:00+00:00 EmrJobFlowSensor 2021-03-25T18:00:53.667795+00:00 2021-03-25T18:09:56.377907+00:00 0:09:02.710112 11641 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T18:00:51.311837+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T17:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T18:00:31.461454+00:00 2021-03-25T18:00:33.191291+00:00 0:00:01.729837 11640 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T18:00:29.291717+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T17:00:00+00:00 PythonOperator 2021-03-25T18:00:11.521223+00:00 2021-03-25T18:00:14.350348+00:00 0:00:02.829125 11639 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T18:00:09.229702+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T16:00:00+00:00 EmrJobFlowSensor 2021-03-25T17:12:12.638419+00:00 2021-03-25T17:22:15.448299+00:00 0:10:02.809880 11637 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T17:12:10.391905+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T16:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T17:11:50.757852+00:00 2021-03-25T17:11:52.524431+00:00 0:00:01.766579 11636 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T17:11:48.353797+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T16:00:00+00:00 PythonOperator 2021-03-25T17:11:28.499715+00:00 2021-03-25T17:11:31.455010+00:00 0:00:02.955295 11635 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T17:11:26.326621+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T16:00:00+00:00 TriggerDagRunOperator 2021-03-25T17:11:14.711556+00:00 2021-03-25T17:11:15.198945+00:00 0:00:00.487389 11634 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T17:11:12.302753+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T16:00:00+00:00 TriggerDagRunOperator 2021-03-25T17:11:14.521346+00:00 2021-03-25T17:11:14.898784+00:00 0:00:00.377438 11633 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T17:11:12.302706+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T16:05:00+00:00 EmrJobFlowSensor 2021-03-25T17:06:06.047295+00:00 2021-03-25T17:15:08.594714+00:00 0:09:02.547419 11632 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T17:06:03.927469+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T16:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T17:05:44.059997+00:00 2021-03-25T17:05:45.829943+00:00 0:00:01.769946 11631 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T17:05:41.912785+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T16:05:00+00:00 PythonOperator 2021-03-25T17:05:21.966437+00:00 2021-03-25T17:05:24.633500+00:00 0:00:02.667063 11630 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T17:05:19.887694+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T16:00:00+00:00 EmrJobFlowSensor 2021-03-25T17:01:08.002464+00:00 2021-03-25T17:11:11.032304+00:00 0:10:03.029840 11629 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T17:01:05.560555+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T16:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T17:00:45.730175+00:00 2021-03-25T17:00:47.528042+00:00 0:00:01.797867 11628 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T17:00:43.491836+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T16:00:00+00:00 PythonOperator 2021-03-25T17:00:23.831398+00:00 2021-03-25T17:00:26.745517+00:00 0:00:02.914119 11627 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T17:00:21.477753+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T15:00:00+00:00 EmrJobFlowSensor 2021-03-25T16:26:26.037921+00:00 2021-03-25T16:36:28.804661+00:00 0:10:02.766740 11626 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T16:26:23.843246+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T15:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T16:26:06.095214+00:00 2021-03-25T16:26:07.776075+00:00 0:00:01.680861 11625 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T16:26:03.825816+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T15:00:00+00:00 PythonOperator 2021-03-25T16:25:42.063170+00:00 2021-03-25T16:25:45.176445+00:00 0:00:03.113275 11624 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T16:25:39.808448+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T15:00:00+00:00 TriggerDagRunOperator 2021-03-25T16:25:26.330551+00:00 2021-03-25T16:25:26.848788+00:00 0:00:00.518237 11623 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T16:25:23.791438+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T15:00:00+00:00 TriggerDagRunOperator 2021-03-25T16:25:26.049227+00:00 2021-03-25T16:25:26.456673+00:00 0:00:00.407446 11622 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T16:25:23.791409+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T15:00:00+00:00 EmrJobFlowSensor 2021-03-25T16:15:11.069385+00:00 2021-03-25T16:25:14.009858+00:00 0:10:02.940473 11621 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T16:15:08.819988+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T15:05:00+00:00 EmrJobFlowSensor 2021-03-25T16:15:07.033448+00:00 2021-03-25T16:23:09.521275+00:00 0:08:02.487827 11620 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T16:15:04.872189+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T15:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T16:14:50.987974+00:00 2021-03-25T16:14:52.778820+00:00 0:00:01.790846 11619 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T16:14:48.805124+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T15:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T16:14:44.984193+00:00 2021-03-25T16:14:46.760060+00:00 0:00:01.775867 11618 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T16:14:42.797288+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T15:00:00+00:00 PythonOperator 2021-03-25T16:14:29.122772+00:00 2021-03-25T16:14:31.850489+00:00 0:00:02.727717 11617 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T16:14:26.782260+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T15:05:00+00:00 PythonOperator 2021-03-25T16:14:25.158018+00:00 2021-03-25T16:14:28.001777+00:00 0:00:02.843759 11616 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T16:14:22.778885+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T14:00:00+00:00 EmrJobFlowSensor 2021-03-25T15:11:19.635739+00:00 2021-03-25T15:20:22.336103+00:00 0:09:02.700364 11614 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T15:11:17.189411+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T14:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T15:10:59.602870+00:00 2021-03-25T15:11:01.428826+00:00 0:00:01.825956 11613 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T15:10:57.162567+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T14:00:00+00:00 PythonOperator 2021-03-25T15:10:37.313355+00:00 2021-03-25T15:10:40.214767+00:00 0:00:02.901412 11612 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T15:10:35.097880+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T14:00:00+00:00 TriggerDagRunOperator 2021-03-25T15:10:17.363600+00:00 2021-03-25T15:10:17.876406+00:00 0:00:00.512806 11611 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T15:10:15.056017+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T14:00:00+00:00 TriggerDagRunOperator 2021-03-25T15:10:17.314128+00:00 2021-03-25T15:10:17.721303+00:00 0:00:00.407175 11610 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T15:10:15.056053+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T14:05:00+00:00 EmrJobFlowSensor 2021-03-25T15:05:46.902973+00:00 2021-03-25T15:16:49.887303+00:00 0:11:02.984330 11609 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T15:05:44.691689+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T14:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T15:05:26.783866+00:00 2021-03-25T15:05:28.420670+00:00 0:00:01.636804 11608 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T15:05:24.644463+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T14:05:00+00:00 PythonOperator 2021-03-25T15:05:05.037545+00:00 2021-03-25T15:05:07.702282+00:00 0:00:02.664737 11607 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T15:05:02.666449+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T14:00:00+00:00 EmrJobFlowSensor 2021-03-25T15:00:58.389045+00:00 2021-03-25T15:10:01.158658+00:00 0:09:02.769613 11606 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T15:00:56.111002+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T14:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T15:00:36.222683+00:00 2021-03-25T15:00:37.906481+00:00 0:00:01.683798 11605 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T15:00:34.087010+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T14:00:00+00:00 PythonOperator 2021-03-25T15:00:16.848702+00:00 2021-03-25T15:00:19.717445+00:00 0:00:02.868743 11604 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T15:00:14.071030+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T13:00:00+00:00 EmrJobFlowSensor 2021-03-25T14:11:56.879449+00:00 2021-03-25T14:20:59.554540+00:00 0:09:02.675091 11602 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T14:11:54.482408+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T13:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T14:11:36.727782+00:00 2021-03-25T14:11:38.536719+00:00 0:00:01.808937 11601 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T14:11:34.395653+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T13:00:00+00:00 PythonOperator 2021-03-25T14:11:14.738865+00:00 2021-03-25T14:11:17.725492+00:00 0:00:02.986627 11600 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T14:11:12.357548+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T13:00:00+00:00 TriggerDagRunOperator 2021-03-25T14:11:06.664270+00:00 2021-03-25T14:11:07.172895+00:00 0:00:00.508625 11599 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T14:11:04.350192+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T13:00:00+00:00 TriggerDagRunOperator 2021-03-25T14:11:06.586925+00:00 2021-03-25T14:11:06.995038+00:00 0:00:00.408113 11598 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T14:11:04.350232+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T13:05:00+00:00 EmrJobFlowSensor 2021-03-25T14:06:00.592731+00:00 2021-03-25T14:15:03.340076+00:00 0:09:02.747345 11597 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T14:05:58.047311+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T13:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T14:05:40.162631+00:00 2021-03-25T14:05:41.779252+00:00 0:00:01.616621 11596 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T14:05:37.871031+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T13:05:00+00:00 PythonOperator 2021-03-25T14:05:07.956028+00:00 2021-03-25T14:05:10.702343+00:00 0:00:02.746315 11595 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T14:05:05.831514+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T13:00:00+00:00 EmrJobFlowSensor 2021-03-25T14:00:49.879203+00:00 2021-03-25T14:10:52.595566+00:00 0:10:02.716363 11594 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T14:00:47.531106+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T13:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T14:00:28.033116+00:00 2021-03-25T14:00:29.723664+00:00 0:00:01.690548 11593 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T14:00:25.565214+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T13:00:00+00:00 PythonOperator 2021-03-25T14:00:06.092244+00:00 2021-03-25T14:00:08.850990+00:00 0:00:02.758746 11592 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T14:00:03.558396+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T12:00:00+00:00 EmrJobFlowSensor 2021-03-25T13:10:49.408847+00:00 2021-03-25T13:20:52.170798+00:00 0:10:02.761951 11590 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T13:10:46.990067+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T12:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T13:10:29.157548+00:00 2021-03-25T13:10:30.882798+00:00 0:00:01.725250 11589 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T13:10:26.908568+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T12:00:00+00:00 PythonOperator 2021-03-25T13:10:07.120662+00:00 2021-03-25T13:10:10.204114+00:00 0:00:03.083452 11588 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T13:10:04.887058+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T12:00:00+00:00 TriggerDagRunOperator 2021-03-25T13:09:59.280814+00:00 2021-03-25T13:09:59.761641+00:00 0:00:00.480827 11587 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T13:09:56.834747+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T12:00:00+00:00 TriggerDagRunOperator 2021-03-25T13:09:59.014946+00:00 2021-03-25T13:09:59.409575+00:00 0:00:00.394629 11586 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T13:09:56.834712+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T12:05:00+00:00 EmrJobFlowSensor 2021-03-25T13:06:12.771326+00:00 2021-03-25T13:15:15.352545+00:00 0:09:02.581219 11585 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T13:06:10.558813+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T12:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T13:05:50.648983+00:00 2021-03-25T13:05:52.326921+00:00 0:00:01.677938 11584 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T13:05:48.487806+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T12:05:00+00:00 PythonOperator 2021-03-25T13:05:22.609095+00:00 2021-03-25T13:05:25.383073+00:00 0:00:02.773978 11583 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T13:05:20.399786+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T12:00:00+00:00 EmrJobFlowSensor 2021-03-25T13:00:48.150688+00:00 2021-03-25T13:09:50.616439+00:00 0:09:02.465751 11582 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T13:00:45.915974+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T12:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T13:00:26.093977+00:00 2021-03-25T13:00:27.772358+00:00 0:00:01.678381 11581 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T13:00:23.910778+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T12:00:00+00:00 PythonOperator 2021-03-25T13:00:04.173339+00:00 2021-03-25T13:00:07.011119+00:00 0:00:02.837780 11580 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T13:00:01.853649+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T11:00:00+00:00 EmrJobFlowSensor 2021-03-25T12:10:59.529259+00:00 2021-03-25T12:21:02.389943+00:00 0:10:02.860684 11578 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T12:10:57.322572+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T11:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T12:10:39.684144+00:00 2021-03-25T12:10:41.497592+00:00 0:00:01.813448 11577 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T12:10:37.303264+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T11:00:00+00:00 PythonOperator 2021-03-25T12:10:17.426373+00:00 2021-03-25T12:10:20.379799+00:00 0:00:02.953426 11576 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T12:10:15.267065+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T11:00:00+00:00 TriggerDagRunOperator 2021-03-25T12:10:07.618661+00:00 2021-03-25T12:10:08.112012+00:00 0:00:00.493351 11575 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T12:10:05.271365+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T11:00:00+00:00 TriggerDagRunOperator 2021-03-25T12:10:07.447815+00:00 2021-03-25T12:10:07.862438+00:00 0:00:00.414623 11574 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T12:10:05.271336+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T11:05:00+00:00 EmrJobFlowSensor 2021-03-25T12:05:59.490668+00:00 2021-03-25T12:15:02.185559+00:00 0:09:02.694891 11573 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T12:05:57.057027+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T11:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T12:05:39.270973+00:00 2021-03-25T12:05:40.978771+00:00 0:00:01.707798 11572 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T12:05:37.059884+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T11:05:00+00:00 PythonOperator 2021-03-25T12:05:17.168089+00:00 2021-03-25T12:05:19.905965+00:00 0:00:02.737876 11571 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T12:05:14.949284+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T11:00:00+00:00 EmrJobFlowSensor 2021-03-25T12:00:48.756839+00:00 2021-03-25T12:09:51.534244+00:00 0:09:02.777405 11570 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T12:00:46.489889+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T11:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T12:00:28.708215+00:00 2021-03-25T12:00:30.386645+00:00 0:00:01.678430 11569 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T12:00:26.476695+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T11:00:00+00:00 PythonOperator 2021-03-25T12:00:06.968765+00:00 2021-03-25T12:00:09.803555+00:00 0:00:02.834790 11568 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T12:00:04.456599+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T10:00:00+00:00 EmrJobFlowSensor 2021-03-25T11:11:22.140035+00:00 2021-03-25T11:23:25.467449+00:00 0:12:03.327414 11566 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T11:11:19.825863+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T10:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T11:10:57.927980+00:00 2021-03-25T11:10:59.652264+00:00 0:00:01.724284 11565 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T11:10:55.807055+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T10:00:00+00:00 PythonOperator 2021-03-25T11:10:33.989354+00:00 2021-03-25T11:10:37.005037+00:00 0:00:03.015683 11564 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T11:10:31.784390+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T10:00:00+00:00 TriggerDagRunOperator 2021-03-25T11:10:16.287265+00:00 2021-03-25T11:10:16.682551+00:00 0:00:00.395286 11563 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T11:10:13.755599+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T10:00:00+00:00 TriggerDagRunOperator 2021-03-25T11:10:16.106581+00:00 2021-03-25T11:10:16.645382+00:00 0:00:00.538801 11562 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T11:10:13.755563+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T10:05:00+00:00 EmrJobFlowSensor 2021-03-25T11:06:11.492642+00:00 2021-03-25T11:15:14.042566+00:00 0:09:02.549924 11561 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T11:06:09.322730+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T10:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T11:05:51.401517+00:00 2021-03-25T11:05:53.038665+00:00 0:00:01.637148 11560 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T11:05:49.302708+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T10:05:00+00:00 PythonOperator 2021-03-25T11:05:29.763091+00:00 2021-03-25T11:05:32.540523+00:00 0:00:02.777432 11559 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T11:05:27.363098+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T10:00:00+00:00 EmrJobFlowSensor 2021-03-25T11:01:06.911797+00:00 2021-03-25T11:10:09.630949+00:00 0:09:02.719152 11558 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T11:01:04.787406+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T10:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T11:00:45.084282+00:00 2021-03-25T11:00:46.958361+00:00 0:00:01.874079 11557 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T11:00:42.759571+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T10:00:00+00:00 PythonOperator 2021-03-25T11:00:23.381369+00:00 2021-03-25T11:00:26.507716+00:00 0:00:03.126347 11556 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T11:00:20.766644+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T09:00:00+00:00 EmrJobFlowSensor 2021-03-25T10:12:16.331679+00:00 2021-03-25T10:22:19.208439+00:00 0:10:02.876760 11554 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T10:12:14.040541+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T09:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T10:11:56.411907+00:00 2021-03-25T10:11:58.228203+00:00 0:00:01.816296 11553 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T10:11:54.016300+00:00 2 default_pool