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-05-09T18:00:00+00:00 PythonOperator 2021-05-09T19:00:20.016605+00:00 2021-05-09T19:00:23.138072+00:00 0:00:03.121467 26277 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T19:00:17.574560+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-09T17:00:00+00:00 EmrJobFlowSensor 2021-05-09T18:12:45.179021+00:00 2021-05-09T18:21:47.845396+00:00 0:09:02.666375 26276 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T18:12:42.841251+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-09T17:00:00+00:00 EmrJobFlowSensor 2021-05-09T18:12:35.044316+00:00 2021-05-09T18:22:37.940149+00:00 0:10:02.895833 26275 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T18:12:32.728075+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-09T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T18:12:25.084558+00:00 2021-05-09T18:12:26.911666+00:00 0:00:01.827108 26274 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T18:12:22.727642+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-09T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T18:12:15.073851+00:00 2021-05-09T18:12:16.868057+00:00 0:00:01.794206 26273 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T18:12:12.708010+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-09T17:00:00+00:00 PythonOperator 2021-05-09T18:12:02.874343+00:00 2021-05-09T18:12:06.152588+00:00 0:00:03.278245 26272 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T18:12:00.700398+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-09T17:00:00+00:00 PythonOperator 2021-05-09T18:11:53.149742+00:00 2021-05-09T18:11:56.504710+00:00 0:00:03.354968 26271 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T18:11:50.692752+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T17:00:00+00:00 TriggerDagRunOperator 2021-05-09T18:11:43.380252+00:00 2021-05-09T18:11:43.797216+00:00 0:00:00.416964 26270 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T18:11:40.563546+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T17:00:00+00:00 TriggerDagRunOperator 2021-05-09T18:11:43.400923+00:00 2021-05-09T18:11:43.949390+00:00 0:00:00.548467 26269 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T18:11:40.563578+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-09T17:05:00+00:00 EmrJobFlowSensor 2021-05-09T18:05:59.186846+00:00 2021-05-09T18:14:01.702809+00:00 0:08:02.515963 26267 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T18:05:57.106088+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-09T17:05:00+00:00 EmrCreateJobFlowOperator 2021-05-09T18:05:37.371614+00:00 2021-05-09T18:05:39.016838+00:00 0:00:01.645224 26266 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T18:05:35.154919+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-09T17:05:00+00:00 PythonOperator 2021-05-09T18:05:15.162063+00:00 2021-05-09T18:05:18.247188+00:00 0:00:03.085125 26265 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T18:05:13.003347+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T17:00:00+00:00 EmrJobFlowSensor 2021-05-09T18:00:50.812854+00:00 2021-05-09T18:10:53.706903+00:00 0:10:02.894049 26264 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T18:00:48.630998+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T18:00:29.040003+00:00 2021-05-09T18:00:30.871923+00:00 0:00:01.831920 26263 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T18:00:26.612496+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T17:00:00+00:00 PythonOperator 2021-05-09T18:00:07.022973+00:00 2021-05-09T18:00:10.110882+00:00 0:00:03.087909 26262 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T18:00:04.598203+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-09T16:00:00+00:00 EmrJobFlowSensor 2021-05-09T17:12:40.081154+00:00 2021-05-09T17:22:42.879296+00:00 0:10:02.798142 26261 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T17:12:37.891557+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-09T16:00:00+00:00 EmrJobFlowSensor 2021-05-09T17:12:28.178549+00:00 2021-05-09T17:21:30.770401+00:00 0:09:02.591852 26260 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T17:12:25.946234+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-09T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T17:12:18.415490+00:00 2021-05-09T17:12:20.254820+00:00 0:00:01.839330 26259 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T17:12:15.854323+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-09T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T17:12:08.001555+00:00 2021-05-09T17:12:09.806472+00:00 0:00:01.804917 26258 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T17:12:05.799539+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-09T16:00:00+00:00 PythonOperator 2021-05-09T17:11:58.182118+00:00 2021-05-09T17:12:01.488096+00:00 0:00:03.305978 26257 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T17:11:55.944583+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-09T16:00:00+00:00 PythonOperator 2021-05-09T17:11:45.870407+00:00 2021-05-09T17:11:48.931629+00:00 0:00:03.061222 26256 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T17:11:43.703378+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T16:00:00+00:00 TriggerDagRunOperator 2021-05-09T17:11:30.207028+00:00 2021-05-09T17:11:30.787307+00:00 0:00:00.580279 26255 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T17:11:27.691111+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T16:00:00+00:00 TriggerDagRunOperator 2021-05-09T17:11:30.083031+00:00 2021-05-09T17:11:30.542121+00:00 0:00:00.459090 26254 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T17:11:27.691084+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-09T16:05:00+00:00 EmrJobFlowSensor 2021-05-09T17:05:58.824385+00:00 2021-05-09T17:14:01.190078+00:00 0:08:02.365693 26252 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T17:05:56.632167+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-09T16:05:00+00:00 EmrCreateJobFlowOperator 2021-05-09T17:05:36.655682+00:00 2021-05-09T17:05:38.291485+00:00 0:00:01.635803 26251 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T17:05:34.613266+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-09T16:05:00+00:00 PythonOperator 2021-05-09T17:05:14.795189+00:00 2021-05-09T17:05:17.869142+00:00 0:00:03.073953 26250 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T17:05:12.594823+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T16:00:00+00:00 EmrJobFlowSensor 2021-05-09T17:00:58.487607+00:00 2021-05-09T17:11:01.282573+00:00 0:10:02.794966 26249 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T17:00:56.256488+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T17:00:38.440436+00:00 2021-05-09T17:00:40.173798+00:00 0:00:01.733362 26248 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T17:00:36.201696+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T16:00:00+00:00 PythonOperator 2021-05-09T17:00:16.328572+00:00 2021-05-09T17:00:19.382894+00:00 0:00:03.054322 26247 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T17:00:14.190661+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-09T15:00:00+00:00 EmrJobFlowSensor 2021-05-09T16:11:21.380688+00:00 2021-05-09T16:32:25.645258+00:00 0:21:04.264570 26246 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T16:11:19.062008+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-09T15:00:00+00:00 EmrJobFlowSensor 2021-05-09T16:11:05.237241+00:00 2021-05-09T16:21:08.161792+00:00 0:10:02.924551 26245 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T16:11:02.969870+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-09T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T16:11:01.033653+00:00 2021-05-09T16:11:02.809443+00:00 0:00:01.775790 26244 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T16:10:58.952575+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-09T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T16:10:45.250311+00:00 2021-05-09T16:10:47.025197+00:00 0:00:01.774886 26243 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T16:10:42.938203+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-09T15:00:00+00:00 PythonOperator 2021-05-09T16:10:39.192624+00:00 2021-05-09T16:10:42.272265+00:00 0:00:03.079641 26242 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T16:10:36.957478+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-09T15:00:00+00:00 PythonOperator 2021-05-09T16:10:23.641459+00:00 2021-05-09T16:10:27.110758+00:00 0:00:03.469299 26241 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T16:10:20.921679+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T15:00:00+00:00 TriggerDagRunOperator 2021-05-09T16:10:15.824255+00:00 2021-05-09T16:10:16.348532+00:00 0:00:00.524277 26240 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T16:10:12.747300+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T15:00:00+00:00 TriggerDagRunOperator 2021-05-09T16:10:15.676104+00:00 2021-05-09T16:10:16.065492+00:00 0:00:00.389388 26239 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T16:10:12.747345+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-09T15:05:00+00:00 EmrJobFlowSensor 2021-05-09T16:06:01.584845+00:00 2021-05-09T16:14:04.194765+00:00 0:08:02.609920 26237 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T16:05:58.941242+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-09T15:05:00+00:00 EmrCreateJobFlowOperator 2021-05-09T16:05:39.066703+00:00 2021-05-09T16:05:40.759946+00:00 0:00:01.693243 26236 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T16:05:36.689156+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-09T15:05:00+00:00 PythonOperator 2021-05-09T16:05:18.767071+00:00 2021-05-09T16:05:21.834806+00:00 0:00:03.067735 26235 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T16:05:16.679663+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T15:00:00+00:00 EmrJobFlowSensor 2021-05-09T16:00:58.609670+00:00 2021-05-09T16:10:01.452578+00:00 0:09:02.842908 26234 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T16:00:56.278393+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T16:00:38.400875+00:00 2021-05-09T16:00:40.094965+00:00 0:00:01.694090 26233 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T16:00:36.248751+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T15:00:00+00:00 PythonOperator 2021-05-09T16:00:16.471192+00:00 2021-05-09T16:00:19.589059+00:00 0:00:03.117867 26232 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T16:00:14.226084+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-09T14:00:00+00:00 EmrJobFlowSensor 2021-05-09T15:12:27.808752+00:00 2021-05-09T15:21:30.423430+00:00 0:09:02.614678 26231 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T15:12:25.260277+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-09T14:00:00+00:00 EmrJobFlowSensor 2021-05-09T15:12:25.506807+00:00 2021-05-09T15:22:28.695740+00:00 0:10:03.188933 26230 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T15:12:23.257582+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-09T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T15:12:07.296438+00:00 2021-05-09T15:12:09.029982+00:00 0:00:01.733544 26229 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T15:12:05.139701+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-09T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T15:12:05.505305+00:00 2021-05-09T15:12:07.315496+00:00 0:00:01.810191 26228 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T15:12:03.151715+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-09T14:00:00+00:00 PythonOperator 2021-05-09T15:11:45.382585+00:00 2021-05-09T15:11:48.540030+00:00 0:00:03.157445 26227 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T15:11:43.121436+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-09T14:00:00+00:00 PythonOperator 2021-05-09T15:11:43.285758+00:00 2021-05-09T15:11:46.582853+00:00 0:00:03.297095 26226 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T15:11:41.120763+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T14:00:00+00:00 TriggerDagRunOperator 2021-05-09T15:11:25.418392+00:00 2021-05-09T15:11:25.916866+00:00 0:00:00.498474 26225 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T15:11:23.103881+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T14:00:00+00:00 TriggerDagRunOperator 2021-05-09T15:11:25.289698+00:00 2021-05-09T15:11:25.685375+00:00 0:00:00.395677 26224 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T15:11:23.103847+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-09T14:05:00+00:00 EmrJobFlowSensor 2021-05-09T15:07:13.083742+00:00 2021-05-09T15:15:15.588066+00:00 0:08:02.504324 26223 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T15:07:10.782826+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-09T14:05:00+00:00 EmrCreateJobFlowOperator 2021-05-09T15:06:50.841195+00:00 2021-05-09T15:06:52.513194+00:00 0:00:01.671999 26222 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T15:06:48.715736+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-09T14:05:00+00:00 PythonOperator 2021-05-09T15:06:31.360553+00:00 2021-05-09T15:06:34.362761+00:00 0:00:03.002208 26221 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T15:06:28.754964+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T14:00:00+00:00 EmrJobFlowSensor 2021-05-09T15:00:49.828413+00:00 2021-05-09T15:10:52.604670+00:00 0:10:02.776257 26219 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T15:00:47.644940+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T15:00:27.901541+00:00 2021-05-09T15:00:29.687680+00:00 0:00:01.786139 26218 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T15:00:25.614711+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T14:00:00+00:00 PythonOperator 2021-05-09T15:00:06.217727+00:00 2021-05-09T15:00:09.332720+00:00 0:00:03.114993 26217 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T15:00:03.647861+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-09T13:00:00+00:00 EmrJobFlowSensor 2021-05-09T14:14:24.814742+00:00 2021-05-09T14:24:27.630058+00:00 0:10:02.815316 26216 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T14:14:22.642101+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-09T13:00:00+00:00 EmrJobFlowSensor 2021-05-09T14:14:09.305173+00:00 2021-05-09T14:22:11.859553+00:00 0:08:02.554380 26215 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T14:14:06.647615+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-09T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T14:14:02.942309+00:00 2021-05-09T14:14:04.684896+00:00 0:00:01.742587 26214 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T14:14:00.662690+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-09T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T14:13:46.921781+00:00 2021-05-09T14:13:48.718428+00:00 0:00:01.796647 26213 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T14:13:44.546515+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-09T13:00:00+00:00 PythonOperator 2021-05-09T14:13:40.761213+00:00 2021-05-09T14:13:44.119560+00:00 0:00:03.358347 26212 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T14:13:38.544181+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-09T13:00:00+00:00 PythonOperator 2021-05-09T14:13:26.903153+00:00 2021-05-09T14:13:29.983157+00:00 0:00:03.080004 26211 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T14:13:24.400263+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T13:00:00+00:00 TriggerDagRunOperator 2021-05-09T14:13:18.795375+00:00 2021-05-09T14:13:19.302828+00:00 0:00:00.507453 26210 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T14:13:16.393276+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T13:00:00+00:00 TriggerDagRunOperator 2021-05-09T14:13:18.581953+00:00 2021-05-09T14:13:18.993051+00:00 0:00:00.411098 26209 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T14:13:16.393232+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-09T13:05:00+00:00 EmrJobFlowSensor 2021-05-09T14:06:05.953270+00:00 2021-05-09T14:15:08.626367+00:00 0:09:02.673097 26208 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T14:06:03.676053+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-09T13:05:00+00:00 EmrCreateJobFlowOperator 2021-05-09T14:05:45.983692+00:00 2021-05-09T14:05:47.639252+00:00 0:00:01.655560 26207 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T14:05:43.591092+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-09T13:05:00+00:00 PythonOperator 2021-05-09T14:05:23.843803+00:00 2021-05-09T14:05:26.988874+00:00 0:00:03.145071 26206 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T14:05:21.518447+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T13:00:00+00:00 EmrJobFlowSensor 2021-05-09T14:04:11.493783+00:00 2021-05-09T14:13:14.254327+00:00 0:09:02.760544 26205 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T14:04:09.373558+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T14:03:51.465750+00:00 2021-05-09T14:03:53.154825+00:00 0:00:01.689075 26204 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T14:03:49.306514+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T13:00:00+00:00 PythonOperator 2021-05-09T14:03:29.900679+00:00 2021-05-09T14:03:33.055893+00:00 0:00:03.155214 26203 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T14:03:27.226894+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-09T12:00:00+00:00 EmrJobFlowSensor 2021-05-09T13:11:33.549858+00:00 2021-05-09T13:19:36.164436+00:00 0:08:02.614578 26201 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T13:11:31.160392+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-09T12:00:00+00:00 EmrJobFlowSensor 2021-05-09T13:11:27.390897+00:00 2021-05-09T13:20:30.062451+00:00 0:09:02.671554 26200 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T13:11:25.177195+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-09T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T13:11:05.394370+00:00 2021-05-09T13:11:07.193736+00:00 0:00:01.799366 26199 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T13:11:03.085317+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-09T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T13:11:03.185862+00:00 2021-05-09T13:11:04.963309+00:00 0:00:01.777447 26198 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T13:11:01.083264+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-09T12:00:00+00:00 PythonOperator 2021-05-09T13:10:39.592942+00:00 2021-05-09T13:10:42.906598+00:00 0:00:03.313656 26197 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T13:10:37.022078+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-09T12:00:00+00:00 PythonOperator 2021-05-09T13:10:37.093806+00:00 2021-05-09T13:10:40.144033+00:00 0:00:03.050227 26196 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T13:10:35.018999+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T12:00:00+00:00 TriggerDagRunOperator 2021-05-09T13:10:17.522399+00:00 2021-05-09T13:10:18.098459+00:00 0:00:00.576060 26195 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T13:10:15.056227+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T12:00:00+00:00 TriggerDagRunOperator 2021-05-09T13:10:17.477610+00:00 2021-05-09T13:10:17.887525+00:00 0:00:00.409915 26194 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T13:10:15.056197+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-09T12:05:00+00:00 EmrJobFlowSensor 2021-05-09T13:05:52.562274+00:00 2021-05-09T13:14:55.154530+00:00 0:09:02.592256 26193 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T13:05:50.499207+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-09T12:05:00+00:00 EmrCreateJobFlowOperator 2021-05-09T13:05:30.709207+00:00 2021-05-09T13:05:32.490972+00:00 0:00:01.781765 26192 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T13:05:28.450662+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-09T12:05:00+00:00 PythonOperator 2021-05-09T13:05:08.542620+00:00 2021-05-09T13:05:11.684521+00:00 0:00:03.141901 26191 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T13:05:06.341062+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T12:00:00+00:00 EmrJobFlowSensor 2021-05-09T13:00:54.390255+00:00 2021-05-09T13:09:56.995509+00:00 0:09:02.605254 26190 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T13:00:52.050590+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T13:00:34.269745+00:00 2021-05-09T13:00:36.152263+00:00 0:00:01.882518 26189 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T13:00:31.925129+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T12:00:00+00:00 PythonOperator 2021-05-09T13:00:12.562018+00:00 2021-05-09T13:00:15.745269+00:00 0:00:03.183251 26188 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T13:00:09.904912+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-09T11:00:00+00:00 EmrJobFlowSensor 2021-05-09T12:11:32.418450+00:00 2021-05-09T12:20:34.920546+00:00 0:09:02.502096 26186 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T12:11:29.956402+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-09T11:00:00+00:00 EmrJobFlowSensor 2021-05-09T12:11:26.116443+00:00 2021-05-09T12:20:29.010122+00:00 0:09:02.893679 26185 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T12:11:23.809418+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-09T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T12:11:09.885247+00:00 2021-05-09T12:11:11.593101+00:00 0:00:01.707854 26184 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T12:11:07.757017+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-09T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T12:11:06.121166+00:00 2021-05-09T12:11:07.967184+00:00 0:00:01.846018 26183 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T12:11:03.759828+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-09T11:00:00+00:00 PythonOperator 2021-05-09T12:10:48.250548+00:00 2021-05-09T12:10:51.526241+00:00 0:00:03.275693 26182 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T12:10:45.762085+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-09T11:00:00+00:00 PythonOperator 2021-05-09T12:10:43.977183+00:00 2021-05-09T12:10:47.124619+00:00 0:00:03.147436 26181 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T12:10:41.748769+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T11:00:00+00:00 TriggerDagRunOperator 2021-05-09T12:10:14.251794+00:00 2021-05-09T12:10:14.791756+00:00 0:00:00.539962 26180 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T12:10:11.679983+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T11:00:00+00:00 TriggerDagRunOperator 2021-05-09T12:10:13.926435+00:00 2021-05-09T12:10:14.378142+00:00 0:00:00.451707 26179 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T12:10:11.679952+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-09T11:05:00+00:00 EmrJobFlowSensor 2021-05-09T12:06:05.464462+00:00 2021-05-09T12:15:08.145917+00:00 0:09:02.681455 26178 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T12:06:03.382438+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-09T11:05:00+00:00 EmrCreateJobFlowOperator 2021-05-09T12:05:43.404092+00:00 2021-05-09T12:05:45.007689+00:00 0:00:01.603597 26177 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T12:05:41.231629+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-09T11:05:00+00:00 PythonOperator 2021-05-09T12:05:23.372026+00:00 2021-05-09T12:05:26.423965+00:00 0:00:03.051939 26176 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T12:05:21.213462+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T11:00:00+00:00 EmrJobFlowSensor 2021-05-09T12:01:05.030532+00:00 2021-05-09T12:10:07.793102+00:00 0:09:02.762570 26175 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T12:01:02.684084+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T12:00:43.066492+00:00 2021-05-09T12:00:44.994980+00:00 0:00:01.928488 26174 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T12:00:40.669118+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T11:00:00+00:00 PythonOperator 2021-05-09T12:00:21.048312+00:00 2021-05-09T12:00:24.152582+00:00 0:00:03.104270 26173 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T12:00:18.608207+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-09T10:00:00+00:00 EmrJobFlowSensor 2021-05-09T11:10:25.947784+00:00 2021-05-09T11:20:28.708252+00:00 0:10:02.760468 26171 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T11:10:23.823878+00:00 2 default_pool