Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-flow-job_v002 create_emr_steps 2021-04-05T04:00:00+00:00 PythonOperator 2021-04-05T05:00:16.391638+00:00 2021-04-05T05:00:19.156198+00:00 0:00:02.764560 13724 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T05:00:14.266541+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-05T03:00:00+00:00 EmrJobFlowSensor 2021-04-05T04:10:06.927909+00:00 2021-04-05T04:20:09.835549+00:00 0:10:02.907640 13723 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T04:10:04.787535+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-05T03:00:00+00:00 EmrJobFlowSensor 2021-04-05T04:09:59.012030+00:00 2021-04-05T04:19:01.738917+00:00 0:09:02.726887 13722 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T04:09:56.733360+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-05T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T04:09:47.011125+00:00 2021-04-05T04:09:48.922071+00:00 0:00:01.910946 13721 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T04:09:44.721917+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-05T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T04:09:36.990195+00:00 2021-04-05T04:09:38.655537+00:00 0:00:01.665342 13720 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T04:09:34.755521+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-05T03:00:00+00:00 PythonOperator 2021-04-05T04:09:25.179482+00:00 2021-04-05T04:09:28.333527+00:00 0:00:03.154045 13719 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T04:09:22.751684+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-05T03:00:00+00:00 PythonOperator 2021-04-05T04:09:17.125747+00:00 2021-04-05T04:09:19.920624+00:00 0:00:02.794877 13718 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T04:09:14.755707+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T03:00:00+00:00 TriggerDagRunOperator 2021-04-05T04:09:07.165931+00:00 2021-04-05T04:09:07.700064+00:00 0:00:00.534133 13717 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T04:09:04.759788+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T03:00:00+00:00 TriggerDagRunOperator 2021-04-05T04:09:07.065233+00:00 2021-04-05T04:09:07.501730+00:00 0:00:00.436497 13716 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T04:09:04.759831+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-05T03:05:00+00:00 EmrJobFlowSensor 2021-04-05T04:05:54.693202+00:00 2021-04-05T04:14:57.429262+00:00 0:09:02.736060 13715 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T04:05:52.395435+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-05T03:05:00+00:00 EmrCreateJobFlowOperator 2021-04-05T04:05:32.499671+00:00 2021-04-05T04:05:34.167399+00:00 0:00:01.667728 13714 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T04:05:30.322815+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-05T03:05:00+00:00 PythonOperator 2021-04-05T04:05:12.825895+00:00 2021-04-05T04:05:15.617281+00:00 0:00:02.791386 13713 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T04:05:10.302807+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T03:00:00+00:00 EmrJobFlowSensor 2021-04-05T04:00:50.642902+00:00 2021-04-05T04:08:53.287662+00:00 0:08:02.644760 13711 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T04:00:48.247493+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T04:00:30.801122+00:00 2021-04-05T04:00:32.534546+00:00 0:00:01.733424 13710 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T04:00:28.273980+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T03:00:00+00:00 PythonOperator 2021-04-05T04:00:08.494319+00:00 2021-04-05T04:00:11.294613+00:00 0:00:02.800294 13709 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T04:00:06.143958+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-05T02:00:00+00:00 EmrJobFlowSensor 2021-04-05T03:14:25.649766+00:00 2021-04-05T03:23:28.244354+00:00 0:09:02.594588 13708 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T03:14:23.386053+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-05T02:00:00+00:00 EmrJobFlowSensor 2021-04-05T03:14:07.530790+00:00 2021-04-05T03:24:10.428024+00:00 0:10:02.897234 13707 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T03:14:05.346002+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-05T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T03:14:05.770956+00:00 2021-04-05T03:14:07.603533+00:00 0:00:01.832577 13706 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T03:14:03.342880+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-05T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T03:13:47.647423+00:00 2021-04-05T03:13:49.491089+00:00 0:00:01.843666 13705 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T03:13:45.299163+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-05T02:00:00+00:00 PythonOperator 2021-04-05T03:13:43.526926+00:00 2021-04-05T03:13:46.519687+00:00 0:00:02.992761 13704 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T03:13:41.293893+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-05T02:00:00+00:00 PythonOperator 2021-04-05T03:13:25.772395+00:00 2021-04-05T03:13:28.640476+00:00 0:00:02.868081 13703 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T03:13:23.341181+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T02:00:00+00:00 TriggerDagRunOperator 2021-04-05T03:13:19.892314+00:00 2021-04-05T03:13:20.410613+00:00 0:00:00.518299 13702 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T03:13:17.266955+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T02:00:00+00:00 TriggerDagRunOperator 2021-04-05T03:13:19.697938+00:00 2021-04-05T03:13:20.112884+00:00 0:00:00.414946 13701 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T03:13:17.267003+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-05T02:05:00+00:00 EmrJobFlowSensor 2021-04-05T03:05:56.566871+00:00 2021-04-05T03:14:59.110133+00:00 0:09:02.543262 13700 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T03:05:54.301545+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-05T02:05:00+00:00 EmrCreateJobFlowOperator 2021-04-05T03:05:36.378327+00:00 2021-04-05T03:05:38.039127+00:00 0:00:01.660800 13699 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T03:05:34.215779+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-05T02:05:00+00:00 PythonOperator 2021-04-05T03:05:14.373657+00:00 2021-04-05T03:05:17.036124+00:00 0:00:02.662467 13698 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T03:05:12.196381+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T02:00:00+00:00 EmrJobFlowSensor 2021-04-05T03:04:00.811294+00:00 2021-04-05T03:13:03.497593+00:00 0:09:02.686299 13697 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T03:03:58.263302+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T03:03:40.455888+00:00 2021-04-05T03:03:42.270091+00:00 0:00:01.814203 13696 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T03:03:38.092698+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T02:00:00+00:00 PythonOperator 2021-04-05T03:03:18.302524+00:00 2021-04-05T03:03:21.026968+00:00 0:00:02.724444 13695 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T03:03:16.055628+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-05T01:00:00+00:00 EmrJobFlowSensor 2021-04-05T02:16:59.542186+00:00 2021-04-05T02:20:01.425659+00:00 0:03:01.883473 13693 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T02:16:57.339113+00:00 3 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-05T01:00:00+00:00 EmrJobFlowSensor 2021-04-05T02:10:11.024411+00:00 2021-04-05T02:19:13.662070+00:00 0:09:02.637659 13691 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T02:10:08.791413+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-05T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T02:10:01.753810+00:00 2021-04-05T02:10:03.517281+00:00 0:00:01.763471 13690 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T02:09:58.947387+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-05T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T02:09:50.891721+00:00 2021-04-05T02:09:52.558197+00:00 0:00:01.666476 13689 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T02:09:48.755129+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-05T01:00:00+00:00 PythonOperator 2021-04-05T02:09:33.115155+00:00 2021-04-05T02:09:36.122273+00:00 0:00:03.007118 13688 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T02:09:30.739159+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-05T01:00:00+00:00 PythonOperator 2021-04-05T02:09:27.107290+00:00 2021-04-05T02:09:29.802102+00:00 0:00:02.694812 13687 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T02:09:24.753478+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T01:00:00+00:00 TriggerDagRunOperator 2021-04-05T02:09:17.395843+00:00 2021-04-05T02:09:17.953473+00:00 0:00:00.557630 13686 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T02:09:14.785619+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T01:00:00+00:00 TriggerDagRunOperator 2021-04-05T02:09:17.263313+00:00 2021-04-05T02:09:17.722461+00:00 0:00:00.459148 13685 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T02:09:14.785585+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-05T01:05:00+00:00 EmrJobFlowSensor 2021-04-05T02:06:06.785039+00:00 2021-04-05T02:15:09.445221+00:00 0:09:02.660182 13684 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T02:06:04.566202+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-05T01:05:00+00:00 EmrCreateJobFlowOperator 2021-04-05T02:05:44.774360+00:00 2021-04-05T02:05:46.504544+00:00 0:00:01.730184 13683 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T02:05:42.545887+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-05T01:05:00+00:00 PythonOperator 2021-04-05T02:05:24.750163+00:00 2021-04-05T02:05:27.541073+00:00 0:00:02.790910 13682 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T02:05:22.435536+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T01:00:00+00:00 EmrJobFlowSensor 2021-04-05T02:00:54.431141+00:00 2021-04-05T02:08:57.171680+00:00 0:08:02.740539 13681 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T02:00:52.025459+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T02:00:26.266730+00:00 2021-04-05T02:00:28.009142+00:00 0:00:01.742412 13680 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T02:00:24.016761+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T01:00:00+00:00 PythonOperator 2021-04-05T02:00:04.778589+00:00 2021-04-05T02:00:07.693400+00:00 0:00:02.914811 13679 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T02:00:01.989495+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-05T00:00:00+00:00 EmrJobFlowSensor 2021-04-05T01:12:11.541587+00:00 2021-04-05T01:21:14.315577+00:00 0:09:02.773990 13677 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T01:12:09.237948+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-05T00:00:00+00:00 EmrJobFlowSensor 2021-04-05T01:11:59.532209+00:00 2021-04-05T01:24:02.656845+00:00 0:12:03.124636 13676 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T01:11:57.229852+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-05T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T01:11:49.797869+00:00 2021-04-05T01:11:51.582211+00:00 0:00:01.784342 13675 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T01:11:47.220444+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-05T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T01:11:37.717264+00:00 2021-04-05T01:11:39.545504+00:00 0:00:01.828240 13674 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T01:11:35.278095+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-05T00:00:00+00:00 PythonOperator 2021-04-05T01:11:27.461964+00:00 2021-04-05T01:11:30.156074+00:00 0:00:02.694110 13673 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T01:11:25.200486+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-05T00:00:00+00:00 PythonOperator 2021-04-05T01:11:17.602817+00:00 2021-04-05T01:11:20.804431+00:00 0:00:03.201614 13672 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T01:11:15.201441+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T00:00:00+00:00 TriggerDagRunOperator 2021-04-05T01:11:09.634646+00:00 2021-04-05T01:11:10.133887+00:00 0:00:00.499241 13671 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T01:11:07.186094+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T00:00:00+00:00 TriggerDagRunOperator 2021-04-05T01:11:09.399586+00:00 2021-04-05T01:11:09.824199+00:00 0:00:00.424613 13670 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T01:11:07.186059+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-05T00:05:00+00:00 EmrJobFlowSensor 2021-04-05T01:06:08.935823+00:00 2021-04-05T01:14:11.308844+00:00 0:08:02.373021 13669 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T01:06:06.695959+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-05T00:05:00+00:00 EmrCreateJobFlowOperator 2021-04-05T01:05:36.779551+00:00 2021-04-05T01:05:38.407789+00:00 0:00:01.628238 13668 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T01:05:34.611910+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-05T00:05:00+00:00 PythonOperator 2021-04-05T01:05:16.757209+00:00 2021-04-05T01:05:19.477253+00:00 0:00:02.720044 13667 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T01:05:14.599716+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T00:00:00+00:00 EmrJobFlowSensor 2021-04-05T01:00:46.438167+00:00 2021-04-05T01:10:49.276867+00:00 0:10:02.838700 13666 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T01:00:44.193817+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T01:00:24.657967+00:00 2021-04-05T01:00:26.518527+00:00 0:00:01.860560 13665 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T01:00:22.169579+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T00:00:00+00:00 PythonOperator 2021-04-05T01:00:04.623369+00:00 2021-04-05T01:00:07.359063+00:00 0:00:02.735694 13664 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T01:00:02.169415+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T23:00:00+00:00 EmrJobFlowSensor 2021-04-05T00:12:28.114776+00:00 2021-04-05T00:22:30.987899+00:00 0:10:02.873123 13662 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T00:12:25.730750+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T23:00:00+00:00 EmrJobFlowSensor 2021-04-05T00:12:19.902665+00:00 2021-04-05T00:20:22.435962+00:00 0:08:02.533297 13661 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T00:12:17.715060+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T00:12:03.917884+00:00 2021-04-05T00:12:05.613152+00:00 0:00:01.695268 13660 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T00:12:01.701058+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T00:11:56.193379+00:00 2021-04-05T00:11:57.889658+00:00 0:00:01.696279 13659 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T00:11:53.786830+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T23:00:00+00:00 PythonOperator 2021-04-05T00:11:42.019107+00:00 2021-04-05T00:11:45.052492+00:00 0:00:03.033385 13658 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T00:11:39.745396+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T23:00:00+00:00 PythonOperator 2021-04-05T00:11:35.993230+00:00 2021-04-05T00:11:38.767319+00:00 0:00:02.774089 13657 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T00:11:33.668481+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T23:00:00+00:00 TriggerDagRunOperator 2021-04-05T00:11:20.306813+00:00 2021-04-05T00:11:20.821137+00:00 0:00:00.514324 13656 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T00:11:17.659220+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T23:00:00+00:00 TriggerDagRunOperator 2021-04-05T00:11:20.120728+00:00 2021-04-05T00:11:20.551476+00:00 0:00:00.430748 13655 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T00:11:17.659254+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T23:05:00+00:00 EmrJobFlowSensor 2021-04-05T00:05:59.437385+00:00 2021-04-05T00:15:02.199197+00:00 0:09:02.761812 13654 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T00:05:57.076927+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T23:05:00+00:00 EmrCreateJobFlowOperator 2021-04-05T00:05:37.506958+00:00 2021-04-05T00:05:39.248024+00:00 0:00:01.741066 13653 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T00:05:35.043974+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T23:05:00+00:00 PythonOperator 2021-04-05T00:05:15.612363+00:00 2021-04-05T00:05:18.283121+00:00 0:00:02.670758 13652 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T00:05:13.059621+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T23:00:00+00:00 EmrJobFlowSensor 2021-04-05T00:01:04.823154+00:00 2021-04-05T00:11:07.804713+00:00 0:10:02.981559 13651 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T00:01:02.517701+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T00:00:43.121330+00:00 2021-04-05T00:00:44.925943+00:00 0:00:01.804613 13650 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T00:00:40.555023+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T23:00:00+00:00 PythonOperator 2021-04-05T00:00:20.814823+00:00 2021-04-05T00:00:23.663907+00:00 0:00:02.849084 13649 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T00:00:18.433254+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T22:00:00+00:00 EmrJobFlowSensor 2021-04-04T23:11:27.708656+00:00 2021-04-04T23:20:30.391381+00:00 0:09:02.682725 13647 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T23:11:25.115521+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T22:00:00+00:00 EmrJobFlowSensor 2021-04-04T23:11:27.541675+00:00 2021-04-04T23:21:30.320750+00:00 0:10:02.779075 13646 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T23:11:25.115553+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T23:11:05.781105+00:00 2021-04-04T23:11:07.608157+00:00 0:00:01.827052 13645 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T23:11:03.164029+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T23:11:05.661339+00:00 2021-04-04T23:11:07.370536+00:00 0:00:01.709197 13644 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T23:11:03.163983+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T22:00:00+00:00 PythonOperator 2021-04-04T23:10:43.551400+00:00 2021-04-04T23:10:46.652003+00:00 0:00:03.100603 13643 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T23:10:41.084022+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T22:00:00+00:00 PythonOperator 2021-04-04T23:10:43.389694+00:00 2021-04-04T23:10:46.160533+00:00 0:00:02.770839 13642 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T23:10:41.083975+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T22:00:00+00:00 TriggerDagRunOperator 2021-04-04T23:10:25.410134+00:00 2021-04-04T23:10:25.979409+00:00 0:00:00.569275 13641 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T23:10:23.053726+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T22:00:00+00:00 TriggerDagRunOperator 2021-04-04T23:10:25.366940+00:00 2021-04-04T23:10:25.853167+00:00 0:00:00.486227 13640 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T23:10:23.053759+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T22:05:00+00:00 EmrJobFlowSensor 2021-04-04T23:05:48.931266+00:00 2021-04-04T23:14:51.521210+00:00 0:09:02.589944 13639 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T23:05:46.655775+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T22:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T23:05:26.924915+00:00 2021-04-04T23:05:28.572492+00:00 0:00:01.647577 13638 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T23:05:24.663066+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T22:05:00+00:00 PythonOperator 2021-04-04T23:05:06.876930+00:00 2021-04-04T23:05:09.575264+00:00 0:00:02.698334 13637 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T23:05:04.649339+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T22:00:00+00:00 EmrJobFlowSensor 2021-04-04T23:01:04.478719+00:00 2021-04-04T23:10:07.251697+00:00 0:09:02.772978 13636 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T23:01:02.214196+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T23:00:42.355151+00:00 2021-04-04T23:00:44.215863+00:00 0:00:01.860712 13635 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T23:00:40.194167+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T22:00:00+00:00 PythonOperator 2021-04-04T23:00:22.482229+00:00 2021-04-04T23:00:25.213468+00:00 0:00:02.731239 13634 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T23:00:20.151178+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T21:00:00+00:00 EmrJobFlowSensor 2021-04-04T22:12:32.405545+00:00 2021-04-04T22:22:35.074068+00:00 0:10:02.668523 13632 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T22:12:30.211023+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T21:00:00+00:00 EmrJobFlowSensor 2021-04-04T22:12:18.694122+00:00 2021-04-04T22:21:21.521147+00:00 0:09:02.827025 13631 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T22:12:16.269761+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T22:12:10.397041+00:00 2021-04-04T22:12:12.115361+00:00 0:00:01.718320 13630 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T22:12:08.190400+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T22:11:48.400405+00:00 2021-04-04T22:11:50.158044+00:00 0:00:01.757639 13629 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T22:11:46.149082+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T21:00:00+00:00 PythonOperator 2021-04-04T22:11:40.372843+00:00 2021-04-04T22:11:43.322147+00:00 0:00:02.949304 13628 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T22:11:38.146227+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T21:00:00+00:00 PythonOperator 2021-04-04T22:11:24.387562+00:00 2021-04-04T22:11:27.287107+00:00 0:00:02.899545 13627 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T22:11:22.129605+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T21:00:00+00:00 TriggerDagRunOperator 2021-04-04T22:11:18.678171+00:00 2021-04-04T22:11:19.200840+00:00 0:00:00.522669 13626 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T22:11:16.126992+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T21:00:00+00:00 TriggerDagRunOperator 2021-04-04T22:11:18.516485+00:00 2021-04-04T22:11:18.968178+00:00 0:00:00.451693 13625 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T22:11:16.127041+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T21:05:00+00:00 EmrJobFlowSensor 2021-04-04T22:05:57.957202+00:00 2021-04-04T22:15:00.460779+00:00 0:09:02.503577 13624 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T22:05:55.722807+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T21:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T22:05:37.962629+00:00 2021-04-04T22:05:39.709101+00:00 0:00:01.746472 13623 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T22:05:35.708321+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T21:05:00+00:00 PythonOperator 2021-04-04T22:05:16.239119+00:00 2021-04-04T22:05:18.955548+00:00 0:00:02.716429 13622 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T22:05:13.689634+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T21:00:00+00:00 EmrJobFlowSensor 2021-04-04T22:01:01.313307+00:00 2021-04-04T22:11:04.141023+00:00 0:10:02.827716 13621 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T22:00:59.075103+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T22:00:39.478825+00:00 2021-04-04T22:00:41.316039+00:00 0:00:01.837214 13620 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T22:00:37.053868+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T21:00:00+00:00 PythonOperator 2021-04-04T22:00:17.283602+00:00 2021-04-04T22:00:20.029176+00:00 0:00:02.745574 13619 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T22:00:14.983290+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T20:00:00+00:00 EmrJobFlowSensor 2021-04-04T21:13:10.125886+00:00 2021-04-04T21:21:12.707153+00:00 0:08:02.581267 13617 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T21:13:07.667020+00:00 2 default_pool