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 trigger_dagrun_booking-processing-job_v002 2021-04-10T04:00:00+00:00 TriggerDagRunOperator 2021-04-10T05:10:04.877547+00:00 2021-04-10T05:10:05.403497+00:00 0:00:00.525950 15532 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T05:10:01.813948+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T04:00:00+00:00 TriggerDagRunOperator 2021-04-10T05:10:04.619132+00:00 2021-04-10T05:10:05.046593+00:00 0:00:00.427461 15531 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T05:10:01.813901+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-10T04:05:00+00:00 EmrJobFlowSensor 2021-04-10T05:05:59.849609+00:00 2021-04-10T05:15:02.694818+00:00 0:09:02.845209 15530 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T05:05:57.388350+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-10T04:05:00+00:00 EmrCreateJobFlowOperator 2021-04-10T05:05:37.555492+00:00 2021-04-10T05:05:39.194749+00:00 0:00:01.639257 15529 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T05:05:35.337725+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-10T04:05:00+00:00 PythonOperator 2021-04-10T05:05:17.623206+00:00 2021-04-10T05:05:20.427025+00:00 0:00:02.803819 15528 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T05:05:15.262253+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T04:00:00+00:00 EmrJobFlowSensor 2021-04-10T05:00:56.823186+00:00 2021-04-10T05:09:59.361153+00:00 0:09:02.537967 15527 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T05:00:54.696059+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T05:00:36.884667+00:00 2021-04-10T05:00:38.582393+00:00 0:00:01.697726 15526 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T05:00:34.683375+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T04:00:00+00:00 PythonOperator 2021-04-10T05:00:13.007419+00:00 2021-04-10T05:00:15.877605+00:00 0:00:02.870186 15525 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T05:00:10.617372+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-10T03:00:00+00:00 EmrJobFlowSensor 2021-04-10T04:12:28.874904+00:00 2021-04-10T04:23:31.808371+00:00 0:11:02.933467 15523 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T04:12:26.607257+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-10T03:00:00+00:00 EmrJobFlowSensor 2021-04-10T04:12:25.007225+00:00 2021-04-10T04:21:27.674797+00:00 0:09:02.667572 15522 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T04:12:22.611000+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-10T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T04:12:06.772208+00:00 2021-04-10T04:12:08.502047+00:00 0:00:01.729839 15521 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T04:12:04.588058+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-10T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T04:12:03.130053+00:00 2021-04-10T04:12:04.859225+00:00 0:00:01.729172 15520 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T04:12:00.655804+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-10T03:00:00+00:00 PythonOperator 2021-04-10T04:11:44.993789+00:00 2021-04-10T04:11:48.224066+00:00 0:00:03.230277 15519 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T04:11:42.572332+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-10T03:00:00+00:00 PythonOperator 2021-04-10T04:11:40.907313+00:00 2021-04-10T04:11:43.767637+00:00 0:00:02.860324 15518 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T04:11:38.489625+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T03:00:00+00:00 TriggerDagRunOperator 2021-04-10T04:11:25.519765+00:00 2021-04-10T04:11:26.024661+00:00 0:00:00.504896 15517 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T04:11:22.486160+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T03:00:00+00:00 TriggerDagRunOperator 2021-04-10T04:11:25.278936+00:00 2021-04-10T04:11:25.700097+00:00 0:00:00.421161 15516 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T04:11:22.486133+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-10T03:05:00+00:00 EmrJobFlowSensor 2021-04-10T04:05:56.281468+00:00 2021-04-10T04:14:58.733897+00:00 0:09:02.452429 15515 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T04:05:53.972858+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-10T03:05:00+00:00 EmrCreateJobFlowOperator 2021-04-10T04:05:34.213122+00:00 2021-04-10T04:05:36.032413+00:00 0:00:01.819291 15514 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T04:05:31.884603+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-10T03:05:00+00:00 PythonOperator 2021-04-10T04:05:14.315667+00:00 2021-04-10T04:05:17.059837+00:00 0:00:02.744170 15513 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T04:05:11.850561+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T03:00:00+00:00 EmrJobFlowSensor 2021-04-10T04:01:01.752430+00:00 2021-04-10T04:11:04.513606+00:00 0:10:02.761176 15512 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T04:00:59.511282+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T04:00:37.744702+00:00 2021-04-10T04:00:39.566996+00:00 0:00:01.822294 15511 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T04:00:35.494713+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T03:00:00+00:00 PythonOperator 2021-04-10T04:00:15.919052+00:00 2021-04-10T04:00:18.761409+00:00 0:00:02.842357 15510 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T04:00:13.478051+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-10T02:00:00+00:00 EmrJobFlowSensor 2021-04-10T03:11:05.904982+00:00 2021-04-10T03:21:08.818144+00:00 0:10:02.913162 15508 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T03:11:03.529708+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-10T02:00:00+00:00 EmrJobFlowSensor 2021-04-10T03:10:57.992010+00:00 2021-04-10T03:19:00.474210+00:00 0:08:02.482200 15507 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T03:10:55.524219+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-10T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T03:10:45.809221+00:00 2021-04-10T03:10:47.512033+00:00 0:00:01.702812 15506 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T03:10:43.514913+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-10T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T03:10:35.899706+00:00 2021-04-10T03:10:37.697293+00:00 0:00:01.797587 15505 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T03:10:33.508065+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-10T02:00:00+00:00 PythonOperator 2021-04-10T03:10:24.212814+00:00 2021-04-10T03:10:27.393146+00:00 0:00:03.180332 15504 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T03:10:21.568146+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-10T02:00:00+00:00 PythonOperator 2021-04-10T03:10:15.686467+00:00 2021-04-10T03:10:18.392687+00:00 0:00:02.706220 15503 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T03:10:13.495272+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T02:00:00+00:00 TriggerDagRunOperator 2021-04-10T03:10:02.142363+00:00 2021-04-10T03:10:02.774395+00:00 0:00:00.632032 15502 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T03:09:59.456246+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T02:00:00+00:00 TriggerDagRunOperator 2021-04-10T03:10:02.131194+00:00 2021-04-10T03:10:02.574626+00:00 0:00:00.443432 15501 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T03:09:59.456197+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-10T02:05:00+00:00 EmrJobFlowSensor 2021-04-10T03:05:49.005514+00:00 2021-04-10T03:13:51.437176+00:00 0:08:02.431662 15500 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T03:05:46.857589+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-10T02:05:00+00:00 EmrCreateJobFlowOperator 2021-04-10T03:05:26.985990+00:00 2021-04-10T03:05:28.661787+00:00 0:00:01.675797 15499 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T03:05:24.846325+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-10T02:05:00+00:00 PythonOperator 2021-04-10T03:05:05.121666+00:00 2021-04-10T03:05:08.165244+00:00 0:00:03.043578 15498 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T03:05:02.803415+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T02:00:00+00:00 EmrJobFlowSensor 2021-04-10T03:00:54.675244+00:00 2021-04-10T03:09:57.335673+00:00 0:09:02.660429 15497 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T03:00:52.301482+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T03:00:32.674202+00:00 2021-04-10T03:00:34.410324+00:00 0:00:01.736122 15496 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T03:00:30.344993+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T02:00:00+00:00 PythonOperator 2021-04-10T03:00:10.539293+00:00 2021-04-10T03:00:13.227382+00:00 0:00:02.688089 15495 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T03:00:08.232021+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-10T01:00:00+00:00 EmrJobFlowSensor 2021-04-10T02:11:58.705355+00:00 2021-04-10T02:30:02.641022+00:00 0:18:03.935667 15493 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T02:11:56.420087+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-10T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T02:11:36.800475+00:00 2021-04-10T02:11:38.514914+00:00 0:00:01.714439 15492 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T02:11:34.459375+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-10T01:00:00+00:00 EmrJobFlowSensor 2021-04-10T02:11:18.985881+00:00 2021-04-10T02:20:21.680457+00:00 0:09:02.694576 15491 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T02:11:16.455076+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-10T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T02:10:46.665826+00:00 2021-04-10T02:10:48.482705+00:00 0:00:01.816879 15490 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T02:10:44.348051+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-10T01:00:00+00:00 PythonOperator 2021-04-10T02:10:22.813768+00:00 2021-04-10T02:10:25.743628+00:00 0:00:02.929860 15489 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T02:10:20.327283+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-10T01:00:00+00:00 PythonOperator 2021-04-10T02:10:18.484227+00:00 2021-04-10T02:10:21.422804+00:00 0:00:02.938577 15488 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T02:10:16.321823+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T01:00:00+00:00 TriggerDagRunOperator 2021-04-10T02:09:56.856916+00:00 2021-04-10T02:09:57.407887+00:00 0:00:00.550971 15487 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T02:09:54.371970+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T01:00:00+00:00 TriggerDagRunOperator 2021-04-10T02:09:56.609878+00:00 2021-04-10T02:09:57.033792+00:00 0:00:00.423914 15486 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T02:09:54.372016+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-10T01:05:00+00:00 EmrJobFlowSensor 2021-04-10T02:06:18.415724+00:00 2021-04-10T02:15:21.217240+00:00 0:09:02.801516 15485 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T02:06:16.048479+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-10T01:05:00+00:00 EmrCreateJobFlowOperator 2021-04-10T02:05:46.453606+00:00 2021-04-10T02:05:48.262629+00:00 0:00:01.809023 15484 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T02:05:44.053039+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-10T01:05:00+00:00 PythonOperator 2021-04-10T02:05:22.300932+00:00 2021-04-10T02:05:24.977613+00:00 0:00:02.676681 15483 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T02:05:20.011971+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T01:00:00+00:00 EmrJobFlowSensor 2021-04-10T02:00:47.785930+00:00 2021-04-10T02:09:50.607227+00:00 0:09:02.821297 15482 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T02:00:45.461912+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T02:00:25.706916+00:00 2021-04-10T02:00:27.591223+00:00 0:00:01.884307 15481 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T02:00:23.389284+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T01:00:00+00:00 PythonOperator 2021-04-10T02:00:04.232363+00:00 2021-04-10T02:00:06.950717+00:00 0:00:02.718354 15480 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T02:00:01.370390+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-10T00:00:00+00:00 EmrJobFlowSensor 2021-04-10T01:11:16.708623+00:00 2021-04-10T01:20:19.394693+00:00 0:09:02.686070 15478 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T01:11:14.501682+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-10T00:00:00+00:00 EmrJobFlowSensor 2021-04-10T01:10:56.630346+00:00 2021-04-10T01:19:59.233308+00:00 0:09:02.602962 15477 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T01:10:54.458743+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-10T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T01:10:54.830501+00:00 2021-04-10T01:10:56.668492+00:00 0:00:01.837991 15476 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T01:10:52.432700+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-10T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T01:10:36.658973+00:00 2021-04-10T01:10:38.460854+00:00 0:00:01.801881 15475 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T01:10:34.406501+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-10T00:00:00+00:00 PythonOperator 2021-04-10T01:10:34.702054+00:00 2021-04-10T01:10:37.432125+00:00 0:00:02.730071 15474 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T01:10:32.408883+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-10T00:00:00+00:00 PythonOperator 2021-04-10T01:10:12.867411+00:00 2021-04-10T01:10:15.813830+00:00 0:00:02.946419 15473 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T01:10:10.459413+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T00:00:00+00:00 TriggerDagRunOperator 2021-04-10T01:10:07.419631+00:00 2021-04-10T01:10:07.975766+00:00 0:00:00.556135 15472 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T01:10:04.457613+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T00:00:00+00:00 TriggerDagRunOperator 2021-04-10T01:10:07.130910+00:00 2021-04-10T01:10:07.578512+00:00 0:00:00.447602 15471 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T01:10:04.457666+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-10T00:05:00+00:00 EmrJobFlowSensor 2021-04-10T01:05:46.371433+00:00 2021-04-10T01:14:49.092745+00:00 0:09:02.721312 15470 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T01:05:44.051255+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-10T00:05:00+00:00 EmrCreateJobFlowOperator 2021-04-10T01:05:24.235871+00:00 2021-04-10T01:05:25.909499+00:00 0:00:01.673628 15469 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T01:05:22.002161+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-10T00:05:00+00:00 PythonOperator 2021-04-10T01:05:04.077366+00:00 2021-04-10T01:05:06.803957+00:00 0:00:02.726591 15468 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T01:05:01.984988+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T00:00:00+00:00 EmrJobFlowSensor 2021-04-10T01:00:56.151354+00:00 2021-04-10T01:09:58.929941+00:00 0:09:02.778587 15467 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T01:00:53.698910+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T01:00:33.912945+00:00 2021-04-10T01:00:35.607978+00:00 0:00:01.695033 15466 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T01:00:31.646751+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T00:00:00+00:00 PythonOperator 2021-04-10T01:00:12.481484+00:00 2021-04-10T01:00:15.221018+00:00 0:00:02.739534 15465 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T01:00:09.526639+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-09T23:00:00+00:00 EmrJobFlowSensor 2021-04-10T00:10:21.774066+00:00 2021-04-10T00:20:24.712619+00:00 0:10:02.938553 15463 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T00:10:18.724131+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-09T23:00:00+00:00 EmrJobFlowSensor 2021-04-10T00:10:19.817075+00:00 2021-04-10T00:21:23.283466+00:00 0:11:03.466391 15462 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T00:10:16.861376+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-09T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T00:09:59.484947+00:00 2021-04-10T00:10:01.280063+00:00 0:00:01.795116 15461 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T00:09:56.763271+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-09T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T00:09:59.289063+00:00 2021-04-10T00:10:00.998717+00:00 0:00:01.709654 15460 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T00:09:56.763328+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-09T23:00:00+00:00 PythonOperator 2021-04-10T00:09:39.637588+00:00 2021-04-10T00:09:42.487907+00:00 0:00:02.850319 15459 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T00:09:36.677429+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-09T23:00:00+00:00 PythonOperator 2021-04-10T00:09:37.281186+00:00 2021-04-10T00:09:40.795443+00:00 0:00:03.514257 15458 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T00:09:34.675784+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T23:00:00+00:00 TriggerDagRunOperator 2021-04-10T00:09:29.131021+00:00 2021-04-10T00:09:29.664043+00:00 0:00:00.533022 15457 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T00:09:26.670190+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T23:00:00+00:00 TriggerDagRunOperator 2021-04-10T00:09:28.891449+00:00 2021-04-10T00:09:29.307355+00:00 0:00:00.415906 15456 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T00:09:26.670157+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-09T23:05:00+00:00 EmrJobFlowSensor 2021-04-10T00:06:04.389735+00:00 2021-04-10T00:15:06.895240+00:00 0:09:02.505505 15455 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T00:06:02.241956+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-09T23:05:00+00:00 EmrCreateJobFlowOperator 2021-04-10T00:05:42.778057+00:00 2021-04-10T00:05:44.559719+00:00 0:00:01.781662 15454 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T00:05:40.278372+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-09T23:05:00+00:00 PythonOperator 2021-04-10T00:05:12.433467+00:00 2021-04-10T00:05:15.183619+00:00 0:00:02.750152 15453 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T00:05:10.197854+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T23:00:00+00:00 EmrJobFlowSensor 2021-04-10T00:01:06.232036+00:00 2021-04-10T00:09:08.735909+00:00 0:08:02.503873 15452 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T00:01:03.940829+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T00:00:44.008820+00:00 2021-04-10T00:00:45.691670+00:00 0:00:01.682850 15451 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T00:00:41.796287+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T23:00:00+00:00 PythonOperator 2021-04-10T00:00:24.237936+00:00 2021-04-10T00:00:27.025864+00:00 0:00:02.787928 15450 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T00:00:21.751504+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-09T22:00:00+00:00 EmrJobFlowSensor 2021-04-09T23:12:13.400667+00:00 2021-04-09T23:21:15.978719+00:00 0:09:02.578052 15448 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T23:12:11.251957+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-09T22:00:00+00:00 EmrJobFlowSensor 2021-04-09T23:12:11.559476+00:00 2021-04-09T23:22:14.697556+00:00 0:10:03.138080 15447 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T23:12:09.252442+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-09T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T23:11:51.547541+00:00 2021-04-09T23:11:53.252374+00:00 0:00:01.704833 15446 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T23:11:49.212761+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-09T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T23:11:51.596764+00:00 2021-04-09T23:11:53.414934+00:00 0:00:01.818170 15445 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T23:11:49.212729+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-09T22:00:00+00:00 PythonOperator 2021-04-09T23:11:31.968440+00:00 2021-04-09T23:11:34.918721+00:00 0:00:02.950281 15444 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T23:11:29.194616+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-09T22:00:00+00:00 PythonOperator 2021-04-09T23:11:29.550915+00:00 2021-04-09T23:11:32.660886+00:00 0:00:03.109971 15443 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T23:11:27.194825+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T22:00:00+00:00 TriggerDagRunOperator 2021-04-09T23:11:09.529185+00:00 2021-04-09T23:11:10.059115+00:00 0:00:00.529930 15442 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T23:11:07.137160+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T22:00:00+00:00 TriggerDagRunOperator 2021-04-09T23:11:09.472335+00:00 2021-04-09T23:11:09.903625+00:00 0:00:00.431290 15441 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T23:11:07.137128+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-09T22:05:00+00:00 EmrJobFlowSensor 2021-04-09T23:05:58.989770+00:00 2021-04-09T23:14:01.499603+00:00 0:08:02.509833 15440 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T23:05:56.683101+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-09T22:05:00+00:00 EmrCreateJobFlowOperator 2021-04-09T23:05:39.086582+00:00 2021-04-09T23:05:40.796540+00:00 0:00:01.709958 15439 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T23:05:36.638878+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-09T22:05:00+00:00 PythonOperator 2021-04-09T23:05:16.888813+00:00 2021-04-09T23:05:20.536543+00:00 0:00:03.647730 15438 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T23:05:14.627887+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T22:00:00+00:00 EmrJobFlowSensor 2021-04-09T23:00:54.675106+00:00 2021-04-09T23:10:57.459066+00:00 0:10:02.783960 15437 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T23:00:52.275849+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T23:00:32.535743+00:00 2021-04-09T23:00:34.227093+00:00 0:00:01.691350 15436 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T23:00:30.248870+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T22:00:00+00:00 PythonOperator 2021-04-09T23:00:10.677877+00:00 2021-04-09T23:00:13.638772+00:00 0:00:02.960895 15435 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T23:00:08.150358+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-09T21:00:00+00:00 EmrJobFlowSensor 2021-04-09T22:12:18.758593+00:00 2021-04-09T22:20:21.354955+00:00 0:08:02.596362 15433 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T22:12:16.239856+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-09T21:00:00+00:00 EmrJobFlowSensor 2021-04-09T22:12:12.394933+00:00 2021-04-09T22:21:15.722249+00:00 0:09:03.327316 15432 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T22:12:10.234507+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-09T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T22:11:58.517718+00:00 2021-04-09T22:12:00.393004+00:00 0:00:01.875286 15431 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T22:11:56.209527+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-09T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T22:11:50.363274+00:00 2021-04-09T22:11:52.039787+00:00 0:00:01.676513 15430 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T22:11:48.201472+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-09T21:00:00+00:00 PythonOperator 2021-04-09T22:11:36.570883+00:00 2021-04-09T22:11:39.309470+00:00 0:00:02.738587 15429 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T22:11:34.187776+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-09T21:00:00+00:00 PythonOperator 2021-04-09T22:11:30.692845+00:00 2021-04-09T22:11:33.717896+00:00 0:00:03.025051 15428 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T22:11:28.340801+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T21:00:00+00:00 TriggerDagRunOperator 2021-04-09T22:11:12.429467+00:00 2021-04-09T22:11:12.874946+00:00 0:00:00.445479 15427 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T22:11:10.101843+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T21:00:00+00:00 TriggerDagRunOperator 2021-04-09T22:11:12.302508+00:00 2021-04-09T22:11:12.887775+00:00 0:00:00.585267 15426 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T22:11:10.101811+00:00 2 default_pool