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 trigger_dagrun_booking-processing-job_v002 2021-05-27T18:00:00+00:00 TriggerDagRunOperator 2021-05-27T19:10:09.559008+00:00 2021-05-27T19:10:09.976157+00:00 0:00:00.417149 33070 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-27T19:10:07.385368+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-27T18:05:00+00:00 EmrJobFlowSensor 2021-05-27T19:05:57.444117+00:00 2021-05-27T19:13:59.802172+00:00 0:08:02.358055 33069 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-27T19:05:55.147327+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-27T18:05:00+00:00 EmrCreateJobFlowOperator 2021-05-27T19:05:35.153590+00:00 2021-05-27T19:05:36.801931+00:00 0:00:01.648341 33068 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-27T19:05:33.020096+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-27T18:05:00+00:00 PythonOperator 2021-05-27T19:05:07.534790+00:00 2021-05-27T19:05:10.738958+00:00 0:00:03.204168 33067 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-27T19:05:04.996109+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-05-27T18:00:00+00:00 EmrJobFlowSensor 2021-05-27T19:00:57.197473+00:00 2021-05-27T19:09:59.924790+00:00 0:09:02.727317 33065 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-27T19:00:54.851933+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-27T18:00:00+00:00 EmrJobFlowSensor 2021-05-27T19:00:46.849066+00:00 2021-05-27T19:09:49.517196+00:00 0:09:02.668130 33064 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-27T19:00:44.695062+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-05-27T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-27T19:00:37.017883+00:00 2021-05-27T19:00:38.684460+00:00 0:00:01.666577 33063 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-27T19:00:34.746482+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-27T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-27T19:00:24.764364+00:00 2021-05-27T19:00:26.524831+00:00 0:00:01.760467 33062 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-27T19:00:22.618844+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-05-27T18:00:00+00:00 PythonOperator 2021-05-27T19:00:15.060905+00:00 2021-05-27T19:00:18.305240+00:00 0:00:03.244335 33061 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-27T19:00:12.615401+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-27T18:00:00+00:00 PythonOperator 2021-05-27T19:00:04.882146+00:00 2021-05-27T19:00:08.093856+00:00 0:00:03.211710 33060 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-27T19:00:02.600888+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-27T17:00:00+00:00 EmrJobFlowSensor 2021-05-27T18:25:57.079782+00:00 2021-05-27T18:25:58.546463+00:00 0:00:01.466681 33059 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-27T18:25:54.950319+00:00 3 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-27T17:00:00+00:00 EmrJobFlowSensor 2021-05-27T18:14:34.392930+00:00 2021-05-27T18:24:37.280372+00:00 0:10:02.887442 33058 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-27T18:14:32.087589+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-27T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-27T18:14:12.152774+00:00 2021-05-27T18:14:13.945083+00:00 0:00:01.792309 33056 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-27T18:14:10.013116+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-27T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-27T18:14:00.527821+00:00 2021-05-27T18:14:02.403783+00:00 0:00:01.875962 33055 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-27T18:13:57.976692+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-27T17:00:00+00:00 PythonOperator 2021-05-27T18:13:50.239904+00:00 2021-05-27T18:13:53.653263+00:00 0:00:03.413359 33054 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-27T18:13:47.916430+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-27T17:00:00+00:00 PythonOperator 2021-05-27T18:13:38.610909+00:00 2021-05-27T18:13:41.863055+00:00 0:00:03.252146 33053 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-27T18:13:35.969580+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-27T17:00:00+00:00 TriggerDagRunOperator 2021-05-27T18:13:30.512080+00:00 2021-05-27T18:13:31.007533+00:00 0:00:00.495453 33052 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-27T18:13:27.961640+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-27T17:00:00+00:00 TriggerDagRunOperator 2021-05-27T18:13:30.315043+00:00 2021-05-27T18:13:30.743169+00:00 0:00:00.428126 33051 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-27T18:13:27.961595+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-27T17:05:00+00:00 EmrJobFlowSensor 2021-05-27T18:05:51.331623+00:00 2021-05-27T18:13:53.745029+00:00 0:08:02.413406 33050 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-27T18:05:49.195389+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-27T17:05:00+00:00 EmrCreateJobFlowOperator 2021-05-27T18:05:29.490584+00:00 2021-05-27T18:05:31.211350+00:00 0:00:01.720766 33049 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-27T18:05:27.126334+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-27T17:05:00+00:00 PythonOperator 2021-05-27T18:05:07.168786+00:00 2021-05-27T18:05:10.361683+00:00 0:00:03.192897 33048 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-27T18:05:05.100989+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-27T17:00:00+00:00 EmrJobFlowSensor 2021-05-27T18:03:11.179582+00:00 2021-05-27T18:13:14.069444+00:00 0:10:02.889862 33047 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-27T18:03:08.969695+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-05-27T17:00:00+00:00 EmrJobFlowSensor 2021-05-27T18:02:55.149605+00:00 2021-05-27T18:10:57.574637+00:00 0:08:02.425032 33046 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-27T18:02:52.957149+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-27T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-27T18:02:50.089621+00:00 2021-05-27T18:02:51.945190+00:00 0:00:01.855569 33045 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-27T18:02:47.006929+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-05-27T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-27T18:00:27.782773+00:00 2021-05-27T18:00:29.502475+00:00 0:00:01.719702 33043 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-27T18:00:25.591102+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-27T17:00:00+00:00 PythonOperator 2021-05-27T18:00:21.815959+00:00 2021-05-27T18:00:25.061859+00:00 0:00:03.245900 33042 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-27T18:00:19.646585+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-05-27T17:00:00+00:00 PythonOperator 2021-05-27T18:00:06.014241+00:00 2021-05-27T18:00:09.191505+00:00 0:00:03.177264 33041 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-27T18:00:03.570934+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-27T16:00:00+00:00 EmrJobFlowSensor 2021-05-27T17:12:57.092309+00:00 2021-05-27T17:20:59.436383+00:00 0:08:02.344074 33040 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-27T17:12:54.855280+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-27T16:00:00+00:00 EmrJobFlowSensor 2021-05-27T17:12:53.035554+00:00 2021-05-27T17:21:55.577545+00:00 0:09:02.541991 33039 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-27T17:12:50.843852+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-27T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-27T17:12:34.928513+00:00 2021-05-27T17:12:36.595901+00:00 0:00:01.667388 33038 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-27T17:12:32.722522+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-27T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-27T17:12:31.118851+00:00 2021-05-27T17:12:32.812555+00:00 0:00:01.693704 33037 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-27T17:12:28.785297+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-27T16:00:00+00:00 PythonOperator 2021-05-27T17:12:12.954828+00:00 2021-05-27T17:12:16.201752+00:00 0:00:03.246924 33036 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-27T17:12:10.706149+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-27T16:00:00+00:00 PythonOperator 2021-05-27T17:12:07.119692+00:00 2021-05-27T17:12:10.555723+00:00 0:00:03.436031 33035 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-27T17:12:04.754637+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-27T16:00:00+00:00 TriggerDagRunOperator 2021-05-27T17:11:51.046036+00:00 2021-05-27T17:11:51.558831+00:00 0:00:00.512795 33034 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-27T17:11:48.690992+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-27T16:00:00+00:00 TriggerDagRunOperator 2021-05-27T17:11:50.911379+00:00 2021-05-27T17:11:51.343019+00:00 0:00:00.431640 33033 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-27T17:11:48.690949+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-27T16:05:00+00:00 EmrJobFlowSensor 2021-05-27T17:06:04.086868+00:00 2021-05-27T17:15:06.612667+00:00 0:09:02.525799 33032 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-27T17:06:01.995399+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-27T16:05:00+00:00 EmrCreateJobFlowOperator 2021-05-27T17:05:36.064589+00:00 2021-05-27T17:05:37.692609+00:00 0:00:01.628020 33031 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-27T17:05:33.927021+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-27T16:05:00+00:00 PythonOperator 2021-05-27T17:05:14.088712+00:00 2021-05-27T17:05:17.328903+00:00 0:00:03.240191 33030 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-27T17:05:11.909139+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-05-27T16:00:00+00:00 EmrJobFlowSensor 2021-05-27T17:01:37.880022+00:00 2021-05-27T17:09:40.469083+00:00 0:08:02.589061 33029 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-27T17:01:35.590889+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-27T16:00:00+00:00 EmrJobFlowSensor 2021-05-27T17:01:35.895168+00:00 2021-05-27T17:11:38.620261+00:00 0:10:02.725093 33028 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-27T17:01:33.648672+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-05-27T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-27T17:01:16.082139+00:00 2021-05-27T17:01:17.767556+00:00 0:00:01.685417 33027 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-27T17:01:13.546696+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-27T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-27T17:01:13.725262+00:00 2021-05-27T17:01:15.809264+00:00 0:00:02.084002 33026 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-27T17:01:11.581226+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-05-27T16:00:00+00:00 PythonOperator 2021-05-27T17:00:56.485072+00:00 2021-05-27T17:00:59.892619+00:00 0:00:03.407547 33025 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-27T17:00:53.518924+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-27T16:00:00+00:00 PythonOperator 2021-05-27T17:00:51.727809+00:00 2021-05-27T17:00:55.718060+00:00 0:00:03.990251 33024 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-27T17:00:49.516052+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-27T15:00:00+00:00 EmrJobFlowSensor 2021-05-27T16:11:15.662909+00:00 2021-05-27T16:21:18.405278+00:00 0:10:02.742369 33022 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-27T16:11:13.312997+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-27T15:00:00+00:00 EmrJobFlowSensor 2021-05-27T16:11:00.178510+00:00 2021-05-27T16:20:02.675857+00:00 0:09:02.497347 33021 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-27T16:10:57.350209+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-27T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-27T16:10:53.587613+00:00 2021-05-27T16:10:55.273479+00:00 0:00:01.685866 33020 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-27T16:10:51.297182+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-27T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-27T16:10:39.712974+00:00 2021-05-27T16:10:41.376880+00:00 0:00:01.663906 33019 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-27T16:10:37.361036+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-27T15:00:00+00:00 PythonOperator 2021-05-27T16:10:33.460011+00:00 2021-05-27T16:10:36.726654+00:00 0:00:03.266643 33018 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-27T16:10:31.272447+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-27T15:00:00+00:00 PythonOperator 2021-05-27T16:10:17.824938+00:00 2021-05-27T16:10:21.276907+00:00 0:00:03.451969 33017 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-27T16:10:15.258925+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-27T15:00:00+00:00 TriggerDagRunOperator 2021-05-27T16:10:09.638291+00:00 2021-05-27T16:10:10.138997+00:00 0:00:00.500706 33016 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-27T16:10:07.191905+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-27T15:00:00+00:00 TriggerDagRunOperator 2021-05-27T16:10:09.540084+00:00 2021-05-27T16:10:09.943647+00:00 0:00:00.403563 33015 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-27T16:10:07.191874+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-27T15:05:00+00:00 EmrJobFlowSensor 2021-05-27T16:06:00.837885+00:00 2021-05-27T16:14:03.260447+00:00 0:08:02.422562 33014 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-27T16:05:58.667605+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-27T15:05:00+00:00 EmrCreateJobFlowOperator 2021-05-27T16:05:38.947067+00:00 2021-05-27T16:05:40.682909+00:00 0:00:01.735842 33013 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-27T16:05:36.586846+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-27T15:05:00+00:00 PythonOperator 2021-05-27T16:05:16.810481+00:00 2021-05-27T16:05:20.000224+00:00 0:00:03.189743 33012 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-27T16:05:14.510994+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-05-27T15:00:00+00:00 EmrJobFlowSensor 2021-05-27T16:01:06.293254+00:00 2021-05-27T16:11:09.053995+00:00 0:10:02.760741 33011 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-27T16:01:04.177360+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-27T15:00:00+00:00 EmrJobFlowSensor 2021-05-27T16:00:46.543650+00:00 2021-05-27T16:09:49.085285+00:00 0:09:02.541635 33010 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-27T16:00:44.253743+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-05-27T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-27T16:00:42.341165+00:00 2021-05-27T16:00:43.995712+00:00 0:00:01.654547 33009 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-27T16:00:40.154657+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-27T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-27T16:00:26.903647+00:00 2021-05-27T16:00:28.618979+00:00 0:00:01.715332 33008 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-27T16:00:24.124523+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-05-27T15:00:00+00:00 PythonOperator 2021-05-27T16:00:22.253557+00:00 2021-05-27T16:00:26.033768+00:00 0:00:03.780211 33007 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-27T16:00:20.122149+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-27T15:00:00+00:00 PythonOperator 2021-05-27T16:00:04.370998+00:00 2021-05-27T16:00:07.658239+00:00 0:00:03.287241 33006 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-27T16:00:02.102652+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-27T14:00:00+00:00 EmrJobFlowSensor 2021-05-27T15:11:20.962715+00:00 2021-05-27T15:20:23.532547+00:00 0:09:02.569832 33004 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-27T15:11:18.834131+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-27T14:00:00+00:00 EmrJobFlowSensor 2021-05-27T15:11:05.220209+00:00 2021-05-27T15:20:07.990986+00:00 0:09:02.770777 33003 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-27T15:11:02.877381+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-27T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-27T15:10:59.120433+00:00 2021-05-27T15:11:00.831798+00:00 0:00:01.711365 33002 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-27T15:10:56.873532+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-27T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-27T15:10:43.503002+00:00 2021-05-27T15:10:45.365270+00:00 0:00:01.862268 33001 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-27T15:10:41.072047+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-27T14:00:00+00:00 PythonOperator 2021-05-27T15:10:37.181056+00:00 2021-05-27T15:10:40.406815+00:00 0:00:03.225759 33000 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-27T15:10:34.862553+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-27T14:00:00+00:00 PythonOperator 2021-05-27T15:10:20.982416+00:00 2021-05-27T15:10:24.542804+00:00 0:00:03.560388 32999 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-27T15:10:18.784824+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-27T14:00:00+00:00 TriggerDagRunOperator 2021-05-27T15:10:13.897883+00:00 2021-05-27T15:10:14.505089+00:00 0:00:00.607206 32998 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-27T15:10:10.764559+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-27T14:00:00+00:00 TriggerDagRunOperator 2021-05-27T15:10:13.280867+00:00 2021-05-27T15:10:13.808620+00:00 0:00:00.527753 32997 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-27T15:10:10.764589+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-27T14:05:00+00:00 EmrJobFlowSensor 2021-05-27T15:05:46.632904+00:00 2021-05-27T15:14:49.280574+00:00 0:09:02.647670 32996 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-27T15:05:44.438004+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-27T14:05:00+00:00 EmrCreateJobFlowOperator 2021-05-27T15:05:24.816301+00:00 2021-05-27T15:05:26.527687+00:00 0:00:01.711386 32995 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-27T15:05:22.471131+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-27T14:05:00+00:00 PythonOperator 2021-05-27T15:05:04.952389+00:00 2021-05-27T15:05:07.848639+00:00 0:00:02.896250 32994 airflow-worker-2.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-27T15:05:02.443718+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-27T14:00:00+00:00 EmrJobFlowSensor 2021-05-27T15:01:04.612540+00:00 2021-05-27T15:10:07.281173+00:00 0:09:02.668633 32993 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-27T15:01:02.173050+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-05-27T14:00:00+00:00 EmrJobFlowSensor 2021-05-27T15:00:54.492581+00:00 2021-05-27T15:09:57.137779+00:00 0:09:02.645198 32992 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-27T15:00:52.091077+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-27T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-27T15:00:44.391768+00:00 2021-05-27T15:00:46.083616+00:00 0:00:01.691848 32991 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-27T15:00:42.088012+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-05-27T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-27T15:00:34.358239+00:00 2021-05-27T15:00:36.174343+00:00 0:00:01.816104 32990 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-27T15:00:32.030198+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-27T14:00:00+00:00 PythonOperator 2021-05-27T15:00:22.196418+00:00 2021-05-27T15:00:25.450982+00:00 0:00:03.254564 32989 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-27T15:00:20.062892+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-05-27T14:00:00+00:00 PythonOperator 2021-05-27T15:00:12.341123+00:00 2021-05-27T15:00:15.497083+00:00 0:00:03.155960 32988 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-27T15:00:10.013529+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-27T13:00:00+00:00 EmrJobFlowSensor 2021-05-27T14:12:32.029410+00:00 2021-05-27T14:21:34.707570+00:00 0:09:02.678160 32986 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-27T14:12:29.352662+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-27T13:00:00+00:00 EmrJobFlowSensor 2021-05-27T14:12:25.602952+00:00 2021-05-27T14:20:28.124126+00:00 0:08:02.521174 32985 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-27T14:12:23.293340+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-27T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-27T14:12:09.700824+00:00 2021-05-27T14:12:11.504745+00:00 0:00:01.803921 32984 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-27T14:12:07.248263+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-27T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-27T14:12:05.513342+00:00 2021-05-27T14:12:07.322144+00:00 0:00:01.808802 32983 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-27T14:12:03.242741+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-27T13:00:00+00:00 PythonOperator 2021-05-27T14:11:49.404476+00:00 2021-05-27T14:11:52.970565+00:00 0:00:03.566089 32982 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-27T14:11:47.225117+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-27T13:00:00+00:00 PythonOperator 2021-05-27T14:11:43.458184+00:00 2021-05-27T14:11:46.656631+00:00 0:00:03.198447 32981 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-27T14:11:41.219558+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-27T13:00:00+00:00 TriggerDagRunOperator 2021-05-27T14:11:29.976970+00:00 2021-05-27T14:11:30.507806+00:00 0:00:00.530836 32980 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-27T14:11:27.206672+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-27T13:00:00+00:00 TriggerDagRunOperator 2021-05-27T14:11:29.505264+00:00 2021-05-27T14:11:29.932429+00:00 0:00:00.427165 32979 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-27T14:11:27.206722+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-27T13:05:00+00:00 EmrJobFlowSensor 2021-05-27T14:06:05.126894+00:00 2021-05-27T14:15:07.771811+00:00 0:09:02.644917 32978 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-27T14:06:02.832393+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-27T13:05:00+00:00 EmrCreateJobFlowOperator 2021-05-27T14:05:35.054386+00:00 2021-05-27T14:05:36.663628+00:00 0:00:01.609242 32977 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-27T14:05:32.851343+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-27T13:05:00+00:00 PythonOperator 2021-05-27T14:05:12.975296+00:00 2021-05-27T14:05:16.195628+00:00 0:00:03.220332 32976 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-27T14:05:10.783065+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-27T13:00:00+00:00 EmrJobFlowSensor 2021-05-27T14:01:04.621477+00:00 2021-05-27T14:11:07.340312+00:00 0:10:02.718835 32975 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-27T14:01:02.415927+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-05-27T13:00:00+00:00 EmrJobFlowSensor 2021-05-27T14:01:02.693639+00:00 2021-05-27T14:10:05.382310+00:00 0:09:02.688671 32974 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-27T14:01:00.414977+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-27T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-27T14:00:43.236795+00:00 2021-05-27T14:00:44.916372+00:00 0:00:01.679577 32973 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-27T14:00:40.396467+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-05-27T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-27T14:00:40.830649+00:00 2021-05-27T14:00:42.924320+00:00 0:00:02.093671 32972 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-27T14:00:38.400299+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-27T13:00:00+00:00 PythonOperator 2021-05-27T14:00:20.635505+00:00 2021-05-27T14:00:23.877770+00:00 0:00:03.242265 32971 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-27T14:00:18.393469+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-05-27T13:00:00+00:00 PythonOperator 2021-05-27T14:00:19.331297+00:00 2021-05-27T14:00:22.552766+00:00 0:00:03.221469 32970 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-27T14:00:16.365333+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-27T12:00:00+00:00 EmrJobFlowSensor 2021-05-27T13:10:20.101256+00:00 2021-05-27T13:19:22.750631+00:00 0:09:02.649375 32968 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-27T13:10:17.879317+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-27T12:00:00+00:00 EmrJobFlowSensor 2021-05-27T13:10:08.227171+00:00 2021-05-27T13:19:10.819381+00:00 0:09:02.592210 32967 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-27T13:10:05.874643+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-27T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-27T13:10:00.395274+00:00 2021-05-27T13:10:02.301886+00:00 0:00:01.906612 32966 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-27T13:09:57.758298+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-27T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-27T13:09:46.454991+00:00 2021-05-27T13:09:48.117427+00:00 0:00:01.662436 32965 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-27T13:09:43.591176+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-27T12:00:00+00:00 PythonOperator 2021-05-27T13:09:37.894320+00:00 2021-05-27T13:09:41.100518+00:00 0:00:03.206198 32964 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-27T13:09:35.592618+00:00 2 default_pool