Task Instances

Reset Filters
  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T20:00:00+00:00 TriggerDagRunOperator 2021-04-03T21:20:17.903870+00:00 2021-04-03T21:20:18.306565+00:00 0:00:00.402695 13249 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T21:20:15.735363+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T20:05:00+00:00 EmrJobFlowSensor 2021-04-03T21:06:02.727197+00:00 2021-04-03T21:15:05.347290+00:00 0:09:02.620093 13248 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T21:06:00.291064+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T20:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T21:05:42.546410+00:00 2021-04-03T21:05:44.287584+00:00 0:00:01.741174 13247 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T21:05:40.255485+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T20:05:00+00:00 PythonOperator 2021-04-03T21:05:20.275455+00:00 2021-04-03T21:05:22.973019+00:00 0:00:02.697564 13246 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T21:05:18.129358+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T20:00:00+00:00 EmrJobFlowSensor 2021-04-03T21:01:00.290843+00:00 2021-04-03T21:20:04.403914+00:00 0:19:04.113071 13245 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T21:00:57.810605+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T21:00:38.016905+00:00 2021-04-03T21:00:39.700219+00:00 0:00:01.683314 13244 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T21:00:35.788474+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T20:00:00+00:00 PythonOperator 2021-04-03T21:00:16.348911+00:00 2021-04-03T21:00:19.233348+00:00 0:00:02.884437 13243 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T21:00:13.765567+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T19:00:00+00:00 EmrJobFlowSensor 2021-04-03T20:11:19.051029+00:00 2021-04-03T20:21:21.830916+00:00 0:10:02.779887 13241 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T20:11:16.855386+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T19:00:00+00:00 EmrJobFlowSensor 2021-04-03T20:11:11.085701+00:00 2021-04-03T20:21:14.019250+00:00 0:10:02.933549 13240 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T20:11:08.841323+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T20:10:47.081492+00:00 2021-04-03T20:10:48.772298+00:00 0:00:01.690806 13239 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T20:10:44.822028+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T20:10:43.104072+00:00 2021-04-03T20:10:44.766368+00:00 0:00:01.662296 13238 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T20:10:40.821463+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T19:00:00+00:00 PythonOperator 2021-04-03T20:10:25.320008+00:00 2021-04-03T20:10:28.192047+00:00 0:00:02.872039 13237 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T20:10:22.803313+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T19:00:00+00:00 PythonOperator 2021-04-03T20:10:21.271679+00:00 2021-04-03T20:10:24.246219+00:00 0:00:02.974540 13236 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T20:10:18.857174+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T19:00:00+00:00 TriggerDagRunOperator 2021-04-03T20:10:13.217521+00:00 2021-04-03T20:10:13.735485+00:00 0:00:00.517964 13235 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T20:10:10.793946+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T19:00:00+00:00 TriggerDagRunOperator 2021-04-03T20:10:13.001688+00:00 2021-04-03T20:10:13.403277+00:00 0:00:00.401589 13234 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T20:10:10.793982+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T19:05:00+00:00 EmrJobFlowSensor 2021-04-03T20:06:04.661826+00:00 2021-04-03T20:15:07.141241+00:00 0:09:02.479415 13233 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T20:06:02.342656+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T19:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T20:05:42.515668+00:00 2021-04-03T20:05:44.234373+00:00 0:00:01.718705 13232 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T20:05:40.224927+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T19:05:00+00:00 PythonOperator 2021-04-03T20:05:20.481252+00:00 2021-04-03T20:05:23.308571+00:00 0:00:02.827319 13231 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T20:05:18.204470+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T19:00:00+00:00 EmrJobFlowSensor 2021-04-03T20:00:56.548535+00:00 2021-04-03T20:09:59.295034+00:00 0:09:02.746499 13230 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T20:00:53.871178+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T20:00:34.482917+00:00 2021-04-03T20:00:36.281035+00:00 0:00:01.798118 13229 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T20:00:31.791323+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T19:00:00+00:00 PythonOperator 2021-04-03T20:00:14.251404+00:00 2021-04-03T20:00:17.010797+00:00 0:00:02.759393 13228 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T20:00:11.753961+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T18:00:00+00:00 EmrJobFlowSensor 2021-04-03T19:25:58.370630+00:00 2021-04-03T19:25:59.870487+00:00 0:00:01.499857 13226 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T19:25:56.185850+00:00 3 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T18:00:00+00:00 EmrJobFlowSensor 2021-04-03T19:14:13.317366+00:00 2021-04-03T19:24:16.103966+00:00 0:10:02.786600 13224 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T19:14:11.050048+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T19:14:05.304371+00:00 2021-04-03T19:14:06.997502+00:00 0:00:01.693131 13223 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T19:14:03.038463+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T19:13:51.283673+00:00 2021-04-03T19:13:53.124897+00:00 0:00:01.841224 13222 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T19:13:49.046735+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T18:00:00+00:00 PythonOperator 2021-04-03T19:13:43.609877+00:00 2021-04-03T19:13:46.337178+00:00 0:00:02.727301 13221 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T19:13:41.144437+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T18:00:00+00:00 PythonOperator 2021-04-03T19:13:31.624512+00:00 2021-04-03T19:13:34.667271+00:00 0:00:03.042759 13220 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T19:13:29.077595+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T18:00:00+00:00 TriggerDagRunOperator 2021-04-03T19:13:23.396584+00:00 2021-04-03T19:13:24.261793+00:00 0:00:00.865209 13219 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T19:13:21.008463+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T18:00:00+00:00 TriggerDagRunOperator 2021-04-03T19:13:23.312018+00:00 2021-04-03T19:13:23.905107+00:00 0:00:00.593089 13218 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T19:13:21.008435+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T18:05:00+00:00 EmrJobFlowSensor 2021-04-03T19:05:52.601400+00:00 2021-04-03T19:14:55.245428+00:00 0:09:02.644028 13217 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T19:05:50.327809+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T19:05:30.979182+00:00 2021-04-03T19:05:32.640392+00:00 0:00:01.661210 13216 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T19:05:28.468691+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T18:05:00+00:00 PythonOperator 2021-04-03T19:05:10.597204+00:00 2021-04-03T19:05:13.259280+00:00 0:00:02.662076 13215 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T19:05:08.359258+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T18:00:00+00:00 EmrJobFlowSensor 2021-04-03T19:00:57.996930+00:00 2021-04-03T19:13:01.035803+00:00 0:12:03.038873 13214 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T19:00:55.797484+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T19:00:38.051052+00:00 2021-04-03T19:00:39.769397+00:00 0:00:01.718345 13213 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T19:00:35.748432+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T18:00:00+00:00 PythonOperator 2021-04-03T19:00:16.159958+00:00 2021-04-03T19:00:18.937735+00:00 0:00:02.777777 13212 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T19:00:13.725417+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T17:00:00+00:00 EmrJobFlowSensor 2021-04-03T18:10:37.306481+00:00 2021-04-03T18:19:39.961154+00:00 0:09:02.654673 13210 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T18:10:35.054333+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T17:00:00+00:00 EmrJobFlowSensor 2021-04-03T18:10:35.520526+00:00 2021-04-03T18:20:38.436771+00:00 0:10:02.916245 13209 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T18:10:32.980549+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T18:10:11.201428+00:00 2021-04-03T18:10:13.011753+00:00 0:00:01.810325 13208 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T18:10:08.952330+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T18:10:09.176977+00:00 2021-04-03T18:10:10.917082+00:00 0:00:01.740105 13207 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T18:10:06.950994+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T17:00:00+00:00 PythonOperator 2021-04-03T18:09:45.301408+00:00 2021-04-03T18:09:48.118644+00:00 0:00:02.817236 13206 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T18:09:42.905439+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T17:00:00+00:00 PythonOperator 2021-04-03T18:09:43.110297+00:00 2021-04-03T18:09:46.016154+00:00 0:00:02.905857 13205 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T18:09:40.904865+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T17:00:00+00:00 TriggerDagRunOperator 2021-04-03T18:09:25.459407+00:00 2021-04-03T18:09:25.989532+00:00 0:00:00.530125 13204 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T18:09:22.965669+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T17:00:00+00:00 TriggerDagRunOperator 2021-04-03T18:09:25.378641+00:00 2021-04-03T18:09:25.847213+00:00 0:00:00.468572 13203 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T18:09:22.965716+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T17:05:00+00:00 EmrJobFlowSensor 2021-04-03T18:05:52.712353+00:00 2021-04-03T18:14:55.283399+00:00 0:09:02.571046 13202 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T18:05:50.479117+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T17:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T18:05:32.649565+00:00 2021-04-03T18:05:34.316315+00:00 0:00:01.666750 13201 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T18:05:30.462632+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T17:05:00+00:00 PythonOperator 2021-04-03T18:05:10.589823+00:00 2021-04-03T18:05:13.354947+00:00 0:00:02.765124 13200 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T18:05:08.401030+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T17:00:00+00:00 EmrJobFlowSensor 2021-04-03T18:01:06.215726+00:00 2021-04-03T18:09:08.851714+00:00 0:08:02.635988 13199 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T18:01:03.913983+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T18:00:42.126831+00:00 2021-04-03T18:00:43.830751+00:00 0:00:01.703920 13198 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T18:00:39.891818+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T17:00:00+00:00 PythonOperator 2021-04-03T18:00:22.347269+00:00 2021-04-03T18:00:25.265077+00:00 0:00:02.917808 13197 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T18:00:19.874896+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T16:00:00+00:00 EmrJobFlowSensor 2021-04-03T17:11:40.351453+00:00 2021-04-03T17:20:43.053264+00:00 0:09:02.701811 13195 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T17:11:37.888756+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T16:00:00+00:00 EmrJobFlowSensor 2021-04-03T17:11:16.116633+00:00 2021-04-03T17:20:18.825329+00:00 0:09:02.708696 13194 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T17:11:13.821234+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T17:11:08.136510+00:00 2021-04-03T17:11:09.914876+00:00 0:00:01.778366 13193 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T17:11:05.814713+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T17:10:54.359027+00:00 2021-04-03T17:10:56.162365+00:00 0:00:01.803338 13192 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T17:10:51.857530+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T16:00:00+00:00 PythonOperator 2021-04-03T17:10:44.703155+00:00 2021-04-03T17:10:47.860925+00:00 0:00:03.157770 13191 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T17:10:41.857490+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T16:00:00+00:00 PythonOperator 2021-04-03T17:10:32.326842+00:00 2021-04-03T17:10:35.193924+00:00 0:00:02.867082 13190 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T17:10:29.866021+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T16:00:00+00:00 TriggerDagRunOperator 2021-04-03T17:10:18.221407+00:00 2021-04-03T17:10:18.738570+00:00 0:00:00.517163 13189 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T17:10:15.751338+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T16:00:00+00:00 TriggerDagRunOperator 2021-04-03T17:10:17.997355+00:00 2021-04-03T17:10:18.434058+00:00 0:00:00.436703 13188 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T17:10:15.751375+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T16:05:00+00:00 EmrJobFlowSensor 2021-04-03T17:06:03.595436+00:00 2021-04-03T17:14:06.212065+00:00 0:08:02.616629 13187 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T17:06:01.337994+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T16:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T17:05:37.580337+00:00 2021-04-03T17:05:39.230266+00:00 0:00:01.649929 13186 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T17:05:35.313977+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T16:05:00+00:00 PythonOperator 2021-04-03T17:05:15.810134+00:00 2021-04-03T17:05:18.526695+00:00 0:00:02.716561 13185 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T17:05:13.351740+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T16:00:00+00:00 EmrJobFlowSensor 2021-04-03T17:01:05.171200+00:00 2021-04-03T17:10:07.877598+00:00 0:09:02.706398 13184 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T17:01:02.882951+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T17:00:43.083559+00:00 2021-04-03T17:00:44.753500+00:00 0:00:01.669941 13183 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T17:00:40.791856+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T16:00:00+00:00 PythonOperator 2021-04-03T17:00:22.899522+00:00 2021-04-03T17:00:25.610925+00:00 0:00:02.711403 13182 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T17:00:20.739248+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T15:00:00+00:00 EmrJobFlowSensor 2021-04-03T16:26:03.409305+00:00 2021-04-03T16:35:06.058662+00:00 0:09:02.649357 13181 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T16:26:01.219221+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T15:00:00+00:00 EmrJobFlowSensor 2021-04-03T16:25:59.412063+00:00 2021-04-03T16:35:01.987739+00:00 0:09:02.575676 13180 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T16:25:57.214194+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T15:05:00+00:00 EmrJobFlowSensor 2021-04-03T16:25:45.759472+00:00 2021-04-03T16:34:48.411841+00:00 0:09:02.652369 13179 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T16:25:43.202996+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T16:25:41.630036+00:00 2021-04-03T16:25:43.333813+00:00 0:00:01.703777 13178 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T16:25:39.263494+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T16:25:33.595572+00:00 2021-04-03T16:25:35.430577+00:00 0:00:01.835005 13177 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T16:25:31.195960+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T15:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T16:25:24.318813+00:00 2021-04-03T16:25:26.016994+00:00 0:00:01.698181 13176 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T16:25:21.189829+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T15:00:00+00:00 PythonOperator 2021-04-03T16:25:20.374199+00:00 2021-04-03T16:25:23.726117+00:00 0:00:03.351918 13175 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T16:25:17.184549+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T15:00:00+00:00 PythonOperator 2021-04-03T16:25:11.536666+00:00 2021-04-03T16:25:14.511644+00:00 0:00:02.974978 13174 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T16:25:09.171034+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T15:00:00+00:00 TriggerDagRunOperator 2021-04-03T16:25:06.628031+00:00 2021-04-03T16:25:07.503383+00:00 0:00:00.875352 13173 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T16:25:00.759501+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T15:00:00+00:00 TriggerDagRunOperator 2021-04-03T16:25:06.571088+00:00 2021-04-03T16:25:07.164569+00:00 0:00:00.593481 13172 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T16:25:00.759514+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T15:05:00+00:00 PythonOperator 2021-04-03T16:25:03.790314+00:00 2021-04-03T16:25:06.719125+00:00 0:00:02.928811 13171 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T16:25:00.759469+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T15:00:00+00:00 EmrJobFlowSensor 2021-04-03T16:01:00.111370+00:00 2021-04-03T16:11:03.157186+00:00 0:10:03.045816 13169 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T16:00:57.427199+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T16:00:37.903110+00:00 2021-04-03T16:00:39.763757+00:00 0:00:01.860647 13168 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T16:00:35.401809+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T15:00:00+00:00 PythonOperator 2021-04-03T16:00:17.654904+00:00 2021-04-03T16:00:20.385393+00:00 0:00:02.730489 13167 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T16:00:15.380283+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T14:00:00+00:00 EmrJobFlowSensor 2021-04-03T15:11:28.291784+00:00 2021-04-03T15:20:30.845383+00:00 0:09:02.553599 13166 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T15:11:25.943318+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T14:00:00+00:00 EmrJobFlowSensor 2021-04-03T15:11:26.257967+00:00 2021-04-03T15:21:29.085672+00:00 0:10:02.827705 13165 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T15:11:23.947767+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T15:11:08.474186+00:00 2021-04-03T15:11:10.239197+00:00 0:00:01.765011 13164 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T15:11:05.926829+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T15:11:06.114631+00:00 2021-04-03T15:11:08.138636+00:00 0:00:02.024005 13163 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T15:11:03.926245+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T14:00:00+00:00 PythonOperator 2021-04-03T15:10:38.134394+00:00 2021-04-03T15:10:41.009742+00:00 0:00:02.875348 13162 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T15:10:35.896618+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T14:00:00+00:00 PythonOperator 2021-04-03T15:10:36.118802+00:00 2021-04-03T15:10:38.974793+00:00 0:00:02.855991 13161 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T15:10:33.893728+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T14:00:00+00:00 TriggerDagRunOperator 2021-04-03T15:10:14.290774+00:00 2021-04-03T15:10:14.844282+00:00 0:00:00.553508 13160 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T15:10:11.872904+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T14:00:00+00:00 TriggerDagRunOperator 2021-04-03T15:10:14.254982+00:00 2021-04-03T15:10:14.671178+00:00 0:00:00.416196 13159 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T15:10:11.872934+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T14:05:00+00:00 EmrJobFlowSensor 2021-04-03T15:05:49.660683+00:00 2021-04-03T15:14:52.120735+00:00 0:09:02.460052 13158 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T15:05:47.518269+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T14:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T15:05:27.968803+00:00 2021-04-03T15:05:29.711178+00:00 0:00:01.742375 13157 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T15:05:25.559574+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T14:05:00+00:00 PythonOperator 2021-04-03T15:05:06.349274+00:00 2021-04-03T15:05:09.050801+00:00 0:00:02.701527 13156 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T15:05:03.543889+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T14:00:00+00:00 EmrJobFlowSensor 2021-04-03T15:01:04.723472+00:00 2021-04-03T15:10:07.413354+00:00 0:09:02.689882 13154 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T15:01:02.408559+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T15:00:40.626950+00:00 2021-04-03T15:00:42.298926+00:00 0:00:01.671976 13153 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T15:00:38.378078+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T14:00:00+00:00 PythonOperator 2021-04-03T15:00:20.847166+00:00 2021-04-03T15:00:23.750643+00:00 0:00:02.903477 13152 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T15:00:18.368824+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T13:00:00+00:00 EmrJobFlowSensor 2021-04-03T14:13:29.893109+00:00 2021-04-03T14:21:32.410431+00:00 0:08:02.517322 13151 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T14:13:27.560122+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T13:00:00+00:00 EmrJobFlowSensor 2021-04-03T14:13:27.704964+00:00 2021-04-03T14:22:30.447469+00:00 0:09:02.742505 13150 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T14:13:25.481979+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T14:13:07.837208+00:00 2021-04-03T14:13:09.816266+00:00 0:00:01.979058 13149 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T14:13:05.437558+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T14:13:07.649847+00:00 2021-04-03T14:13:09.391106+00:00 0:00:01.741259 13148 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T14:13:05.437590+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T13:00:00+00:00 PythonOperator 2021-04-03T14:12:48.053183+00:00 2021-04-03T14:12:50.778972+00:00 0:00:02.725789 13147 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T14:12:45.419960+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T13:00:00+00:00 PythonOperator 2021-04-03T14:12:45.809221+00:00 2021-04-03T14:12:49.044204+00:00 0:00:03.234983 13146 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T14:12:43.415346+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T13:00:00+00:00 TriggerDagRunOperator 2021-04-03T14:12:30.175513+00:00 2021-04-03T14:12:30.756845+00:00 0:00:00.581332 13145 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T14:12:27.403826+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T13:00:00+00:00 TriggerDagRunOperator 2021-04-03T14:12:29.843628+00:00 2021-04-03T14:12:30.262540+00:00 0:00:00.418912 13144 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T14:12:27.403780+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T13:05:00+00:00 EmrJobFlowSensor 2021-04-03T14:05:56.926058+00:00 2021-04-03T14:14:59.557158+00:00 0:09:02.631100 13143 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T14:05:54.754751+00:00 2 default_pool