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-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
success vc-asset-import_v002 check_cluster_status 2021-04-09T21:05:00+00:00 EmrJobFlowSensor 2021-04-09T22:05:49.878798+00:00 2021-04-09T22:14:52.407853+00:00 0:09:02.529055 15425 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T22:05:47.652660+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-09T21:05:00+00:00 EmrCreateJobFlowOperator 2021-04-09T22:05:27.770929+00:00 2021-04-09T22:05:29.398521+00:00 0:00:01.627592 15424 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T22:05:25.533728+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-09T21:05:00+00:00 PythonOperator 2021-04-09T22:05:05.666041+00:00 2021-04-09T22:05:08.371954+00:00 0:00:02.705913 15423 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T22:05:03.513705+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T21:00:00+00:00 EmrJobFlowSensor 2021-04-09T22:00:47.517995+00:00 2021-04-09T22:10:50.253941+00:00 0:10:02.735946 15422 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T22:00:45.202721+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T22:00:27.483664+00:00 2021-04-09T22:00:29.318389+00:00 0:00:01.834725 15421 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T22:00:25.182384+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T21:00:00+00:00 PythonOperator 2021-04-09T22:00:05.688752+00:00 2021-04-09T22:00:09.210055+00:00 0:00:03.521303 15420 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T22:00:03.162752+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-09T20:00:00+00:00 EmrJobFlowSensor 2021-04-09T21:12:20.318296+00:00 2021-04-09T21:21:23.077696+00:00 0:09:02.759400 15418 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T21:12:18.021740+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-09T20:00:00+00:00 EmrJobFlowSensor 2021-04-09T21:12:16.189651+00:00 2021-04-09T21:22:18.948165+00:00 0:10:02.758514 15417 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T21:12:14.018725+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-09T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T21:11:58.408652+00:00 2021-04-09T21:12:00.126686+00:00 0:00:01.718034 15416 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T21:11:56.054311+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-09T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T21:11:54.507196+00:00 2021-04-09T21:11:56.200571+00:00 0:00:01.693375 15415 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T21:11:52.066772+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-09T20:00:00+00:00 PythonOperator 2021-04-09T21:11:36.456299+00:00 2021-04-09T21:11:39.251294+00:00 0:00:02.794995 15414 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T21:11:34.067571+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-09T20:00:00+00:00 PythonOperator 2021-04-09T21:11:34.563839+00:00 2021-04-09T21:11:37.548512+00:00 0:00:02.984673 15413 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T21:11:32.044832+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T20:00:00+00:00 TriggerDagRunOperator 2021-04-09T21:11:20.306732+00:00 2021-04-09T21:11:20.899998+00:00 0:00:00.593266 15412 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T21:11:17.942584+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T20:00:00+00:00 TriggerDagRunOperator 2021-04-09T21:11:20.157970+00:00 2021-04-09T21:11:20.580037+00:00 0:00:00.422067 15411 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T21:11:17.942551+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-09T20:05:00+00:00 EmrJobFlowSensor 2021-04-09T21:06:01.773816+00:00 2021-04-09T21:14:04.331262+00:00 0:08:02.557446 15410 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T21:05:59.460127+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-09T20:05:00+00:00 EmrCreateJobFlowOperator 2021-04-09T21:05:39.766365+00:00 2021-04-09T21:05:41.418935+00:00 0:00:01.652570 15409 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T21:05:37.473474+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-09T20:05:00+00:00 PythonOperator 2021-04-09T21:05:17.578495+00:00 2021-04-09T21:05:20.366533+00:00 0:00:02.788038 15408 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T21:05:15.365971+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T20:00:00+00:00 EmrJobFlowSensor 2021-04-09T21:00:59.255753+00:00 2021-04-09T21:11:02.057148+00:00 0:10:02.801395 15407 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T21:00:56.971900+00:00 2 default_pool