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 vc-asset-import_v002 create_emr_steps 2021-04-01T20:05:00+00:00 PythonOperator 2021-04-01T21:05:10.379516+00:00 2021-04-01T21:05:13.155537+00:00 0:00:02.776021 12526 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T21:05:08.184694+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T20:00:00+00:00 EmrJobFlowSensor 2021-04-01T21:01:06.234057+00:00 2021-04-01T21:11:09.142288+00:00 0:10:02.908231 12525 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T21:01:03.867349+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T21:00:45.997707+00:00 2021-04-01T21:00:47.692572+00:00 0:00:01.694865 12524 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T21:00:43.795821+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T20:00:00+00:00 PythonOperator 2021-04-01T21:00:24.285050+00:00 2021-04-01T21:00:27.055720+00:00 0:00:02.770670 12523 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T21:00:21.740604+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T19:00:00+00:00 EmrJobFlowSensor 2021-04-01T20:12:06.029516+00:00 2021-04-01T20:20:08.588440+00:00 0:08:02.558924 12521 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T20:12:03.547619+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T19:00:00+00:00 EmrJobFlowSensor 2021-04-01T20:11:57.953525+00:00 2021-04-01T20:22:00.744226+00:00 0:10:02.790701 12520 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T20:11:55.550594+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T20:11:43.817545+00:00 2021-04-01T20:11:45.589529+00:00 0:00:01.771984 12519 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T20:11:41.532047+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T20:11:36.001545+00:00 2021-04-01T20:11:37.710340+00:00 0:00:01.708795 12518 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T20:11:33.524650+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T19:00:00+00:00 PythonOperator 2021-04-01T20:11:24.307607+00:00 2021-04-01T20:11:27.009011+00:00 0:00:02.701404 12517 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T20:11:21.511109+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T19:00:00+00:00 PythonOperator 2021-04-01T20:11:13.806375+00:00 2021-04-01T20:11:16.808855+00:00 0:00:03.002480 12516 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T20:11:11.505800+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T19:00:00+00:00 TriggerDagRunOperator 2021-04-01T20:11:08.066553+00:00 2021-04-01T20:11:08.712758+00:00 0:00:00.646205 12515 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T20:11:05.483693+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T19:00:00+00:00 TriggerDagRunOperator 2021-04-01T20:11:07.628398+00:00 2021-04-01T20:11:08.063001+00:00 0:00:00.434603 12514 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T20:11:05.483722+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T19:05:00+00:00 EmrJobFlowSensor 2021-04-01T20:05:47.053501+00:00 2021-04-01T20:14:49.737105+00:00 0:09:02.683604 12513 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T20:05:44.756509+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T19:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T20:05:26.852442+00:00 2021-04-01T20:05:28.647872+00:00 0:00:01.795430 12512 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T20:05:24.630527+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T19:05:00+00:00 PythonOperator 2021-04-01T20:05:04.761699+00:00 2021-04-01T20:05:07.470341+00:00 0:00:02.708642 12511 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T20:05:02.612476+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T19:00:00+00:00 EmrJobFlowSensor 2021-04-01T20:00:52.583263+00:00 2021-04-01T20:10:55.503177+00:00 0:10:02.919914 12510 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T20:00:50.242929+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T20:00:30.739327+00:00 2021-04-01T20:00:32.440818+00:00 0:00:01.701491 12509 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T20:00:28.353612+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T19:00:00+00:00 PythonOperator 2021-04-01T20:00:06.621476+00:00 2021-04-01T20:00:09.414309+00:00 0:00:02.792833 12508 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T20:00:04.220894+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T18:00:00+00:00 EmrJobFlowSensor 2021-04-01T19:11:42.103574+00:00 2021-04-01T19:21:44.785008+00:00 0:10:02.681434 12506 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T19:11:39.955210+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T18:00:00+00:00 EmrJobFlowSensor 2021-04-01T19:11:32.585057+00:00 2021-04-01T19:21:35.309576+00:00 0:10:02.724519 12505 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T19:11:29.944335+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T19:11:20.204742+00:00 2021-04-01T19:11:21.971506+00:00 0:00:01.766764 12504 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T19:11:17.936601+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T19:11:10.385833+00:00 2021-04-01T19:11:12.241403+00:00 0:00:01.855570 12503 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T19:11:07.985595+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T18:00:00+00:00 PythonOperator 2021-04-01T19:10:58.112083+00:00 2021-04-01T19:11:01.048666+00:00 0:00:02.936583 12502 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T19:10:55.919071+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T18:00:00+00:00 PythonOperator 2021-04-01T19:10:42.127756+00:00 2021-04-01T19:10:44.852989+00:00 0:00:02.725233 12501 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T19:10:39.899364+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T18:00:00+00:00 TriggerDagRunOperator 2021-04-01T19:10:36.220004+00:00 2021-04-01T19:10:36.763646+00:00 0:00:00.543642 12500 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T19:10:33.895425+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T18:00:00+00:00 TriggerDagRunOperator 2021-04-01T19:10:36.098678+00:00 2021-04-01T19:10:36.508638+00:00 0:00:00.409960 12499 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T19:10:33.895391+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T18:05:00+00:00 EmrJobFlowSensor 2021-04-01T19:05:55.663379+00:00 2021-04-01T19:14:58.316432+00:00 0:09:02.653053 12498 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T19:05:53.520980+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T19:05:33.898078+00:00 2021-04-01T19:05:35.618737+00:00 0:00:01.720659 12497 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T19:05:31.518858+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T18:05:00+00:00 PythonOperator 2021-04-01T19:05:11.948713+00:00 2021-04-01T19:05:14.633504+00:00 0:00:02.684791 12496 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T19:05:09.554670+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T18:00:00+00:00 EmrJobFlowSensor 2021-04-01T19:01:07.107809+00:00 2021-04-01T19:10:09.764630+00:00 0:09:02.656821 12495 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T19:01:04.908687+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T19:00:45.281939+00:00 2021-04-01T19:00:46.988306+00:00 0:00:01.706367 12494 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T19:00:42.901150+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T18:00:00+00:00 PythonOperator 2021-04-01T19:00:25.104855+00:00 2021-04-01T19:00:27.874495+00:00 0:00:02.769640 12493 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T19:00:22.845482+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T17:00:00+00:00 EmrJobFlowSensor 2021-04-01T18:11:40.298330+00:00 2021-04-01T18:21:43.090368+00:00 0:10:02.792038 12491 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T18:11:38.057053+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T17:00:00+00:00 EmrJobFlowSensor 2021-04-01T18:11:36.422225+00:00 2021-04-01T18:20:39.209546+00:00 0:09:02.787321 12490 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T18:11:34.045183+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T18:11:18.288186+00:00 2021-04-01T18:11:20.017102+00:00 0:00:01.728916 12489 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T18:11:15.919951+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T18:11:14.349614+00:00 2021-04-01T18:11:16.203143+00:00 0:00:01.853529 12488 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T18:11:11.916838+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T17:00:00+00:00 PythonOperator 2021-04-01T18:10:56.580374+00:00 2021-04-01T18:10:59.267561+00:00 0:00:02.687187 12487 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T18:10:53.967573+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T17:00:00+00:00 PythonOperator 2021-04-01T18:10:52.516737+00:00 2021-04-01T18:10:55.620894+00:00 0:00:03.104157 12486 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T18:10:49.960906+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T17:00:00+00:00 TriggerDagRunOperator 2021-04-01T18:10:40.542926+00:00 2021-04-01T18:10:41.044391+00:00 0:00:00.501465 12485 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T18:10:37.891882+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T17:00:00+00:00 TriggerDagRunOperator 2021-04-01T18:10:40.193413+00:00 2021-04-01T18:10:40.617768+00:00 0:00:00.424355 12484 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T18:10:37.891851+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T17:05:00+00:00 EmrJobFlowSensor 2021-04-01T18:05:55.675487+00:00 2021-04-01T18:14:58.264953+00:00 0:09:02.589466 12483 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T18:05:53.325300+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T17:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T18:05:33.491679+00:00 2021-04-01T18:05:35.131946+00:00 0:00:01.640267 12482 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T18:05:31.307279+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T17:05:00+00:00 PythonOperator 2021-04-01T18:05:11.602951+00:00 2021-04-01T18:05:14.285767+00:00 0:00:02.682816 12481 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T18:05:09.289775+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T17:00:00+00:00 EmrJobFlowSensor 2021-04-01T18:01:15.151390+00:00 2021-04-01T18:10:18.005557+00:00 0:09:02.854167 12480 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T18:01:12.801517+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T18:00:52.994750+00:00 2021-04-01T18:00:54.673818+00:00 0:00:01.679068 12479 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T18:00:50.786472+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T17:00:00+00:00 PythonOperator 2021-04-01T18:00:21.151002+00:00 2021-04-01T18:00:24.018348+00:00 0:00:02.867346 12478 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T18:00:18.758794+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T16:00:00+00:00 EmrJobFlowSensor 2021-04-01T17:10:10.647198+00:00 2021-04-01T17:20:13.403656+00:00 0:10:02.756458 12476 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T17:10:07.932068+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T16:00:00+00:00 EmrJobFlowSensor 2021-04-01T17:10:08.214430+00:00 2021-04-01T17:20:11.369806+00:00 0:10:03.155376 12475 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T17:10:05.934346+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T17:09:48.421902+00:00 2021-04-01T17:09:50.198345+00:00 0:00:01.776443 12474 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T17:09:45.957309+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T17:09:46.458194+00:00 2021-04-01T17:09:48.265773+00:00 0:00:01.807579 12473 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T17:09:43.995540+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T16:00:00+00:00 PythonOperator 2021-04-01T17:09:26.484690+00:00 2021-04-01T17:09:29.356431+00:00 0:00:02.871741 12472 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T17:09:23.977387+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T16:00:00+00:00 PythonOperator 2021-04-01T17:09:24.339645+00:00 2021-04-01T17:09:27.317214+00:00 0:00:02.977569 12471 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T17:09:21.963354+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T16:00:00+00:00 TriggerDagRunOperator 2021-04-01T17:09:20.327845+00:00 2021-04-01T17:09:20.847089+00:00 0:00:00.519244 12470 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T17:09:17.958607+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T16:00:00+00:00 TriggerDagRunOperator 2021-04-01T17:09:20.217956+00:00 2021-04-01T17:09:20.648227+00:00 0:00:00.430271 12469 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T17:09:17.958561+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T16:05:00+00:00 EmrJobFlowSensor 2021-04-01T17:06:03.768299+00:00 2021-04-01T17:14:06.250794+00:00 0:08:02.482495 12468 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T17:06:01.560532+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T16:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T17:05:41.828894+00:00 2021-04-01T17:05:43.556935+00:00 0:00:01.728041 12467 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T17:05:39.515636+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T16:05:00+00:00 PythonOperator 2021-04-01T17:05:21.685649+00:00 2021-04-01T17:05:24.386700+00:00 0:00:02.701051 12466 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T17:05:19.500671+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T16:00:00+00:00 EmrJobFlowSensor 2021-04-01T17:01:05.380202+00:00 2021-04-01T17:09:07.933639+00:00 0:08:02.553437 12465 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T17:01:02.982073+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T17:00:31.256483+00:00 2021-04-01T17:00:32.931915+00:00 0:00:01.675432 12464 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T17:00:28.970215+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T16:00:00+00:00 PythonOperator 2021-04-01T17:00:11.193451+00:00 2021-04-01T17:00:13.968223+00:00 0:00:02.774772 12463 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T17:00:08.919901+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T15:00:00+00:00 EmrJobFlowSensor 2021-04-01T16:12:29.801454+00:00 2021-04-01T16:22:32.556587+00:00 0:10:02.755133 12461 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T16:12:27.390565+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T15:00:00+00:00 EmrJobFlowSensor 2021-04-01T16:12:17.696966+00:00 2021-04-01T16:21:20.343419+00:00 0:09:02.646453 12460 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T16:12:15.378979+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T16:12:07.776763+00:00 2021-04-01T16:12:09.516407+00:00 0:00:01.739644 12459 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T16:12:05.369177+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T16:11:55.621782+00:00 2021-04-01T16:11:57.290970+00:00 0:00:01.669188 12458 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T16:11:53.315117+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T15:00:00+00:00 PythonOperator 2021-04-01T16:11:47.725519+00:00 2021-04-01T16:11:50.695384+00:00 0:00:02.969865 12457 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T16:11:45.355534+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T15:00:00+00:00 PythonOperator 2021-04-01T16:11:33.864587+00:00 2021-04-01T16:11:36.659505+00:00 0:00:02.794918 12456 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T16:11:31.288673+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T15:00:00+00:00 TriggerDagRunOperator 2021-04-01T16:11:27.557851+00:00 2021-04-01T16:11:28.064071+00:00 0:00:00.506220 12455 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T16:11:25.189808+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T15:00:00+00:00 TriggerDagRunOperator 2021-04-01T16:11:27.401747+00:00 2021-04-01T16:11:27.830050+00:00 0:00:00.428303 12454 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T16:11:25.189780+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T15:05:00+00:00 EmrJobFlowSensor 2021-04-01T16:06:01.179657+00:00 2021-04-01T16:15:03.826067+00:00 0:09:02.646410 12453 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T16:05:58.670770+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T15:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T16:05:39.009286+00:00 2021-04-01T16:05:40.708846+00:00 0:00:01.699560 12452 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T16:05:36.546294+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T15:05:00+00:00 PythonOperator 2021-04-01T16:05:18.770784+00:00 2021-04-01T16:05:21.519066+00:00 0:00:02.748282 12451 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T16:05:16.445497+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T15:00:00+00:00 EmrJobFlowSensor 2021-04-01T16:01:04.366110+00:00 2021-04-01T16:11:07.230000+00:00 0:10:02.863890 12450 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T16:01:02.031050+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T16:00:42.177087+00:00 2021-04-01T16:00:44.005050+00:00 0:00:01.827963 12449 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T16:00:40.011944+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T15:00:00+00:00 PythonOperator 2021-04-01T16:00:20.297333+00:00 2021-04-01T16:00:23.012639+00:00 0:00:02.715306 12448 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T16:00:17.994733+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T14:00:00+00:00 EmrJobFlowSensor 2021-04-01T15:12:26.898661+00:00 2021-04-01T15:21:29.536119+00:00 0:09:02.637458 12446 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T15:12:24.552355+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T14:00:00+00:00 EmrJobFlowSensor 2021-04-01T15:12:25.066052+00:00 2021-04-01T15:21:27.649545+00:00 0:09:02.583493 12445 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T15:12:22.642126+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T15:12:06.602372+00:00 2021-04-01T15:12:08.321389+00:00 0:00:01.719017 12444 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T15:12:04.398499+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T15:12:02.644178+00:00 2021-04-01T15:12:04.364220+00:00 0:00:01.720042 12443 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T15:12:00.381962+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T14:00:00+00:00 PythonOperator 2021-04-01T15:11:44.709844+00:00 2021-04-01T15:11:47.680970+00:00 0:00:02.971126 12442 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T15:11:42.256577+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T14:00:00+00:00 PythonOperator 2021-04-01T15:11:40.531187+00:00 2021-04-01T15:11:43.355742+00:00 0:00:02.824555 12441 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T15:11:38.253889+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T14:00:00+00:00 TriggerDagRunOperator 2021-04-01T15:11:18.824887+00:00 2021-04-01T15:11:19.354302+00:00 0:00:00.529415 12440 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T15:11:16.234401+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T14:00:00+00:00 TriggerDagRunOperator 2021-04-01T15:11:18.696824+00:00 2021-04-01T15:11:19.119119+00:00 0:00:00.422295 12439 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T15:11:16.234432+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T14:05:00+00:00 EmrJobFlowSensor 2021-04-01T15:05:57.982446+00:00 2021-04-01T15:15:00.735862+00:00 0:09:02.753416 12438 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T15:05:55.789233+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T14:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T15:05:36.092495+00:00 2021-04-01T15:05:37.841666+00:00 0:00:01.749171 12437 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T15:05:33.727664+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T14:05:00+00:00 PythonOperator 2021-04-01T15:05:14.117314+00:00 2021-04-01T15:05:16.892941+00:00 0:00:02.775627 12436 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T15:05:11.751221+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T14:00:00+00:00 EmrJobFlowSensor 2021-04-01T15:00:59.503258+00:00 2021-04-01T15:11:02.394667+00:00 0:10:02.891409 12435 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T15:00:57.111371+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T15:00:37.321488+00:00 2021-04-01T15:00:39.110182+00:00 0:00:01.788694 12434 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T15:00:35.085979+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T14:00:00+00:00 PythonOperator 2021-04-01T15:00:17.449253+00:00 2021-04-01T15:00:20.302947+00:00 0:00:02.853694 12433 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T15:00:15.011662+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T13:00:00+00:00 EmrJobFlowSensor 2021-04-01T14:12:24.322999+00:00 2021-04-01T14:20:26.805187+00:00 0:08:02.482188 12431 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T14:12:21.963873+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T13:00:00+00:00 EmrJobFlowSensor 2021-04-01T14:12:08.484070+00:00 2021-04-01T14:23:11.605377+00:00 0:11:03.121307 12430 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T14:12:05.958317+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T14:12:04.315523+00:00 2021-04-01T14:12:06.001254+00:00 0:00:01.685731 12429 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T14:12:01.945874+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T14:11:48.177484+00:00 2021-04-01T14:11:49.997361+00:00 0:00:01.819877 12428 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T14:11:45.844735+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T13:00:00+00:00 PythonOperator 2021-04-01T14:11:42.074276+00:00 2021-04-01T14:11:44.897010+00:00 0:00:02.822734 12427 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T14:11:39.840105+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T13:00:00+00:00 PythonOperator 2021-04-01T14:11:26.081499+00:00 2021-04-01T14:11:29.029730+00:00 0:00:02.948231 12426 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T14:11:23.825711+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T13:00:00+00:00 TriggerDagRunOperator 2021-04-01T14:11:20.231327+00:00 2021-04-01T14:11:20.762993+00:00 0:00:00.531666 12425 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T14:11:17.822796+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T13:00:00+00:00 TriggerDagRunOperator 2021-04-01T14:11:20.034925+00:00 2021-04-01T14:11:20.459459+00:00 0:00:00.424534 12424 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T14:11:17.822762+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T13:05:00+00:00 EmrJobFlowSensor 2021-04-01T14:06:05.579545+00:00 2021-04-01T14:14:08.130773+00:00 0:08:02.551228 12423 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T14:06:03.290693+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T13:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T14:05:45.670537+00:00 2021-04-01T14:05:47.383531+00:00 0:00:01.712994 12422 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T14:05:43.236368+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T13:05:00+00:00 PythonOperator 2021-04-01T14:05:23.367536+00:00 2021-04-01T14:05:26.138936+00:00 0:00:02.771400 12421 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T14:05:21.217753+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T13:00:00+00:00 EmrJobFlowSensor 2021-04-01T14:00:53.587444+00:00 2021-04-01T14:10:56.540986+00:00 0:10:02.953542 12420 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T14:00:50.808850+00:00 2 default_pool