Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T10:00:31.710072+00:00 2021-04-05T10:00:33.524513+00:00 0:00:01.814441 13800 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T10:00:29.359895+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T09:00:00+00:00 PythonOperator 2021-04-05T10:00:09.722520+00:00 2021-04-05T10:00:12.593262+00:00 0:00:02.870742 13799 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T10:00:07.273108+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-05T08:00:00+00:00 EmrJobFlowSensor 2021-04-05T09:12:10.108590+00:00 2021-04-05T09:22:12.736131+00:00 0:10:02.627541 13797 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T09:12:07.937494+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-05T08:00:00+00:00 EmrJobFlowSensor 2021-04-05T09:12:08.303295+00:00 2021-04-05T09:29:12.242586+00:00 0:17:03.939291 13796 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T09:12:05.935395+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-05T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T09:11:50.228023+00:00 2021-04-05T09:11:51.909770+00:00 0:00:01.681747 13795 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T09:11:47.919301+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-05T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T09:11:46.429573+00:00 2021-04-05T09:11:48.245354+00:00 0:00:01.815781 13794 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T09:11:44.044154+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-05T08:00:00+00:00 PythonOperator 2021-04-05T09:11:28.118032+00:00 2021-04-05T09:11:31.092472+00:00 0:00:02.974440 13793 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T09:11:25.902188+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-05T08:00:00+00:00 PythonOperator 2021-04-05T09:11:26.581568+00:00 2021-04-05T09:11:29.555677+00:00 0:00:02.974109 13792 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T09:11:23.916496+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T08:00:00+00:00 TriggerDagRunOperator 2021-04-05T09:11:14.281572+00:00 2021-04-05T09:11:14.817394+00:00 0:00:00.535822 13791 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T09:11:11.886977+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T08:00:00+00:00 TriggerDagRunOperator 2021-04-05T09:11:14.005228+00:00 2021-04-05T09:11:14.410464+00:00 0:00:00.405236 13790 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T09:11:11.887008+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-05T08:05:00+00:00 EmrJobFlowSensor 2021-04-05T09:05:55.705651+00:00 2021-04-05T09:14:58.436800+00:00 0:09:02.731149 13789 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T09:05:53.265022+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-05T08:05:00+00:00 EmrCreateJobFlowOperator 2021-04-05T09:05:33.313499+00:00 2021-04-05T09:05:34.947820+00:00 0:00:01.634321 13788 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T09:05:31.182355+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-05T08:05:00+00:00 PythonOperator 2021-04-05T09:05:11.371181+00:00 2021-04-05T09:05:14.159442+00:00 0:00:02.788261 13787 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T09:05:09.152666+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T08:00:00+00:00 EmrJobFlowSensor 2021-04-05T09:00:59.092826+00:00 2021-04-05T09:11:01.937940+00:00 0:10:02.845114 13786 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T09:00:56.698779+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T09:00:39.122355+00:00 2021-04-05T09:00:40.810370+00:00 0:00:01.688015 13785 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T09:00:36.683801+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T08:00:00+00:00 PythonOperator 2021-04-05T09:00:16.925392+00:00 2021-04-05T09:00:19.808316+00:00 0:00:02.882924 13784 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T09:00:14.621266+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-05T07:00:00+00:00 EmrJobFlowSensor 2021-04-05T08:15:20.628218+00:00 2021-04-05T08:25:23.618722+00:00 0:10:02.990504 13783 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T08:15:18.255521+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-05T07:00:00+00:00 EmrJobFlowSensor 2021-04-05T08:15:14.578977+00:00 2021-04-05T08:25:17.403811+00:00 0:10:02.824834 13782 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T08:15:12.243299+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-05T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T08:14:58.691111+00:00 2021-04-05T08:15:00.482820+00:00 0:00:01.791709 13781 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T08:14:56.280455+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-05T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T08:14:54.598044+00:00 2021-04-05T08:14:56.385563+00:00 0:00:01.787519 13780 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T08:14:52.274004+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-05T07:00:00+00:00 PythonOperator 2021-04-05T08:14:36.970579+00:00 2021-04-05T08:14:39.883060+00:00 0:00:02.912481 13779 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T08:14:34.213593+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-05T07:00:00+00:00 PythonOperator 2021-04-05T08:14:32.611618+00:00 2021-04-05T08:14:35.514884+00:00 0:00:02.903266 13778 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T08:14:30.268185+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T07:00:00+00:00 TriggerDagRunOperator 2021-04-05T08:14:11.078125+00:00 2021-04-05T08:14:11.633171+00:00 0:00:00.555046 13777 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T08:14:08.186431+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T07:00:00+00:00 TriggerDagRunOperator 2021-04-05T08:14:10.682326+00:00 2021-04-05T08:14:11.146432+00:00 0:00:00.464106 13776 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T08:14:08.186462+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-05T07:05:00+00:00 EmrJobFlowSensor 2021-04-05T08:06:00.776016+00:00 2021-04-05T08:14:03.276722+00:00 0:08:02.500706 13774 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T08:05:58.557609+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-05T07:05:00+00:00 EmrCreateJobFlowOperator 2021-04-05T08:05:31.010598+00:00 2021-04-05T08:05:32.732428+00:00 0:00:01.721830 13773 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T08:05:28.568198+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-05T07:05:00+00:00 PythonOperator 2021-04-05T08:05:08.988005+00:00 2021-04-05T08:05:11.658182+00:00 0:00:02.670177 13772 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T08:05:06.456169+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T07:00:00+00:00 EmrJobFlowSensor 2021-04-05T08:00:54.550590+00:00 2021-04-05T08:10:57.486957+00:00 0:10:02.936367 13771 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T08:00:51.991524+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T08:00:32.220289+00:00 2021-04-05T08:00:33.983065+00:00 0:00:01.762776 13770 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T08:00:29.964244+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T07:00:00+00:00 PythonOperator 2021-04-05T08:00:10.152538+00:00 2021-04-05T08:00:12.907409+00:00 0:00:02.754871 13769 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T08:00:07.888570+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-05T06:00:00+00:00 EmrJobFlowSensor 2021-04-05T07:10:40.895257+00:00 2021-04-05T07:20:43.812157+00:00 0:10:02.916900 13768 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T07:10:38.545698+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-05T06:00:00+00:00 EmrJobFlowSensor 2021-04-05T07:10:23.078336+00:00 2021-04-05T07:19:25.962338+00:00 0:09:02.884002 13767 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T07:10:20.468647+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-05T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T07:10:18.729120+00:00 2021-04-05T07:10:20.443555+00:00 0:00:01.714435 13766 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T07:10:16.468124+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-05T06:05:00+00:00 EmrJobFlowSensor 2021-04-05T07:10:14.803441+00:00 2021-04-05T07:19:17.476169+00:00 0:09:02.672728 13765 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T07:10:12.397260+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-05T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T07:10:01.324679+00:00 2021-04-05T07:10:03.066963+00:00 0:00:01.742284 13764 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T07:09:58.465639+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-05T06:00:00+00:00 PythonOperator 2021-04-05T07:09:56.525360+00:00 2021-04-05T07:09:59.722156+00:00 0:00:03.196796 13763 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T07:09:54.361720+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-05T06:05:00+00:00 EmrCreateJobFlowOperator 2021-04-05T07:09:52.514337+00:00 2021-04-05T07:09:54.185188+00:00 0:00:01.670851 13762 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T07:09:50.360589+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-05T06:00:00+00:00 PythonOperator 2021-04-05T07:09:40.659420+00:00 2021-04-05T07:09:43.516090+00:00 0:00:02.856670 13761 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T07:09:38.347242+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T06:00:00+00:00 TriggerDagRunOperator 2021-04-05T07:09:35.589836+00:00 2021-04-05T07:09:35.974113+00:00 0:00:00.384277 13760 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T07:09:32.344567+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T06:00:00+00:00 TriggerDagRunOperator 2021-04-05T07:09:34.632942+00:00 2021-04-05T07:09:35.147976+00:00 0:00:00.515034 13759 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T07:09:32.344597+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-05T06:05:00+00:00 PythonOperator 2021-04-05T07:09:33.538394+00:00 2021-04-05T07:09:36.552922+00:00 0:00:03.014528 13758 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T07:09:30.396000+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T06:00:00+00:00 EmrJobFlowSensor 2021-04-05T07:00:57.789193+00:00 2021-04-05T07:09:00.352950+00:00 0:08:02.563757 13756 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T07:00:55.530792+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T07:00:27.821461+00:00 2021-04-05T07:00:29.706067+00:00 0:00:01.884606 13755 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T07:00:25.503218+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T06:00:00+00:00 PythonOperator 2021-04-05T07:00:05.836415+00:00 2021-04-05T07:00:08.593209+00:00 0:00:02.756794 13754 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T07:00:03.490147+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-05T05:00:00+00:00 EmrJobFlowSensor 2021-04-05T06:10:02.846859+00:00 2021-04-05T06:20:05.812606+00:00 0:10:02.965747 13753 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T06:10:00.487195+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-05T05:00:00+00:00 EmrJobFlowSensor 2021-04-05T06:10:02.760622+00:00 2021-04-05T06:19:05.466203+00:00 0:09:02.705581 13752 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T06:10:00.487165+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-05T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T06:09:40.837054+00:00 2021-04-05T06:09:42.566465+00:00 0:00:01.729411 13751 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T06:09:38.433916+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-05T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T06:09:40.832153+00:00 2021-04-05T06:09:42.654866+00:00 0:00:01.822713 13750 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T06:09:38.433950+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-05T05:00:00+00:00 PythonOperator 2021-04-05T06:09:19.147854+00:00 2021-04-05T06:09:21.986326+00:00 0:00:02.838472 13749 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T06:09:16.464509+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-05T05:00:00+00:00 PythonOperator 2021-04-05T06:09:19.059149+00:00 2021-04-05T06:09:22.074784+00:00 0:00:03.015635 13748 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T06:09:16.464558+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T05:00:00+00:00 TriggerDagRunOperator 2021-04-05T06:08:58.860943+00:00 2021-04-05T06:08:59.420350+00:00 0:00:00.559407 13747 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T06:08:56.459736+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T05:00:00+00:00 TriggerDagRunOperator 2021-04-05T06:08:58.814523+00:00 2021-04-05T06:08:59.296718+00:00 0:00:00.482195 13746 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T06:08:56.459700+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-05T05:05:00+00:00 EmrJobFlowSensor 2021-04-05T06:06:18.488809+00:00 2021-04-05T06:14:21.035100+00:00 0:08:02.546291 13745 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T06:06:16.278425+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-05T05:05:00+00:00 EmrCreateJobFlowOperator 2021-04-05T06:05:44.415322+00:00 2021-04-05T06:05:46.077354+00:00 0:00:01.662032 13744 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T06:05:42.189823+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-05T05:05:00+00:00 PythonOperator 2021-04-05T06:05:18.364160+00:00 2021-04-05T06:05:21.109159+00:00 0:00:02.744999 13743 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T06:05:16.169778+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T05:00:00+00:00 EmrJobFlowSensor 2021-04-05T06:00:51.699816+00:00 2021-04-05T06:08:54.208533+00:00 0:08:02.508717 13741 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T06:00:49.486731+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T06:00:31.658890+00:00 2021-04-05T06:00:33.366480+00:00 0:00:01.707590 13740 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T06:00:29.456007+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T05:00:00+00:00 PythonOperator 2021-04-05T06:00:09.747659+00:00 2021-04-05T06:00:12.550047+00:00 0:00:02.802388 13739 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T06:00:07.430178+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-05T04:00:00+00:00 EmrJobFlowSensor 2021-04-05T05:12:39.139932+00:00 2021-04-05T05:22:41.807810+00:00 0:10:02.667878 13738 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T05:12:36.764380+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-05T04:00:00+00:00 EmrJobFlowSensor 2021-04-05T05:12:20.904067+00:00 2021-04-05T05:22:23.669262+00:00 0:10:02.765195 13737 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T05:12:18.629204+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-05T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T05:12:19.210319+00:00 2021-04-05T05:12:21.065939+00:00 0:00:01.855620 13736 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T05:12:16.674977+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-05T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T05:11:59.030173+00:00 2021-04-05T05:12:00.825543+00:00 0:00:01.795370 13735 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T05:11:56.616009+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-05T04:00:00+00:00 PythonOperator 2021-04-05T05:11:56.819161+00:00 2021-04-05T05:11:59.817315+00:00 0:00:02.998154 13734 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T05:11:54.602955+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-05T04:00:00+00:00 PythonOperator 2021-04-05T05:11:38.911993+00:00 2021-04-05T05:11:41.663983+00:00 0:00:02.751990 13733 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T05:11:36.588628+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T04:00:00+00:00 TriggerDagRunOperator 2021-04-05T05:11:32.930745+00:00 2021-04-05T05:11:33.386983+00:00 0:00:00.456238 13732 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T05:11:30.585865+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T04:00:00+00:00 TriggerDagRunOperator 2021-04-05T05:11:32.861576+00:00 2021-04-05T05:11:33.419068+00:00 0:00:00.557492 13731 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T05:11:30.585820+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-05T04:05:00+00:00 EmrJobFlowSensor 2021-04-05T05:05:56.250165+00:00 2021-04-05T05:13:58.662768+00:00 0:08:02.412603 13730 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T05:05:54.128360+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-05T04:05:00+00:00 EmrCreateJobFlowOperator 2021-04-05T05:05:34.470954+00:00 2021-04-05T05:05:36.225085+00:00 0:00:01.754131 13729 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T05:05:32.108227+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-05T04:05:00+00:00 PythonOperator 2021-04-05T05:05:13.036204+00:00 2021-04-05T05:05:15.811360+00:00 0:00:02.775156 13728 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T05:05:10.151592+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T04:00:00+00:00 EmrJobFlowSensor 2021-04-05T05:01:14.705836+00:00 2021-04-05T05:11:17.544092+00:00 0:10:02.838256 13726 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T05:01:12.362735+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T05:00:42.585178+00:00 2021-04-05T05:00:44.306474+00:00 0:00:01.721296 13725 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T05:00:40.301563+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T04:00:00+00:00 PythonOperator 2021-04-05T05:00:16.391638+00:00 2021-04-05T05:00:19.156198+00:00 0:00:02.764560 13724 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T05:00:14.266541+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-05T03:00:00+00:00 EmrJobFlowSensor 2021-04-05T04:10:06.927909+00:00 2021-04-05T04:20:09.835549+00:00 0:10:02.907640 13723 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T04:10:04.787535+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-05T03:00:00+00:00 EmrJobFlowSensor 2021-04-05T04:09:59.012030+00:00 2021-04-05T04:19:01.738917+00:00 0:09:02.726887 13722 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T04:09:56.733360+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-05T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T04:09:47.011125+00:00 2021-04-05T04:09:48.922071+00:00 0:00:01.910946 13721 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T04:09:44.721917+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-05T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T04:09:36.990195+00:00 2021-04-05T04:09:38.655537+00:00 0:00:01.665342 13720 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T04:09:34.755521+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-05T03:00:00+00:00 PythonOperator 2021-04-05T04:09:25.179482+00:00 2021-04-05T04:09:28.333527+00:00 0:00:03.154045 13719 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T04:09:22.751684+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-05T03:00:00+00:00 PythonOperator 2021-04-05T04:09:17.125747+00:00 2021-04-05T04:09:19.920624+00:00 0:00:02.794877 13718 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T04:09:14.755707+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T03:00:00+00:00 TriggerDagRunOperator 2021-04-05T04:09:07.165931+00:00 2021-04-05T04:09:07.700064+00:00 0:00:00.534133 13717 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T04:09:04.759788+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T03:00:00+00:00 TriggerDagRunOperator 2021-04-05T04:09:07.065233+00:00 2021-04-05T04:09:07.501730+00:00 0:00:00.436497 13716 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T04:09:04.759831+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-05T03:05:00+00:00 EmrJobFlowSensor 2021-04-05T04:05:54.693202+00:00 2021-04-05T04:14:57.429262+00:00 0:09:02.736060 13715 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T04:05:52.395435+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-05T03:05:00+00:00 EmrCreateJobFlowOperator 2021-04-05T04:05:32.499671+00:00 2021-04-05T04:05:34.167399+00:00 0:00:01.667728 13714 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T04:05:30.322815+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-05T03:05:00+00:00 PythonOperator 2021-04-05T04:05:12.825895+00:00 2021-04-05T04:05:15.617281+00:00 0:00:02.791386 13713 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T04:05:10.302807+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T03:00:00+00:00 EmrJobFlowSensor 2021-04-05T04:00:50.642902+00:00 2021-04-05T04:08:53.287662+00:00 0:08:02.644760 13711 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T04:00:48.247493+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T04:00:30.801122+00:00 2021-04-05T04:00:32.534546+00:00 0:00:01.733424 13710 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T04:00:28.273980+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T03:00:00+00:00 PythonOperator 2021-04-05T04:00:08.494319+00:00 2021-04-05T04:00:11.294613+00:00 0:00:02.800294 13709 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T04:00:06.143958+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-05T02:00:00+00:00 EmrJobFlowSensor 2021-04-05T03:14:25.649766+00:00 2021-04-05T03:23:28.244354+00:00 0:09:02.594588 13708 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T03:14:23.386053+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-05T02:00:00+00:00 EmrJobFlowSensor 2021-04-05T03:14:07.530790+00:00 2021-04-05T03:24:10.428024+00:00 0:10:02.897234 13707 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T03:14:05.346002+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-05T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T03:14:05.770956+00:00 2021-04-05T03:14:07.603533+00:00 0:00:01.832577 13706 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T03:14:03.342880+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-05T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T03:13:47.647423+00:00 2021-04-05T03:13:49.491089+00:00 0:00:01.843666 13705 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T03:13:45.299163+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-05T02:00:00+00:00 PythonOperator 2021-04-05T03:13:43.526926+00:00 2021-04-05T03:13:46.519687+00:00 0:00:02.992761 13704 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T03:13:41.293893+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-05T02:00:00+00:00 PythonOperator 2021-04-05T03:13:25.772395+00:00 2021-04-05T03:13:28.640476+00:00 0:00:02.868081 13703 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T03:13:23.341181+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T02:00:00+00:00 TriggerDagRunOperator 2021-04-05T03:13:19.892314+00:00 2021-04-05T03:13:20.410613+00:00 0:00:00.518299 13702 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T03:13:17.266955+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T02:00:00+00:00 TriggerDagRunOperator 2021-04-05T03:13:19.697938+00:00 2021-04-05T03:13:20.112884+00:00 0:00:00.414946 13701 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T03:13:17.267003+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-05T02:05:00+00:00 EmrJobFlowSensor 2021-04-05T03:05:56.566871+00:00 2021-04-05T03:14:59.110133+00:00 0:09:02.543262 13700 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T03:05:54.301545+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-05T02:05:00+00:00 EmrCreateJobFlowOperator 2021-04-05T03:05:36.378327+00:00 2021-04-05T03:05:38.039127+00:00 0:00:01.660800 13699 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T03:05:34.215779+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-05T02:05:00+00:00 PythonOperator 2021-04-05T03:05:14.373657+00:00 2021-04-05T03:05:17.036124+00:00 0:00:02.662467 13698 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T03:05:12.196381+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T02:00:00+00:00 EmrJobFlowSensor 2021-04-05T03:04:00.811294+00:00 2021-04-05T03:13:03.497593+00:00 0:09:02.686299 13697 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T03:03:58.263302+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T03:03:40.455888+00:00 2021-04-05T03:03:42.270091+00:00 0:00:01.814203 13696 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T03:03:38.092698+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T02:00:00+00:00 PythonOperator 2021-04-05T03:03:18.302524+00:00 2021-04-05T03:03:21.026968+00:00 0:00:02.724444 13695 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T03:03:16.055628+00:00 2 default_pool