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_cluster_and_add_emr_steps 2021-04-15T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T07:10:00.328194+00:00 2021-04-15T07:10:02.320200+00:00 0:00:01.992006 17382 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T07:09:57.358643+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-15T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T07:09:47.479256+00:00 2021-04-15T07:09:49.231064+00:00 0:00:01.751808 17381 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T07:09:45.250133+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-15T06:00:00+00:00 PythonOperator 2021-04-15T07:09:37.530107+00:00 2021-04-15T07:09:40.879360+00:00 0:00:03.349253 17380 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T07:09:35.220357+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-15T06:00:00+00:00 PythonOperator 2021-04-15T07:09:25.497281+00:00 2021-04-15T07:09:28.405202+00:00 0:00:02.907921 17379 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T07:09:23.203982+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-15T06:00:00+00:00 TriggerDagRunOperator 2021-04-15T07:09:19.682992+00:00 2021-04-15T07:09:20.216802+00:00 0:00:00.533810 17378 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T07:09:17.205871+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-15T06:00:00+00:00 TriggerDagRunOperator 2021-04-15T07:09:19.390337+00:00 2021-04-15T07:09:19.844699+00:00 0:00:00.454362 17377 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T07:09:17.205822+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-15T06:05:00+00:00 EmrJobFlowSensor 2021-04-15T07:06:01.092541+00:00 2021-04-15T07:16:03.907399+00:00 0:10:02.814858 17376 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T07:05:58.876061+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-15T06:05:00+00:00 EmrCreateJobFlowOperator 2021-04-15T07:05:39.240471+00:00 2021-04-15T07:05:40.902271+00:00 0:00:01.661800 17375 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T07:05:36.879474+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-15T06:05:00+00:00 PythonOperator 2021-04-15T07:05:18.981034+00:00 2021-04-15T07:05:21.841092+00:00 0:00:02.860058 17374 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T07:05:16.801298+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-15T06:00:00+00:00 EmrJobFlowSensor 2021-04-15T07:01:00.716737+00:00 2021-04-15T07:09:03.243792+00:00 0:08:02.527055 17373 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T07:00:58.356018+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-15T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T07:00:38.613176+00:00 2021-04-15T07:00:40.400613+00:00 0:00:01.787437 17372 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-15T07:00:36.243385+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-15T06:00:00+00:00 PythonOperator 2021-04-15T07:00:18.694483+00:00 2021-04-15T07:00:21.643954+00:00 0:00:02.949471 17371 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-15T07:00:16.226194+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-15T05:00:00+00:00 EmrJobFlowSensor 2021-04-15T06:11:24.694210+00:00 2021-04-15T06:21:27.478855+00:00 0:10:02.784645 17369 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T06:11:22.333784+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-15T05:00:00+00:00 EmrJobFlowSensor 2021-04-15T06:11:12.610314+00:00 2021-04-15T06:20:15.264246+00:00 0:09:02.653932 17368 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T06:11:10.321828+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-15T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T06:11:04.897406+00:00 2021-04-15T06:11:06.744383+00:00 0:00:01.846977 17367 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T06:11:02.378010+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-15T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T06:10:50.316075+00:00 2021-04-15T06:10:52.306153+00:00 0:00:01.990078 17366 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T06:10:48.109100+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-15T05:00:00+00:00 PythonOperator 2021-04-15T06:10:40.514519+00:00 2021-04-15T06:10:43.577309+00:00 0:00:03.062790 17365 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T06:10:38.168222+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-15T05:00:00+00:00 PythonOperator 2021-04-15T06:10:30.524669+00:00 2021-04-15T06:10:33.421732+00:00 0:00:02.897063 17364 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T06:10:28.160560+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-15T05:00:00+00:00 TriggerDagRunOperator 2021-04-15T06:10:25.210581+00:00 2021-04-15T06:10:25.634901+00:00 0:00:00.424320 17363 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T06:10:22.089818+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-15T05:00:00+00:00 TriggerDagRunOperator 2021-04-15T06:10:25.198365+00:00 2021-04-15T06:10:25.752147+00:00 0:00:00.553782 17362 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T06:10:22.089855+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-15T05:05:00+00:00 EmrJobFlowSensor 2021-04-15T06:06:18.112891+00:00 2021-04-15T06:15:20.680380+00:00 0:09:02.567489 17361 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T06:06:15.686799+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-15T05:05:00+00:00 EmrCreateJobFlowOperator 2021-04-15T06:05:55.775856+00:00 2021-04-15T06:05:57.540775+00:00 0:00:01.764919 17360 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T06:05:53.600005+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-15T05:05:00+00:00 PythonOperator 2021-04-15T06:05:23.718551+00:00 2021-04-15T06:05:26.665710+00:00 0:00:02.947159 17359 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T06:05:21.570437+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-15T05:00:00+00:00 EmrJobFlowSensor 2021-04-15T06:00:59.309307+00:00 2021-04-15T06:10:02.024497+00:00 0:09:02.715190 17358 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T06:00:56.956917+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-15T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T06:00:37.178941+00:00 2021-04-15T06:00:38.906156+00:00 0:00:01.727215 17357 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-15T06:00:34.940765+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-15T05:00:00+00:00 PythonOperator 2021-04-15T06:00:17.281244+00:00 2021-04-15T06:00:20.235570+00:00 0:00:02.954326 17356 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-15T06:00:14.919086+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-15T04:00:00+00:00 EmrJobFlowSensor 2021-04-15T05:19:41.062984+00:00 2021-04-15T05:28:43.623619+00:00 0:09:02.560635 17354 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T05:19:38.440729+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-15T04:00:00+00:00 EmrJobFlowSensor 2021-04-15T05:19:30.739486+00:00 2021-04-15T05:27:33.842007+00:00 0:08:03.102521 17353 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T05:19:28.169340+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-15T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T05:19:18.389332+00:00 2021-04-15T05:19:20.086513+00:00 0:00:01.697181 17352 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T05:19:16.054467+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-15T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T05:19:10.594596+00:00 2021-04-15T05:19:12.403900+00:00 0:00:01.809304 17351 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T05:19:08.053147+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-15T04:00:00+00:00 PythonOperator 2021-04-15T05:18:56.192931+00:00 2021-04-15T05:18:59.526415+00:00 0:00:03.333484 17350 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T05:18:53.905103+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-15T04:00:00+00:00 PythonOperator 2021-04-15T05:18:48.145987+00:00 2021-04-15T05:18:51.063997+00:00 0:00:02.918010 17349 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T05:18:45.903731+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-15T04:00:00+00:00 TriggerDagRunOperator 2021-04-15T05:18:34.222306+00:00 2021-04-15T05:18:34.772676+00:00 0:00:00.550370 17348 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T05:18:31.884423+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-15T04:00:00+00:00 TriggerDagRunOperator 2021-04-15T05:18:34.188894+00:00 2021-04-15T05:18:34.580476+00:00 0:00:00.391582 17347 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T05:18:31.884395+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-15T04:05:00+00:00 EmrJobFlowSensor 2021-04-15T05:05:59.023485+00:00 2021-04-15T05:15:01.635409+00:00 0:09:02.611924 17346 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T05:05:56.565649+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-15T04:05:00+00:00 EmrCreateJobFlowOperator 2021-04-15T05:05:36.658496+00:00 2021-04-15T05:05:38.283675+00:00 0:00:01.625179 17345 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T05:05:34.510188+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-15T04:05:00+00:00 PythonOperator 2021-04-15T05:05:17.032611+00:00 2021-04-15T05:05:20.053635+00:00 0:00:03.021024 17344 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T05:05:14.496141+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-15T04:00:00+00:00 EmrJobFlowSensor 2021-04-15T05:01:08.236131+00:00 2021-04-15T05:18:11.875359+00:00 0:17:03.639228 17343 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T05:01:06.037487+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-15T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T05:00:46.540021+00:00 2021-04-15T05:00:48.349716+00:00 0:00:01.809695 17342 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-15T05:00:44.082465+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-15T04:00:00+00:00 PythonOperator 2021-04-15T05:00:24.469823+00:00 2021-04-15T05:00:27.434082+00:00 0:00:02.964259 17341 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-15T05:00:21.995975+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-15T03:00:00+00:00 EmrJobFlowSensor 2021-04-15T04:11:04.866368+00:00 2021-04-15T04:19:07.460073+00:00 0:08:02.593705 17339 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T04:11:02.473657+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-15T03:00:00+00:00 EmrJobFlowSensor 2021-04-15T04:10:50.711051+00:00 2021-04-15T04:19:53.263070+00:00 0:09:02.552019 17338 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T04:10:48.447449+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-15T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T04:10:43.208744+00:00 2021-04-15T04:10:44.839587+00:00 0:00:01.630843 17337 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T04:10:40.463178+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-15T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T04:10:30.977784+00:00 2021-04-15T04:10:32.665860+00:00 0:00:01.688076 17336 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T04:10:28.452864+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-15T03:00:00+00:00 PythonOperator 2021-04-15T04:10:20.592317+00:00 2021-04-15T04:10:23.494772+00:00 0:00:02.902455 17335 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T04:10:18.383318+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-15T03:00:00+00:00 PythonOperator 2021-04-15T04:10:08.708417+00:00 2021-04-15T04:10:11.873336+00:00 0:00:03.164919 17334 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T04:10:06.371317+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-15T03:00:00+00:00 TriggerDagRunOperator 2021-04-15T04:10:02.602277+00:00 2021-04-15T04:10:03.086423+00:00 0:00:00.484146 17333 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T04:10:00.366258+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-15T03:00:00+00:00 TriggerDagRunOperator 2021-04-15T04:10:02.601047+00:00 2021-04-15T04:10:03.174263+00:00 0:00:00.573216 17332 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T04:10:00.366289+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-15T03:05:00+00:00 EmrJobFlowSensor 2021-04-15T04:06:04.177562+00:00 2021-04-15T04:15:06.749691+00:00 0:09:02.572129 17331 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T04:06:01.986351+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-15T03:05:00+00:00 EmrCreateJobFlowOperator 2021-04-15T04:05:42.058865+00:00 2021-04-15T04:05:43.678631+00:00 0:00:01.619766 17330 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T04:05:39.933969+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-15T03:05:00+00:00 PythonOperator 2021-04-15T04:05:14.224243+00:00 2021-04-15T04:05:17.055066+00:00 0:00:02.830823 17329 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T04:05:11.909707+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-15T03:00:00+00:00 EmrJobFlowSensor 2021-04-15T04:00:47.893584+00:00 2021-04-15T04:09:50.760545+00:00 0:09:02.866961 17328 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T04:00:45.540853+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-15T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T04:00:25.844558+00:00 2021-04-15T04:00:27.741616+00:00 0:00:01.897058 17327 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-15T04:00:23.503590+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-15T03:00:00+00:00 PythonOperator 2021-04-15T04:00:03.830921+00:00 2021-04-15T04:00:06.778136+00:00 0:00:02.947215 17326 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-15T04:00:01.459612+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-15T02:00:00+00:00 EmrJobFlowSensor 2021-04-15T03:11:09.091927+00:00 2021-04-15T03:21:11.860174+00:00 0:10:02.768247 17324 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T03:11:06.250720+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-15T02:00:00+00:00 EmrJobFlowSensor 2021-04-15T03:11:06.477087+00:00 2021-04-15T03:21:09.598851+00:00 0:10:03.121764 17323 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T03:11:04.255541+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-15T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T03:10:48.797831+00:00 2021-04-15T03:10:50.539138+00:00 0:00:01.741307 17322 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T03:10:46.134360+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-15T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T03:10:46.408508+00:00 2021-04-15T03:10:48.493696+00:00 0:00:02.085188 17321 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T03:10:44.135217+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-15T02:00:00+00:00 PythonOperator 2021-04-15T03:10:18.408292+00:00 2021-04-15T03:10:21.536347+00:00 0:00:03.128055 17320 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T03:10:16.107556+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-15T02:00:00+00:00 PythonOperator 2021-04-15T03:10:16.492373+00:00 2021-04-15T03:10:19.387840+00:00 0:00:02.895467 17319 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T03:10:14.106369+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-15T02:00:00+00:00 TriggerDagRunOperator 2021-04-15T03:10:04.444612+00:00 2021-04-15T03:10:05.216255+00:00 0:00:00.771643 17318 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T03:10:02.094838+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-15T02:00:00+00:00 TriggerDagRunOperator 2021-04-15T03:10:04.324574+00:00 2021-04-15T03:10:05.012695+00:00 0:00:00.688121 17317 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T03:10:02.094869+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-15T02:05:00+00:00 EmrJobFlowSensor 2021-04-15T03:06:03.825715+00:00 2021-04-15T03:15:06.653093+00:00 0:09:02.827378 17316 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T03:06:01.524137+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-15T02:05:00+00:00 EmrCreateJobFlowOperator 2021-04-15T03:05:41.686171+00:00 2021-04-15T03:05:43.429148+00:00 0:00:01.742977 17315 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T03:05:39.475074+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-15T02:05:00+00:00 PythonOperator 2021-04-15T03:05:21.564159+00:00 2021-04-15T03:05:24.647566+00:00 0:00:03.083407 17314 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T03:05:19.459645+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-15T02:00:00+00:00 EmrJobFlowSensor 2021-04-15T03:00:46.931113+00:00 2021-04-15T03:09:49.723290+00:00 0:09:02.792177 17313 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T03:00:44.729996+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-15T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T03:00:26.951963+00:00 2021-04-15T03:00:28.705854+00:00 0:00:01.753891 17312 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-15T03:00:24.711185+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-15T02:00:00+00:00 PythonOperator 2021-04-15T03:00:05.514390+00:00 2021-04-15T03:00:08.407180+00:00 0:00:02.892790 17311 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-15T03:00:02.752706+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-15T01:00:00+00:00 EmrJobFlowSensor 2021-04-15T02:11:18.425690+00:00 2021-04-15T02:22:21.319531+00:00 0:11:02.893841 17309 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T02:11:16.134338+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-15T01:00:00+00:00 EmrJobFlowSensor 2021-04-15T02:11:12.323680+00:00 2021-04-15T02:21:15.173443+00:00 0:10:02.849763 17308 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T02:11:10.130177+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-15T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T02:10:56.323178+00:00 2021-04-15T02:10:58.055714+00:00 0:00:01.732536 17307 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T02:10:54.120852+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-15T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T02:10:52.617912+00:00 2021-04-15T02:10:54.316832+00:00 0:00:01.698920 17306 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T02:10:50.109059+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-15T01:00:00+00:00 PythonOperator 2021-04-15T02:10:36.662447+00:00 2021-04-15T02:10:39.673866+00:00 0:00:03.011419 17305 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T02:10:34.095415+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-15T01:00:00+00:00 PythonOperator 2021-04-15T02:10:30.893834+00:00 2021-04-15T02:10:34.201002+00:00 0:00:03.307168 17304 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T02:10:28.240883+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-15T01:00:00+00:00 TriggerDagRunOperator 2021-04-15T02:10:16.781323+00:00 2021-04-15T02:10:17.191238+00:00 0:00:00.409915 17303 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T02:10:14.053355+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-15T01:00:00+00:00 TriggerDagRunOperator 2021-04-15T02:10:16.798564+00:00 2021-04-15T02:10:17.313499+00:00 0:00:00.514935 17302 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T02:10:14.053402+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-15T01:05:00+00:00 EmrJobFlowSensor 2021-04-15T02:06:01.733780+00:00 2021-04-15T02:15:04.401781+00:00 0:09:02.668001 17301 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T02:05:59.589564+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-15T01:05:00+00:00 EmrCreateJobFlowOperator 2021-04-15T02:05:39.668758+00:00 2021-04-15T02:05:41.333394+00:00 0:00:01.664636 17300 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T02:05:37.498798+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-15T01:05:00+00:00 PythonOperator 2021-04-15T02:05:19.725962+00:00 2021-04-15T02:05:22.937581+00:00 0:00:03.211619 17299 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T02:05:17.392758+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-15T01:00:00+00:00 EmrJobFlowSensor 2021-04-15T02:00:51.145632+00:00 2021-04-15T02:09:54.170149+00:00 0:09:03.024517 17298 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T02:00:48.825188+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-15T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T02:00:29.094892+00:00 2021-04-15T02:00:30.795255+00:00 0:00:01.700363 17297 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-15T02:00:26.811013+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-15T01:00:00+00:00 PythonOperator 2021-04-15T02:00:09.257859+00:00 2021-04-15T02:00:12.103665+00:00 0:00:02.845806 17296 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-15T02:00:06.790086+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-15T00:00:00+00:00 EmrJobFlowSensor 2021-04-15T01:10:22.201214+00:00 2021-04-15T01:20:25.027637+00:00 0:10:02.826423 17294 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T01:10:19.749709+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-15T00:00:00+00:00 EmrJobFlowSensor 2021-04-15T01:10:13.995878+00:00 2021-04-15T01:18:16.630231+00:00 0:08:02.634353 17293 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T01:10:11.745731+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-15T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T01:09:59.957161+00:00 2021-04-15T01:10:01.801147+00:00 0:00:01.843986 17292 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T01:09:57.701511+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-15T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T01:09:51.911387+00:00 2021-04-15T01:09:53.954975+00:00 0:00:02.043588 17291 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T01:09:49.689401+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-15T00:00:00+00:00 PythonOperator 2021-04-15T01:09:39.903465+00:00 2021-04-15T01:09:43.208046+00:00 0:00:03.304581 17290 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T01:09:37.637193+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-15T00:00:00+00:00 PythonOperator 2021-04-15T01:09:31.836474+00:00 2021-04-15T01:09:34.930465+00:00 0:00:03.093991 17289 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T01:09:29.632057+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-15T00:00:00+00:00 TriggerDagRunOperator 2021-04-15T01:09:16.081082+00:00 2021-04-15T01:09:16.608506+00:00 0:00:00.527424 17288 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T01:09:13.616982+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-15T00:00:00+00:00 TriggerDagRunOperator 2021-04-15T01:09:15.973128+00:00 2021-04-15T01:09:16.391811+00:00 0:00:00.418683 17287 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T01:09:13.616924+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-15T00:05:00+00:00 EmrJobFlowSensor 2021-04-15T01:05:57.378805+00:00 2021-04-15T01:13:59.814474+00:00 0:08:02.435669 17286 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T01:05:55.202400+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-15T00:05:00+00:00 EmrCreateJobFlowOperator 2021-04-15T01:05:35.451986+00:00 2021-04-15T01:05:37.170851+00:00 0:00:01.718865 17285 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T01:05:33.186374+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-15T00:05:00+00:00 PythonOperator 2021-04-15T01:05:13.310006+00:00 2021-04-15T01:05:16.234244+00:00 0:00:02.924238 17284 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T01:05:11.118714+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-15T00:00:00+00:00 EmrJobFlowSensor 2021-04-15T01:01:02.893414+00:00 2021-04-15T01:09:05.379834+00:00 0:08:02.486420 17283 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T01:01:00.551311+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-15T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T01:00:40.667239+00:00 2021-04-15T01:00:42.369720+00:00 0:00:01.702481 17282 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-15T01:00:38.395662+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-15T00:00:00+00:00 PythonOperator 2021-04-15T01:00:18.795281+00:00 2021-04-15T01:00:21.932480+00:00 0:00:03.137199 17281 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-15T01:00:16.334749+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-14T23:00:00+00:00 EmrJobFlowSensor 2021-04-15T00:12:42.223978+00:00 2021-04-15T00:22:45.074621+00:00 0:10:02.850643 17279 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T00:12:40.046776+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-14T23:00:00+00:00 EmrJobFlowSensor 2021-04-15T00:12:26.322649+00:00 2021-04-15T00:21:29.141017+00:00 0:09:02.818368 17278 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T00:12:24.031403+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-14T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T00:12:18.550810+00:00 2021-04-15T00:12:20.379934+00:00 0:00:01.829124 17277 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T00:12:16.071929+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-14T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T00:12:04.862627+00:00 2021-04-15T00:12:06.757559+00:00 0:00:01.894932 17276 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T00:12:02.012875+00:00 2 default_pool