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_emr_steps 2021-04-15T05:00:00+00:00 PythonOperator 2021-04-15T06:00:17.281244+00:00 2021-04-15T06:00:20.235570+00:00 0:00:02.954326 17356 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-15T06:00:14.919086+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-15T04:00:00+00:00 EmrJobFlowSensor 2021-04-15T05:19:41.062984+00:00 2021-04-15T05:28:43.623619+00:00 0:09:02.560635 17354 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T05:19:38.440729+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-15T04:00:00+00:00 EmrJobFlowSensor 2021-04-15T05:19:30.739486+00:00 2021-04-15T05:27:33.842007+00:00 0:08:03.102521 17353 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T05:19:28.169340+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-15T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T05:19:18.389332+00:00 2021-04-15T05:19:20.086513+00:00 0:00:01.697181 17352 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T05:19:16.054467+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-15T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T05:19:10.594596+00:00 2021-04-15T05:19:12.403900+00:00 0:00:01.809304 17351 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T05:19:08.053147+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-15T04:00:00+00:00 PythonOperator 2021-04-15T05:18:56.192931+00:00 2021-04-15T05:18:59.526415+00:00 0:00:03.333484 17350 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T05:18:53.905103+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-15T04:00:00+00:00 PythonOperator 2021-04-15T05:18:48.145987+00:00 2021-04-15T05:18:51.063997+00:00 0:00:02.918010 17349 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T05:18:45.903731+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-15T04:00:00+00:00 TriggerDagRunOperator 2021-04-15T05:18:34.222306+00:00 2021-04-15T05:18:34.772676+00:00 0:00:00.550370 17348 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T05:18:31.884423+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-15T04:00:00+00:00 TriggerDagRunOperator 2021-04-15T05:18:34.188894+00:00 2021-04-15T05:18:34.580476+00:00 0:00:00.391582 17347 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T05:18:31.884395+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-15T04:05:00+00:00 EmrJobFlowSensor 2021-04-15T05:05:59.023485+00:00 2021-04-15T05:15:01.635409+00:00 0:09:02.611924 17346 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T05:05:56.565649+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-15T04:05:00+00:00 EmrCreateJobFlowOperator 2021-04-15T05:05:36.658496+00:00 2021-04-15T05:05:38.283675+00:00 0:00:01.625179 17345 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T05:05:34.510188+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-15T04:05:00+00:00 PythonOperator 2021-04-15T05:05:17.032611+00:00 2021-04-15T05:05:20.053635+00:00 0:00:03.021024 17344 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T05:05:14.496141+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-15T04:00:00+00:00 EmrJobFlowSensor 2021-04-15T05:01:08.236131+00:00 2021-04-15T05:18:11.875359+00:00 0:17:03.639228 17343 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T05:01:06.037487+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-15T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T05:00:46.540021+00:00 2021-04-15T05:00:48.349716+00:00 0:00:01.809695 17342 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-15T05:00:44.082465+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-15T04:00:00+00:00 PythonOperator 2021-04-15T05:00:24.469823+00:00 2021-04-15T05:00:27.434082+00:00 0:00:02.964259 17341 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-15T05:00:21.995975+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-15T03:00:00+00:00 EmrJobFlowSensor 2021-04-15T04:11:04.866368+00:00 2021-04-15T04:19:07.460073+00:00 0:08:02.593705 17339 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T04:11:02.473657+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-15T03:00:00+00:00 EmrJobFlowSensor 2021-04-15T04:10:50.711051+00:00 2021-04-15T04:19:53.263070+00:00 0:09:02.552019 17338 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T04:10:48.447449+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-15T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T04:10:43.208744+00:00 2021-04-15T04:10:44.839587+00:00 0:00:01.630843 17337 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T04:10:40.463178+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-15T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T04:10:30.977784+00:00 2021-04-15T04:10:32.665860+00:00 0:00:01.688076 17336 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T04:10:28.452864+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-15T03:00:00+00:00 PythonOperator 2021-04-15T04:10:20.592317+00:00 2021-04-15T04:10:23.494772+00:00 0:00:02.902455 17335 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T04:10:18.383318+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-15T03:00:00+00:00 PythonOperator 2021-04-15T04:10:08.708417+00:00 2021-04-15T04:10:11.873336+00:00 0:00:03.164919 17334 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T04:10:06.371317+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-15T03:00:00+00:00 TriggerDagRunOperator 2021-04-15T04:10:02.602277+00:00 2021-04-15T04:10:03.086423+00:00 0:00:00.484146 17333 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T04:10:00.366258+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-15T03:00:00+00:00 TriggerDagRunOperator 2021-04-15T04:10:02.601047+00:00 2021-04-15T04:10:03.174263+00:00 0:00:00.573216 17332 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T04:10:00.366289+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-15T03:05:00+00:00 EmrJobFlowSensor 2021-04-15T04:06:04.177562+00:00 2021-04-15T04:15:06.749691+00:00 0:09:02.572129 17331 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T04:06:01.986351+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-15T03:05:00+00:00 EmrCreateJobFlowOperator 2021-04-15T04:05:42.058865+00:00 2021-04-15T04:05:43.678631+00:00 0:00:01.619766 17330 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T04:05:39.933969+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-15T03:05:00+00:00 PythonOperator 2021-04-15T04:05:14.224243+00:00 2021-04-15T04:05:17.055066+00:00 0:00:02.830823 17329 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T04:05:11.909707+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-15T03:00:00+00:00 EmrJobFlowSensor 2021-04-15T04:00:47.893584+00:00 2021-04-15T04:09:50.760545+00:00 0:09:02.866961 17328 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T04:00:45.540853+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-15T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T04:00:25.844558+00:00 2021-04-15T04:00:27.741616+00:00 0:00:01.897058 17327 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-15T04:00:23.503590+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-15T03:00:00+00:00 PythonOperator 2021-04-15T04:00:03.830921+00:00 2021-04-15T04:00:06.778136+00:00 0:00:02.947215 17326 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-15T04:00:01.459612+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-15T02:00:00+00:00 EmrJobFlowSensor 2021-04-15T03:11:09.091927+00:00 2021-04-15T03:21:11.860174+00:00 0:10:02.768247 17324 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T03:11:06.250720+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-15T02:00:00+00:00 EmrJobFlowSensor 2021-04-15T03:11:06.477087+00:00 2021-04-15T03:21:09.598851+00:00 0:10:03.121764 17323 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T03:11:04.255541+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-15T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T03:10:48.797831+00:00 2021-04-15T03:10:50.539138+00:00 0:00:01.741307 17322 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T03:10:46.134360+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-15T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T03:10:46.408508+00:00 2021-04-15T03:10:48.493696+00:00 0:00:02.085188 17321 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T03:10:44.135217+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-15T02:00:00+00:00 PythonOperator 2021-04-15T03:10:18.408292+00:00 2021-04-15T03:10:21.536347+00:00 0:00:03.128055 17320 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T03:10:16.107556+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-15T02:00:00+00:00 PythonOperator 2021-04-15T03:10:16.492373+00:00 2021-04-15T03:10:19.387840+00:00 0:00:02.895467 17319 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T03:10:14.106369+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-15T02:00:00+00:00 TriggerDagRunOperator 2021-04-15T03:10:04.444612+00:00 2021-04-15T03:10:05.216255+00:00 0:00:00.771643 17318 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T03:10:02.094838+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-15T02:00:00+00:00 TriggerDagRunOperator 2021-04-15T03:10:04.324574+00:00 2021-04-15T03:10:05.012695+00:00 0:00:00.688121 17317 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T03:10:02.094869+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-15T02:05:00+00:00 EmrJobFlowSensor 2021-04-15T03:06:03.825715+00:00 2021-04-15T03:15:06.653093+00:00 0:09:02.827378 17316 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T03:06:01.524137+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-15T02:05:00+00:00 EmrCreateJobFlowOperator 2021-04-15T03:05:41.686171+00:00 2021-04-15T03:05:43.429148+00:00 0:00:01.742977 17315 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T03:05:39.475074+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-15T02:05:00+00:00 PythonOperator 2021-04-15T03:05:21.564159+00:00 2021-04-15T03:05:24.647566+00:00 0:00:03.083407 17314 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T03:05:19.459645+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-15T02:00:00+00:00 EmrJobFlowSensor 2021-04-15T03:00:46.931113+00:00 2021-04-15T03:09:49.723290+00:00 0:09:02.792177 17313 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T03:00:44.729996+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-15T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T03:00:26.951963+00:00 2021-04-15T03:00:28.705854+00:00 0:00:01.753891 17312 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-15T03:00:24.711185+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-15T02:00:00+00:00 PythonOperator 2021-04-15T03:00:05.514390+00:00 2021-04-15T03:00:08.407180+00:00 0:00:02.892790 17311 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-15T03:00:02.752706+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-15T01:00:00+00:00 EmrJobFlowSensor 2021-04-15T02:11:18.425690+00:00 2021-04-15T02:22:21.319531+00:00 0:11:02.893841 17309 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T02:11:16.134338+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-15T01:00:00+00:00 EmrJobFlowSensor 2021-04-15T02:11:12.323680+00:00 2021-04-15T02:21:15.173443+00:00 0:10:02.849763 17308 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T02:11:10.130177+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-15T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T02:10:56.323178+00:00 2021-04-15T02:10:58.055714+00:00 0:00:01.732536 17307 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T02:10:54.120852+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-15T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T02:10:52.617912+00:00 2021-04-15T02:10:54.316832+00:00 0:00:01.698920 17306 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T02:10:50.109059+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-15T01:00:00+00:00 PythonOperator 2021-04-15T02:10:36.662447+00:00 2021-04-15T02:10:39.673866+00:00 0:00:03.011419 17305 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T02:10:34.095415+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-15T01:00:00+00:00 PythonOperator 2021-04-15T02:10:30.893834+00:00 2021-04-15T02:10:34.201002+00:00 0:00:03.307168 17304 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T02:10:28.240883+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-15T01:00:00+00:00 TriggerDagRunOperator 2021-04-15T02:10:16.781323+00:00 2021-04-15T02:10:17.191238+00:00 0:00:00.409915 17303 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T02:10:14.053355+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-15T01:00:00+00:00 TriggerDagRunOperator 2021-04-15T02:10:16.798564+00:00 2021-04-15T02:10:17.313499+00:00 0:00:00.514935 17302 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T02:10:14.053402+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-15T01:05:00+00:00 EmrJobFlowSensor 2021-04-15T02:06:01.733780+00:00 2021-04-15T02:15:04.401781+00:00 0:09:02.668001 17301 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T02:05:59.589564+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-15T01:05:00+00:00 EmrCreateJobFlowOperator 2021-04-15T02:05:39.668758+00:00 2021-04-15T02:05:41.333394+00:00 0:00:01.664636 17300 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T02:05:37.498798+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-15T01:05:00+00:00 PythonOperator 2021-04-15T02:05:19.725962+00:00 2021-04-15T02:05:22.937581+00:00 0:00:03.211619 17299 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T02:05:17.392758+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-15T01:00:00+00:00 EmrJobFlowSensor 2021-04-15T02:00:51.145632+00:00 2021-04-15T02:09:54.170149+00:00 0:09:03.024517 17298 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T02:00:48.825188+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-15T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T02:00:29.094892+00:00 2021-04-15T02:00:30.795255+00:00 0:00:01.700363 17297 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-15T02:00:26.811013+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-15T01:00:00+00:00 PythonOperator 2021-04-15T02:00:09.257859+00:00 2021-04-15T02:00:12.103665+00:00 0:00:02.845806 17296 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-15T02:00:06.790086+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-15T00:00:00+00:00 EmrJobFlowSensor 2021-04-15T01:10:22.201214+00:00 2021-04-15T01:20:25.027637+00:00 0:10:02.826423 17294 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T01:10:19.749709+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-15T00:00:00+00:00 EmrJobFlowSensor 2021-04-15T01:10:13.995878+00:00 2021-04-15T01:18:16.630231+00:00 0:08:02.634353 17293 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T01:10:11.745731+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-15T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T01:09:59.957161+00:00 2021-04-15T01:10:01.801147+00:00 0:00:01.843986 17292 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T01:09:57.701511+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-15T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T01:09:51.911387+00:00 2021-04-15T01:09:53.954975+00:00 0:00:02.043588 17291 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T01:09:49.689401+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-15T00:00:00+00:00 PythonOperator 2021-04-15T01:09:39.903465+00:00 2021-04-15T01:09:43.208046+00:00 0:00:03.304581 17290 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T01:09:37.637193+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-15T00:00:00+00:00 PythonOperator 2021-04-15T01:09:31.836474+00:00 2021-04-15T01:09:34.930465+00:00 0:00:03.093991 17289 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T01:09:29.632057+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-15T00:00:00+00:00 TriggerDagRunOperator 2021-04-15T01:09:16.081082+00:00 2021-04-15T01:09:16.608506+00:00 0:00:00.527424 17288 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T01:09:13.616982+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-15T00:00:00+00:00 TriggerDagRunOperator 2021-04-15T01:09:15.973128+00:00 2021-04-15T01:09:16.391811+00:00 0:00:00.418683 17287 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T01:09:13.616924+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-15T00:05:00+00:00 EmrJobFlowSensor 2021-04-15T01:05:57.378805+00:00 2021-04-15T01:13:59.814474+00:00 0:08:02.435669 17286 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T01:05:55.202400+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-15T00:05:00+00:00 EmrCreateJobFlowOperator 2021-04-15T01:05:35.451986+00:00 2021-04-15T01:05:37.170851+00:00 0:00:01.718865 17285 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T01:05:33.186374+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-15T00:05:00+00:00 PythonOperator 2021-04-15T01:05:13.310006+00:00 2021-04-15T01:05:16.234244+00:00 0:00:02.924238 17284 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T01:05:11.118714+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-15T00:00:00+00:00 EmrJobFlowSensor 2021-04-15T01:01:02.893414+00:00 2021-04-15T01:09:05.379834+00:00 0:08:02.486420 17283 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T01:01:00.551311+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-15T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T01:00:40.667239+00:00 2021-04-15T01:00:42.369720+00:00 0:00:01.702481 17282 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-15T01:00:38.395662+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-15T00:00:00+00:00 PythonOperator 2021-04-15T01:00:18.795281+00:00 2021-04-15T01:00:21.932480+00:00 0:00:03.137199 17281 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-15T01:00:16.334749+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-14T23:00:00+00:00 EmrJobFlowSensor 2021-04-15T00:12:42.223978+00:00 2021-04-15T00:22:45.074621+00:00 0:10:02.850643 17279 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T00:12:40.046776+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-14T23:00:00+00:00 EmrJobFlowSensor 2021-04-15T00:12:26.322649+00:00 2021-04-15T00:21:29.141017+00:00 0:09:02.818368 17278 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T00:12:24.031403+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-14T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T00:12:18.550810+00:00 2021-04-15T00:12:20.379934+00:00 0:00:01.829124 17277 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T00:12:16.071929+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-14T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T00:12:04.862627+00:00 2021-04-15T00:12:06.757559+00:00 0:00:01.894932 17276 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T00:12:02.012875+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-14T23:00:00+00:00 PythonOperator 2021-04-15T00:11:58.392841+00:00 2021-04-15T00:12:01.904490+00:00 0:00:03.511649 17275 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T00:11:56.064215+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-14T23:00:00+00:00 PythonOperator 2021-04-15T00:11:42.241364+00:00 2021-04-15T00:11:45.841480+00:00 0:00:03.600116 17274 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T00:11:39.992674+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T23:00:00+00:00 TriggerDagRunOperator 2021-04-15T00:11:32.275808+00:00 2021-04-15T00:11:32.699141+00:00 0:00:00.423333 17273 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T00:11:29.992158+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T23:00:00+00:00 TriggerDagRunOperator 2021-04-15T00:11:32.277167+00:00 2021-04-15T00:11:32.841056+00:00 0:00:00.563889 17272 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T00:11:29.992191+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-14T23:05:00+00:00 EmrJobFlowSensor 2021-04-15T00:05:57.557403+00:00 2021-04-15T00:14:00.049124+00:00 0:08:02.491721 17271 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T00:05:55.376808+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-14T23:05:00+00:00 EmrCreateJobFlowOperator 2021-04-15T00:05:27.620162+00:00 2021-04-15T00:05:29.315615+00:00 0:00:01.695453 17270 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T00:05:25.342194+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-14T23:05:00+00:00 PythonOperator 2021-04-15T00:05:07.491640+00:00 2021-04-15T00:05:10.354661+00:00 0:00:02.863021 17269 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T00:05:05.323746+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T23:00:00+00:00 EmrJobFlowSensor 2021-04-15T00:01:05.311654+00:00 2021-04-15T00:11:08.194897+00:00 0:10:02.883243 17268 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T00:01:03.052251+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T00:00:45.230981+00:00 2021-04-15T00:00:46.936718+00:00 0:00:01.705737 17267 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-15T00:00:42.993631+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T23:00:00+00:00 PythonOperator 2021-04-15T00:00:23.221966+00:00 2021-04-15T00:00:26.081636+00:00 0:00:02.859670 17266 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-15T00:00:20.907757+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-14T22:00:00+00:00 EmrJobFlowSensor 2021-04-14T23:11:31.134007+00:00 2021-04-14T23:20:33.634493+00:00 0:09:02.500486 17264 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T23:11:28.750177+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-14T22:00:00+00:00 EmrJobFlowSensor 2021-04-14T23:11:22.935647+00:00 2021-04-14T23:20:25.694768+00:00 0:09:02.759121 17263 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T23:11:20.599639+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-14T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T23:11:11.083361+00:00 2021-04-14T23:11:12.967349+00:00 0:00:01.883988 17262 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T23:11:08.588367+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-14T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T23:11:01.206327+00:00 2021-04-14T23:11:02.913937+00:00 0:00:01.707610 17261 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T23:10:58.640805+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-14T22:00:00+00:00 PythonOperator 2021-04-14T23:10:48.766038+00:00 2021-04-14T23:10:51.834225+00:00 0:00:03.068187 17260 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T23:10:46.498217+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-14T22:00:00+00:00 PythonOperator 2021-04-14T23:10:40.711164+00:00 2021-04-14T23:10:43.833110+00:00 0:00:03.121946 17259 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T23:10:38.491890+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T22:00:00+00:00 TriggerDagRunOperator 2021-04-14T23:10:34.930271+00:00 2021-04-14T23:10:35.510746+00:00 0:00:00.580475 17258 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T23:10:32.488041+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T22:00:00+00:00 TriggerDagRunOperator 2021-04-14T23:10:34.716647+00:00 2021-04-14T23:10:35.365208+00:00 0:00:00.648561 17257 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T23:10:32.488072+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-14T22:05:00+00:00 EmrJobFlowSensor 2021-04-14T23:05:56.366401+00:00 2021-04-14T23:13:58.841615+00:00 0:08:02.475214 17256 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T23:05:54.124495+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-14T22:05:00+00:00 EmrCreateJobFlowOperator 2021-04-14T23:05:34.220534+00:00 2021-04-14T23:05:35.839035+00:00 0:00:01.618501 17255 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T23:05:32.093918+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-14T22:05:00+00:00 PythonOperator 2021-04-14T23:05:14.573781+00:00 2021-04-14T23:05:17.410796+00:00 0:00:02.837015 17254 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T23:05:12.061102+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T22:00:00+00:00 EmrJobFlowSensor 2021-04-14T23:01:09.795554+00:00 2021-04-14T23:10:12.478328+00:00 0:09:02.682774 17253 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T23:01:07.523167+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T23:00:48.239210+00:00 2021-04-14T23:00:50.339206+00:00 0:00:02.099996 17252 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T23:00:45.568750+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T22:00:00+00:00 PythonOperator 2021-04-14T23:00:25.791445+00:00 2021-04-14T23:00:28.667699+00:00 0:00:02.876254 17251 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T23:00:23.488068+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-14T21:00:00+00:00 EmrJobFlowSensor 2021-04-14T22:11:10.363883+00:00 2021-04-14T22:20:13.140260+00:00 0:09:02.776377 17249 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T22:11:08.158530+00:00 2 default_pool