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 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
success booking-processing-job_v002 check_cluster_status 2021-04-14T21:00:00+00:00 EmrJobFlowSensor 2021-04-14T22:11:06.481698+00:00 2021-04-14T22:21:09.212898+00:00 0:10:02.731200 17248 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T22:11:04.166639+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-14T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T22:10:50.420142+00:00 2021-04-14T22:10:52.223355+00:00 0:00:01.803213 17247 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T22:10:48.090151+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-14T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T22:10:44.673214+00:00 2021-04-14T22:10:46.351810+00:00 0:00:01.678596 17246 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T22:10:42.163300+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-14T21:00:00+00:00 PythonOperator 2021-04-14T22:10:28.532434+00:00 2021-04-14T22:10:31.910258+00:00 0:00:03.377824 17245 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T22:10:26.059933+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-14T21:00:00+00:00 PythonOperator 2021-04-14T22:10:22.265435+00:00 2021-04-14T22:10:25.316766+00:00 0:00:03.051331 17244 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T22:10:20.054804+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T21:00:00+00:00 TriggerDagRunOperator 2021-04-14T22:10:18.441513+00:00 2021-04-14T22:10:18.970047+00:00 0:00:00.528534 17243 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T22:10:16.051484+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T21:00:00+00:00 TriggerDagRunOperator 2021-04-14T22:10:18.369635+00:00 2021-04-14T22:10:18.815072+00:00 0:00:00.445437 17242 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T22:10:16.051521+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-14T21:05:00+00:00 EmrJobFlowSensor 2021-04-14T22:06:05.869785+00:00 2021-04-14T22:14:08.274776+00:00 0:08:02.404991 17241 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T22:06:03.724897+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-14T21:05:00+00:00 EmrCreateJobFlowOperator 2021-04-14T22:05:45.857448+00:00 2021-04-14T22:05:47.692305+00:00 0:00:01.834857 17240 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T22:05:43.706504+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-14T21:05:00+00:00 PythonOperator 2021-04-14T22:05:23.990711+00:00 2021-04-14T22:05:26.962147+00:00 0:00:02.971436 17239 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T22:05:21.689640+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T21:00:00+00:00 EmrJobFlowSensor 2021-04-14T22:00:51.413329+00:00 2021-04-14T22:09:54.140900+00:00 0:09:02.727571 17238 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T22:00:49.299336+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T22:00:29.731326+00:00 2021-04-14T22:00:31.748013+00:00 0:00:02.016687 17237 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T22:00:27.290931+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T21:00:00+00:00 PythonOperator 2021-04-14T22:00:07.481597+00:00 2021-04-14T22:00:10.559305+00:00 0:00:03.077708 17236 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T22:00:05.267848+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-14T20:00:00+00:00 EmrJobFlowSensor 2021-04-14T21:11:29.889306+00:00 2021-04-14T21:20:32.473376+00:00 0:09:02.584070 17234 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T21:11:27.556631+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-14T20:00:00+00:00 EmrJobFlowSensor 2021-04-14T21:11:21.705561+00:00 2021-04-14T21:21:24.647345+00:00 0:10:02.941784 17233 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T21:11:19.500693+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-14T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T21:11:07.704657+00:00 2021-04-14T21:11:09.802166+00:00 0:00:02.097509 17232 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T21:11:05.486796+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-14T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T21:11:01.909750+00:00 2021-04-14T21:11:03.634641+00:00 0:00:01.724891 17231 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T21:10:59.556163+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-14T20:00:00+00:00 PythonOperator 2021-04-14T21:10:45.799845+00:00 2021-04-14T21:10:48.715083+00:00 0:00:02.915238 17230 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T21:10:43.446191+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-14T20:00:00+00:00 PythonOperator 2021-04-14T21:10:39.750848+00:00 2021-04-14T21:10:42.984746+00:00 0:00:03.233898 17229 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T21:10:37.439304+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T20:00:00+00:00 TriggerDagRunOperator 2021-04-14T21:10:25.722349+00:00 2021-04-14T21:10:26.139435+00:00 0:00:00.417086 17228 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T21:10:23.429785+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T20:00:00+00:00 TriggerDagRunOperator 2021-04-14T21:10:25.732103+00:00 2021-04-14T21:10:26.268892+00:00 0:00:00.536789 17227 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T21:10:23.429816+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-14T20:05:00+00:00 EmrJobFlowSensor 2021-04-14T21:05:59.182109+00:00 2021-04-14T21:15:01.906864+00:00 0:09:02.724755 17226 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T21:05:56.934209+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-14T20:05:00+00:00 EmrCreateJobFlowOperator 2021-04-14T21:05:37.100905+00:00 2021-04-14T21:05:38.779105+00:00 0:00:01.678200 17225 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T21:05:34.953007+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-14T20:05:00+00:00 PythonOperator 2021-04-14T21:05:17.173134+00:00 2021-04-14T21:05:19.996989+00:00 0:00:02.823855 17224 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T21:05:14.951059+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T20:00:00+00:00 EmrJobFlowSensor 2021-04-14T21:01:04.895840+00:00 2021-04-14T21:10:07.666238+00:00 0:09:02.770398 17223 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T21:01:02.510734+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T21:00:40.724562+00:00 2021-04-14T21:00:42.415855+00:00 0:00:01.691293 17222 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T21:00:38.486208+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T20:00:00+00:00 PythonOperator 2021-04-14T21:00:20.691901+00:00 2021-04-14T21:00:23.729483+00:00 0:00:03.037582 17221 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T21:00:18.425255+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-14T19:00:00+00:00 EmrJobFlowSensor 2021-04-14T20:10:26.061253+00:00 2021-04-14T20:19:28.779558+00:00 0:09:02.718305 17219 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T20:10:23.518033+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-14T19:00:00+00:00 EmrJobFlowSensor 2021-04-14T20:10:11.884395+00:00 2021-04-14T20:20:14.823378+00:00 0:10:02.938983 17218 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T20:10:09.568346+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-14T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T20:10:04.110218+00:00 2021-04-14T20:10:05.791879+00:00 0:00:01.681661 17217 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T20:10:01.499493+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-14T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T20:09:52.020405+00:00 2021-04-14T20:09:53.701134+00:00 0:00:01.680729 17216 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T20:09:49.485097+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-14T19:00:00+00:00 PythonOperator 2021-04-14T20:09:41.666112+00:00 2021-04-14T20:09:44.626009+00:00 0:00:02.959897 17215 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T20:09:39.450838+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-14T19:00:00+00:00 PythonOperator 2021-04-14T20:09:30.163647+00:00 2021-04-14T20:09:33.244534+00:00 0:00:03.080887 17214 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T20:09:27.483954+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T19:00:00+00:00 TriggerDagRunOperator 2021-04-14T20:09:17.646396+00:00 2021-04-14T20:09:18.159362+00:00 0:00:00.512966 17213 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T20:09:15.385950+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T19:00:00+00:00 TriggerDagRunOperator 2021-04-14T20:09:17.521101+00:00 2021-04-14T20:09:17.942570+00:00 0:00:00.421469 17212 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T20:09:15.385919+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-14T19:05:00+00:00 EmrJobFlowSensor 2021-04-14T20:05:57.261791+00:00 2021-04-14T20:14:59.933286+00:00 0:09:02.671495 17211 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T20:05:55.106734+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-14T19:05:00+00:00 EmrCreateJobFlowOperator 2021-04-14T20:05:29.207512+00:00 2021-04-14T20:05:30.880836+00:00 0:00:01.673324 17210 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T20:05:27.085364+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-14T19:05:00+00:00 PythonOperator 2021-04-14T20:05:07.245651+00:00 2021-04-14T20:05:10.065221+00:00 0:00:02.819570 17209 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T20:05:05.010881+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T19:00:00+00:00 EmrJobFlowSensor 2021-04-14T20:00:50.900530+00:00 2021-04-14T20:08:54.071399+00:00 0:08:03.170869 17208 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T20:00:48.697942+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T20:00:28.911650+00:00 2021-04-14T20:00:30.626581+00:00 0:00:01.714931 17207 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T20:00:26.641302+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T19:00:00+00:00 PythonOperator 2021-04-14T20:00:09.010002+00:00 2021-04-14T20:00:12.864819+00:00 0:00:03.854817 17206 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T20:00:06.161229+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-14T18:00:00+00:00 EmrJobFlowSensor 2021-04-14T19:11:19.557116+00:00 2021-04-14T19:21:22.311238+00:00 0:10:02.754122 17204 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T19:11:17.353653+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-14T18:00:00+00:00 EmrJobFlowSensor 2021-04-14T19:11:07.626554+00:00 2021-04-14T19:20:10.209928+00:00 0:09:02.583374 17203 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T19:11:05.338042+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-14T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T19:10:57.721952+00:00 2021-04-14T19:10:59.448909+00:00 0:00:01.726957 17202 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T19:10:55.331324+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-14T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T19:10:45.928968+00:00 2021-04-14T19:10:47.996647+00:00 0:00:02.067679 17201 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T19:10:43.314736+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-14T18:00:00+00:00 PythonOperator 2021-04-14T19:10:37.467003+00:00 2021-04-14T19:10:40.747917+00:00 0:00:03.280914 17200 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T19:10:35.307958+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-14T18:00:00+00:00 PythonOperator 2021-04-14T19:10:23.580310+00:00 2021-04-14T19:10:26.722198+00:00 0:00:03.141888 17199 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T19:10:21.298996+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T18:00:00+00:00 TriggerDagRunOperator 2021-04-14T19:10:13.853677+00:00 2021-04-14T19:10:14.790808+00:00 0:00:00.937131 17198 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T19:10:11.354929+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T18:00:00+00:00 TriggerDagRunOperator 2021-04-14T19:10:13.809479+00:00 2021-04-14T19:10:14.719785+00:00 0:00:00.910306 17197 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T19:10:11.354973+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-14T18:05:00+00:00 EmrJobFlowSensor 2021-04-14T19:05:46.856943+00:00 2021-04-14T19:14:49.515612+00:00 0:09:02.658669 17196 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T19:05:44.697308+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-14T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-14T19:05:25.095718+00:00 2021-04-14T19:05:26.798242+00:00 0:00:01.702524 17195 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T19:05:22.659705+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-14T18:05:00+00:00 PythonOperator 2021-04-14T19:05:04.919729+00:00 2021-04-14T19:05:07.824840+00:00 0:00:02.905111 17194 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T19:05:02.599395+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T18:00:00+00:00 EmrJobFlowSensor 2021-04-14T19:01:00.840422+00:00 2021-04-14T19:10:03.429065+00:00 0:09:02.588643 17193 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T19:00:58.356672+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T19:00:40.408835+00:00 2021-04-14T19:00:42.228759+00:00 0:00:01.819924 17192 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T19:00:38.215653+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T18:00:00+00:00 PythonOperator 2021-04-14T19:00:18.593671+00:00 2021-04-14T19:00:21.508330+00:00 0:00:02.914659 17191 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T19:00:16.200687+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-14T17:00:00+00:00 EmrJobFlowSensor 2021-04-14T18:10:24.724373+00:00 2021-04-14T18:20:27.334349+00:00 0:10:02.609976 17189 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T18:10:22.376915+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-14T17:00:00+00:00 EmrJobFlowSensor 2021-04-14T18:10:12.458366+00:00 2021-04-14T18:20:15.199814+00:00 0:10:02.741448 17188 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T18:10:10.293258+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-14T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T18:10:05.067688+00:00 2021-04-14T18:10:06.916494+00:00 0:00:01.848806 17187 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T18:10:02.290237+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-14T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T18:09:52.515750+00:00 2021-04-14T18:09:54.309646+00:00 0:00:01.793896 17186 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T18:09:50.263712+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-14T17:00:00+00:00 PythonOperator 2021-04-14T18:09:42.706104+00:00 2021-04-14T18:09:45.563391+00:00 0:00:02.857287 17185 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T18:09:40.254952+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-14T17:00:00+00:00 PythonOperator 2021-04-14T18:09:30.837190+00:00 2021-04-14T18:09:33.939625+00:00 0:00:03.102435 17184 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T18:09:28.340841+00:00 2 default_pool