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-12T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T09:00:56.144038+00:00 2021-04-12T09:00:57.826519+00:00 0:00:01.682481 16306 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T09:00:53.803272+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T08:00:00+00:00 PythonOperator 2021-04-12T09:00:34.270020+00:00 2021-04-12T09:00:37.207050+00:00 0:00:02.937030 16305 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T09:00:31.852885+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-12T07:00:00+00:00 EmrJobFlowSensor 2021-04-12T08:12:09.560877+00:00 2021-04-12T08:30:13.334929+00:00 0:18:03.774052 16304 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T08:12:06.605818+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-12T07:00:00+00:00 EmrJobFlowSensor 2021-04-12T08:12:06.849609+00:00 2021-04-12T08:22:10.054526+00:00 0:10:03.204917 16303 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T08:12:04.666869+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-12T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T08:11:47.393561+00:00 2021-04-12T08:11:49.128884+00:00 0:00:01.735323 16302 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T08:11:44.654738+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-12T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T08:11:45.164601+00:00 2021-04-12T08:11:47.218088+00:00 0:00:02.053487 16301 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T08:11:42.655184+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-12T07:00:00+00:00 PythonOperator 2021-04-12T08:11:27.286984+00:00 2021-04-12T08:11:29.982992+00:00 0:00:02.696008 16300 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T08:11:24.587367+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-12T07:00:00+00:00 PythonOperator 2021-04-12T08:11:23.399727+00:00 2021-04-12T08:11:26.938176+00:00 0:00:03.538449 16299 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T08:11:20.570227+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T07:00:00+00:00 TriggerDagRunOperator 2021-04-12T08:11:09.302844+00:00 2021-04-12T08:11:09.807151+00:00 0:00:00.504307 16298 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T08:11:06.495436+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T07:00:00+00:00 TriggerDagRunOperator 2021-04-12T08:11:09.055266+00:00 2021-04-12T08:11:09.467584+00:00 0:00:00.412318 16297 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T08:11:06.495463+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-12T07:05:00+00:00 EmrJobFlowSensor 2021-04-12T08:05:56.607462+00:00 2021-04-12T08:14:59.381659+00:00 0:09:02.774197 16295 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T08:05:54.359570+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-12T07:05:00+00:00 EmrCreateJobFlowOperator 2021-04-12T08:05:34.730276+00:00 2021-04-12T08:05:36.471992+00:00 0:00:01.741716 16294 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T08:05:32.336191+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-12T07:05:00+00:00 PythonOperator 2021-04-12T08:05:12.610973+00:00 2021-04-12T08:05:15.354704+00:00 0:00:02.743731 16293 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T08:05:10.371889+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T07:00:00+00:00 EmrJobFlowSensor 2021-04-12T08:00:46.203963+00:00 2021-04-12T08:10:48.995373+00:00 0:10:02.791410 16292 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T08:00:43.877027+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T08:00:26.119037+00:00 2021-04-12T08:00:27.804472+00:00 0:00:01.685435 16291 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T08:00:23.863687+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T07:00:00+00:00 PythonOperator 2021-04-12T08:00:04.087806+00:00 2021-04-12T08:00:06.936356+00:00 0:00:02.848550 16290 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T08:00:01.735308+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-12T06:00:00+00:00 EmrJobFlowSensor 2021-04-12T07:12:27.530557+00:00 2021-04-12T07:22:30.246457+00:00 0:10:02.715900 16289 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T07:12:25.240921+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-12T06:00:00+00:00 EmrJobFlowSensor 2021-04-12T07:12:23.730608+00:00 2021-04-12T07:21:26.358450+00:00 0:09:02.627842 16288 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T07:12:21.180322+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-12T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T07:12:05.595357+00:00 2021-04-12T07:12:07.320932+00:00 0:00:01.725575 16287 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T07:12:03.156619+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-12T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T07:12:01.479303+00:00 2021-04-12T07:12:03.306421+00:00 0:00:01.827118 16286 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T07:11:59.166290+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-12T06:00:00+00:00 PythonOperator 2021-04-12T07:11:43.356428+00:00 2021-04-12T07:11:46.508371+00:00 0:00:03.151943 16285 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T07:11:41.085818+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-12T06:00:00+00:00 PythonOperator 2021-04-12T07:11:41.307879+00:00 2021-04-12T07:11:44.094287+00:00 0:00:02.786408 16284 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T07:11:39.084117+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T06:00:00+00:00 TriggerDagRunOperator 2021-04-12T07:11:28.018687+00:00 2021-04-12T07:11:28.558904+00:00 0:00:00.540217 16283 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T07:11:25.027613+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T06:00:00+00:00 TriggerDagRunOperator 2021-04-12T07:11:27.739034+00:00 2021-04-12T07:11:28.207296+00:00 0:00:00.468262 16282 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T07:11:25.027585+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-12T06:05:00+00:00 EmrJobFlowSensor 2021-04-12T07:06:04.025842+00:00 2021-04-12T07:15:06.681338+00:00 0:09:02.655496 16280 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T07:06:01.812278+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-12T06:05:00+00:00 EmrCreateJobFlowOperator 2021-04-12T07:05:41.918899+00:00 2021-04-12T07:05:43.559131+00:00 0:00:01.640232 16279 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T07:05:39.793718+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-12T06:05:00+00:00 PythonOperator 2021-04-12T07:05:15.955844+00:00 2021-04-12T07:05:18.604709+00:00 0:00:02.648865 16278 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T07:05:13.752013+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T06:00:00+00:00 EmrJobFlowSensor 2021-04-12T07:01:07.272402+00:00 2021-04-12T07:11:09.996582+00:00 0:10:02.724180 16277 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T07:01:05.017257+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T07:00:45.521731+00:00 2021-04-12T07:00:47.237995+00:00 0:00:01.716264 16276 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T07:00:42.995760+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T06:00:00+00:00 PythonOperator 2021-04-12T07:00:23.279793+00:00 2021-04-12T07:00:26.175024+00:00 0:00:02.895231 16275 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T07:00:20.922280+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-12T05:00:00+00:00 EmrJobFlowSensor 2021-04-12T06:10:08.404735+00:00 2021-04-12T06:18:10.840406+00:00 0:08:02.435671 16274 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T06:10:06.155411+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-12T05:00:00+00:00 EmrJobFlowSensor 2021-04-12T06:09:58.582182+00:00 2021-04-12T06:20:01.407414+00:00 0:10:02.825232 16273 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T06:09:56.080744+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-12T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T06:09:48.422150+00:00 2021-04-12T06:09:50.180057+00:00 0:00:01.757907 16272 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T06:09:46.071045+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-12T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T06:09:38.491934+00:00 2021-04-12T06:09:40.296714+00:00 0:00:01.804780 16271 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T06:09:36.046834+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-12T05:00:00+00:00 PythonOperator 2021-04-12T06:09:26.392695+00:00 2021-04-12T06:09:29.103211+00:00 0:00:02.710516 16270 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T06:09:24.061981+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-12T05:00:00+00:00 PythonOperator 2021-04-12T06:09:16.434895+00:00 2021-04-12T06:09:19.444938+00:00 0:00:03.010043 16269 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T06:09:14.056020+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T05:00:00+00:00 TriggerDagRunOperator 2021-04-12T06:09:10.374984+00:00 2021-04-12T06:09:10.949575+00:00 0:00:00.574591 16268 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T06:09:07.950204+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T05:00:00+00:00 TriggerDagRunOperator 2021-04-12T06:09:10.169923+00:00 2021-04-12T06:09:10.595335+00:00 0:00:00.425412 16267 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T06:09:07.950238+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-12T05:05:00+00:00 EmrJobFlowSensor 2021-04-12T06:08:08.112960+00:00 2021-04-12T06:17:10.603327+00:00 0:09:02.490367 16266 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T06:08:05.890851+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-12T05:05:00+00:00 EmrCreateJobFlowOperator 2021-04-12T06:07:42.035030+00:00 2021-04-12T06:07:43.763434+00:00 0:00:01.728404 16265 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T06:07:39.866985+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-12T05:05:00+00:00 PythonOperator 2021-04-12T06:07:22.245951+00:00 2021-04-12T06:07:25.127667+00:00 0:00:02.881716 16264 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T06:07:19.846843+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T05:00:00+00:00 EmrJobFlowSensor 2021-04-12T06:00:58.416856+00:00 2021-04-12T06:09:00.887035+00:00 0:08:02.470179 16262 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T06:00:56.059289+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T06:00:38.781749+00:00 2021-04-12T06:00:40.630007+00:00 0:00:01.848258 16261 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T06:00:36.044439+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T05:00:00+00:00 PythonOperator 2021-04-12T06:00:16.400456+00:00 2021-04-12T06:00:19.106973+00:00 0:00:02.706517 16260 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T06:00:14.081162+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-12T04:00:00+00:00 EmrJobFlowSensor 2021-04-12T05:12:01.745198+00:00 2021-04-12T05:21:04.369911+00:00 0:09:02.624713 16259 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T05:11:59.510013+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-12T04:00:00+00:00 EmrJobFlowSensor 2021-04-12T05:11:57.633302+00:00 2021-04-12T05:21:00.246742+00:00 0:09:02.613440 16258 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T05:11:55.510465+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-12T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T05:11:40.038081+00:00 2021-04-12T05:11:41.838582+00:00 0:00:01.800501 16257 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T05:11:37.498226+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-12T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T05:11:35.893418+00:00 2021-04-12T05:11:37.761061+00:00 0:00:01.867643 16256 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T05:11:33.546310+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-12T04:00:00+00:00 PythonOperator 2021-04-12T05:11:18.769731+00:00 2021-04-12T05:11:22.282177+00:00 0:00:03.512446 16255 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T05:11:15.403829+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-12T04:00:00+00:00 PythonOperator 2021-04-12T05:11:16.303945+00:00 2021-04-12T05:11:19.322943+00:00 0:00:03.018998 16254 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T05:11:13.473198+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T04:00:00+00:00 TriggerDagRunOperator 2021-04-12T05:11:07.699189+00:00 2021-04-12T05:11:08.268647+00:00 0:00:00.569458 16253 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T05:11:05.391475+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T04:00:00+00:00 TriggerDagRunOperator 2021-04-12T05:11:07.631499+00:00 2021-04-12T05:11:08.102382+00:00 0:00:00.470883 16252 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T05:11:05.391444+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-12T04:05:00+00:00 EmrJobFlowSensor 2021-04-12T05:05:53.338203+00:00 2021-04-12T05:13:55.750287+00:00 0:08:02.412084 16251 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T05:05:50.926848+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-12T04:05:00+00:00 EmrCreateJobFlowOperator 2021-04-12T05:05:31.285385+00:00 2021-04-12T05:05:33.016287+00:00 0:00:01.730902 16250 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T05:05:28.974205+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-12T04:05:00+00:00 PythonOperator 2021-04-12T05:05:09.623006+00:00 2021-04-12T05:05:12.329451+00:00 0:00:02.706445 16249 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T05:05:06.968029+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T04:00:00+00:00 EmrJobFlowSensor 2021-04-12T05:00:50.824929+00:00 2021-04-12T05:10:53.706300+00:00 0:10:02.881371 16247 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T05:00:48.625904+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T05:00:31.286383+00:00 2021-04-12T05:00:33.102904+00:00 0:00:01.816521 16246 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T05:00:28.753672+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T04:00:00+00:00 PythonOperator 2021-04-12T05:00:08.751782+00:00 2021-04-12T05:00:11.500707+00:00 0:00:02.748925 16245 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T05:00:06.535969+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-12T03:00:00+00:00 EmrJobFlowSensor 2021-04-12T04:12:33.980581+00:00 2021-04-12T04:21:36.602029+00:00 0:09:02.621448 16244 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T04:12:31.650094+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-12T03:00:00+00:00 EmrJobFlowSensor 2021-04-12T04:12:18.153829+00:00 2021-04-12T04:21:20.793743+00:00 0:09:02.639914 16243 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T04:12:15.662698+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-12T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T04:12:11.906620+00:00 2021-04-12T04:12:13.649646+00:00 0:00:01.743026 16242 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T04:12:09.643795+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-12T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T04:11:58.002541+00:00 2021-04-12T04:11:59.634803+00:00 0:00:01.632262 16241 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T04:11:55.557117+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-12T03:00:00+00:00 PythonOperator 2021-04-12T04:11:49.798730+00:00 2021-04-12T04:11:52.729811+00:00 0:00:02.931081 16240 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T04:11:47.550149+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-12T03:00:00+00:00 PythonOperator 2021-04-12T04:11:35.897653+00:00 2021-04-12T04:11:38.825974+00:00 0:00:02.928321 16239 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T04:11:33.534985+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T03:00:00+00:00 TriggerDagRunOperator 2021-04-12T04:11:26.273431+00:00 2021-04-12T04:11:26.861185+00:00 0:00:00.587754 16238 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T04:11:23.677021+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T03:00:00+00:00 TriggerDagRunOperator 2021-04-12T04:11:26.110339+00:00 2021-04-12T04:11:26.550617+00:00 0:00:00.440278 16237 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T04:11:23.677057+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-12T03:05:00+00:00 EmrJobFlowSensor 2021-04-12T04:06:05.271606+00:00 2021-04-12T04:15:07.767816+00:00 0:09:02.496210 16236 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T04:06:03.066097+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-12T03:05:00+00:00 EmrCreateJobFlowOperator 2021-04-12T04:05:45.270333+00:00 2021-04-12T04:05:47.009452+00:00 0:00:01.739119 16235 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T04:05:43.050179+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-12T03:05:00+00:00 PythonOperator 2021-04-12T04:05:23.818460+00:00 2021-04-12T04:05:26.965217+00:00 0:00:03.146757 16234 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T04:05:21.030825+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T03:00:00+00:00 EmrJobFlowSensor 2021-04-12T04:01:05.328866+00:00 2021-04-12T04:11:08.095948+00:00 0:10:02.767082 16232 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T04:01:03.040461+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T04:00:41.791404+00:00 2021-04-12T04:00:43.518074+00:00 0:00:01.726670 16231 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T04:00:39.005236+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T03:00:00+00:00 PythonOperator 2021-04-12T04:00:21.159254+00:00 2021-04-12T04:00:23.953687+00:00 0:00:02.794433 16230 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T04:00:18.990777+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-12T02:00:00+00:00 EmrJobFlowSensor 2021-04-12T03:11:26.397064+00:00 2021-04-12T03:21:29.152228+00:00 0:10:02.755164 16229 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T03:11:24.051402+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-12T02:00:00+00:00 EmrJobFlowSensor 2021-04-12T03:11:22.244830+00:00 2021-04-12T03:22:25.385204+00:00 0:11:03.140374 16228 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T03:11:19.952896+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-12T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T03:11:04.289022+00:00 2021-04-12T03:11:06.191278+00:00 0:00:01.902256 16227 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T03:11:01.916987+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-12T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T03:11:00.401981+00:00 2021-04-12T03:11:02.334636+00:00 0:00:01.932655 16226 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T03:10:58.051665+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-12T02:00:00+00:00 PythonOperator 2021-04-12T03:10:42.477136+00:00 2021-04-12T03:10:45.225365+00:00 0:00:02.748229 16225 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T03:10:39.865472+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-12T02:00:00+00:00 PythonOperator 2021-04-12T03:10:38.626834+00:00 2021-04-12T03:10:42.111174+00:00 0:00:03.484340 16224 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T03:10:35.946675+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T02:00:00+00:00 TriggerDagRunOperator 2021-04-12T03:10:18.521337+00:00 2021-04-12T03:10:19.043496+00:00 0:00:00.522159 16223 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T03:10:15.893970+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T02:00:00+00:00 TriggerDagRunOperator 2021-04-12T03:10:18.305204+00:00 2021-04-12T03:10:18.714437+00:00 0:00:00.409233 16222 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T03:10:15.894019+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-12T02:05:00+00:00 EmrJobFlowSensor 2021-04-12T03:06:03.799274+00:00 2021-04-12T03:15:06.484086+00:00 0:09:02.684812 16221 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T03:06:01.452853+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-12T02:05:00+00:00 EmrCreateJobFlowOperator 2021-04-12T03:05:42.139654+00:00 2021-04-12T03:05:43.786525+00:00 0:00:01.646871 16220 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T03:05:39.385029+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-12T02:05:00+00:00 PythonOperator 2021-04-12T03:05:21.590029+00:00 2021-04-12T03:05:24.246382+00:00 0:00:02.656353 16219 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T03:05:19.315033+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T02:00:00+00:00 EmrJobFlowSensor 2021-04-12T03:00:52.230170+00:00 2021-04-12T03:09:55.136202+00:00 0:09:02.906032 16217 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T03:00:49.938361+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T03:00:30.378617+00:00 2021-04-12T03:00:32.102989+00:00 0:00:01.724372 16216 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T03:00:28.041204+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T02:00:00+00:00 PythonOperator 2021-04-12T03:00:10.177768+00:00 2021-04-12T03:00:13.015208+00:00 0:00:02.837440 16215 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T03:00:07.903288+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-12T01:00:00+00:00 EmrJobFlowSensor 2021-04-12T02:12:21.616395+00:00 2021-04-12T02:22:24.385530+00:00 0:10:02.769135 16214 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T02:12:19.311064+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-12T01:00:00+00:00 EmrJobFlowSensor 2021-04-12T02:12:07.777009+00:00 2021-04-12T02:22:10.920507+00:00 0:10:03.143498 16213 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T02:12:05.357164+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-12T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T02:11:59.939708+00:00 2021-04-12T02:12:01.624328+00:00 0:00:01.684620 16212 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T02:11:57.359366+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-12T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T02:11:47.895393+00:00 2021-04-12T02:11:49.553594+00:00 0:00:01.658201 16211 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T02:11:45.340833+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-12T01:00:00+00:00 PythonOperator 2021-04-12T02:11:39.671684+00:00 2021-04-12T02:11:42.405173+00:00 0:00:02.733489 16210 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T02:11:37.266257+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-12T01:00:00+00:00 PythonOperator 2021-04-12T02:11:25.947846+00:00 2021-04-12T02:11:29.248064+00:00 0:00:03.300218 16209 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T02:11:23.269198+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T01:00:00+00:00 TriggerDagRunOperator 2021-04-12T02:11:17.712256+00:00 2021-04-12T02:11:18.305123+00:00 0:00:00.592867 16208 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T02:11:15.200184+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T01:00:00+00:00 TriggerDagRunOperator 2021-04-12T02:11:17.284065+00:00 2021-04-12T02:11:17.708417+00:00 0:00:00.424352 16207 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T02:11:15.200212+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-12T01:05:00+00:00 EmrJobFlowSensor 2021-04-12T02:06:04.756973+00:00 2021-04-12T02:14:07.396851+00:00 0:08:02.639878 16206 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T02:06:02.423324+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-12T01:05:00+00:00 EmrCreateJobFlowOperator 2021-04-12T02:05:40.775521+00:00 2021-04-12T02:05:42.512859+00:00 0:00:01.737338 16205 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T02:05:38.471837+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-12T01:05:00+00:00 PythonOperator 2021-04-12T02:05:20.765017+00:00 2021-04-12T02:05:23.662661+00:00 0:00:02.897644 16204 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T02:05:18.460517+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T01:00:00+00:00 EmrJobFlowSensor 2021-04-12T02:02:10.402649+00:00 2021-04-12T02:11:13.133111+00:00 0:09:02.730462 16203 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T02:02:08.037581+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T02:01:50.776039+00:00 2021-04-12T02:01:52.505304+00:00 0:00:01.729265 16202 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T02:01:48.017044+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T01:00:00+00:00 PythonOperator 2021-04-12T02:01:28.470223+00:00 2021-04-12T02:01:31.515230+00:00 0:00:03.045007 16201 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T02:01:25.998480+00:00 2 default_pool