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-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
success booking-processing-job_v002 check_cluster_status 2021-04-12T00:00:00+00:00 EmrJobFlowSensor 2021-04-12T01:12:20.389175+00:00 2021-04-12T01:22:23.264907+00:00 0:10:02.875732 16199 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T01:12:18.065772+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-12T00:00:00+00:00 EmrJobFlowSensor 2021-04-12T01:12:10.715443+00:00 2021-04-12T01:22:13.515401+00:00 0:10:02.799958 16198 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T01:12:08.081570+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-12T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T01:12:00.893191+00:00 2021-04-12T01:12:02.612508+00:00 0:00:01.719317 16197 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T01:11:58.057632+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-12T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T01:11:48.348053+00:00 2021-04-12T01:11:50.050188+00:00 0:00:01.702135 16196 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T01:11:45.968468+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-12T00:00:00+00:00 PythonOperator 2021-04-12T01:11:38.313832+00:00 2021-04-12T01:11:41.483995+00:00 0:00:03.170163 16195 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T01:11:35.953771+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-12T00:00:00+00:00 PythonOperator 2021-04-12T01:11:28.442886+00:00 2021-04-12T01:11:31.425935+00:00 0:00:02.983049 16194 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T01:11:25.953867+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T00:00:00+00:00 TriggerDagRunOperator 2021-04-12T01:11:18.575349+00:00 2021-04-12T01:11:19.005061+00:00 0:00:00.429712 16193 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T01:11:15.836739+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T00:00:00+00:00 TriggerDagRunOperator 2021-04-12T01:11:18.288265+00:00 2021-04-12T01:11:18.940293+00:00 0:00:00.652028 16192 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T01:11:15.836712+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-12T00:05:00+00:00 EmrJobFlowSensor 2021-04-12T01:05:49.683783+00:00 2021-04-12T01:14:52.127035+00:00 0:09:02.443252 16191 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T01:05:47.346683+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-12T00:05:00+00:00 EmrCreateJobFlowOperator 2021-04-12T01:05:29.381426+00:00 2021-04-12T01:05:31.004468+00:00 0:00:01.623042 16190 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T01:05:27.286523+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-12T00:05:00+00:00 PythonOperator 2021-04-12T01:05:07.494110+00:00 2021-04-12T01:05:10.159751+00:00 0:00:02.665641 16189 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T01:05:05.218465+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T00:00:00+00:00 EmrJobFlowSensor 2021-04-12T01:01:05.144114+00:00 2021-04-12T01:11:07.937866+00:00 0:10:02.793752 16188 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T01:01:02.791125+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T01:00:43.032380+00:00 2021-04-12T01:00:44.731325+00:00 0:00:01.698945 16187 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T01:00:40.765276+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T00:00:00+00:00 PythonOperator 2021-04-12T01:00:23.250466+00:00 2021-04-12T01:00:26.411969+00:00 0:00:03.161503 16186 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T01:00:20.748724+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-11T23:00:00+00:00 EmrJobFlowSensor 2021-04-12T00:12:12.883086+00:00 2021-04-12T00:21:15.585869+00:00 0:09:02.702783 16184 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T00:12:10.461338+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-11T23:00:00+00:00 EmrJobFlowSensor 2021-04-12T00:12:10.687089+00:00 2021-04-12T00:22:13.488846+00:00 0:10:02.801757 16183 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T00:12:08.461954+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-11T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T00:11:50.855505+00:00 2021-04-12T00:11:52.553984+00:00 0:00:01.698479 16182 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T00:11:48.323260+00:00 2 default_pool