Task Instances

Reset Filters
  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-05T13:00:00+00:00 PythonOperator 2021-04-05T14:00:07.391890+00:00 2021-04-05T14:00:10.234542+00:00 0:00:02.842652 13860 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T14:00:04.792205+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T12:00:00+00:00 TriggerDagRunOperator 2021-04-05T13:10:20.567904+00:00 2021-04-05T13:10:21.112002+00:00 0:00:00.544098 13852 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T13:10:18.312216+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T12:00:00+00:00 TriggerDagRunOperator 2021-04-05T13:10:20.538372+00:00 2021-04-05T13:10:20.955247+00:00 0:00:00.416875 13851 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T13:10:18.312247+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T12:00:00+00:00 EmrJobFlowSensor 2021-04-05T13:00:55.399876+00:00 2021-04-05T13:09:58.169244+00:00 0:09:02.769368 13847 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T13:00:53.208059+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T13:00:33.350588+00:00 2021-04-05T13:00:35.089817+00:00 0:00:01.739229 13846 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T13:00:31.189795+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T12:00:00+00:00 PythonOperator 2021-04-05T13:00:11.654775+00:00 2021-04-05T13:00:14.494799+00:00 0:00:02.840024 13845 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T13:00:09.162792+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T11:00:00+00:00 TriggerDagRunOperator 2021-04-05T12:11:16.451353+00:00 2021-04-05T12:11:16.985381+00:00 0:00:00.534028 13837 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T12:11:14.052984+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T11:00:00+00:00 TriggerDagRunOperator 2021-04-05T12:11:16.382883+00:00 2021-04-05T12:11:16.787495+00:00 0:00:00.404612 13836 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T12:11:14.053032+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T11:00:00+00:00 EmrJobFlowSensor 2021-04-05T12:01:03.518529+00:00 2021-04-05T12:11:06.246990+00:00 0:10:02.728461 13832 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T12:01:01.144790+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T12:00:41.405586+00:00 2021-04-05T12:00:43.215362+00:00 0:00:01.809776 13831 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T12:00:39.059964+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T11:00:00+00:00 PythonOperator 2021-04-05T12:00:21.464033+00:00 2021-04-05T12:00:24.286776+00:00 0:00:02.822743 13830 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T12:00:18.994208+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T10:00:00+00:00 TriggerDagRunOperator 2021-04-05T11:10:23.988565+00:00 2021-04-05T11:10:24.607314+00:00 0:00:00.618749 13821 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T11:10:21.552034+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T10:00:00+00:00 TriggerDagRunOperator 2021-04-05T11:10:23.810941+00:00 2021-04-05T11:10:24.405972+00:00 0:00:00.595031 13820 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T11:10:21.552067+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T10:00:00+00:00 EmrJobFlowSensor 2021-04-05T11:01:04.957947+00:00 2021-04-05T11:10:07.645716+00:00 0:09:02.687769 13816 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T11:01:02.592811+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T11:00:42.753081+00:00 2021-04-05T11:00:44.478787+00:00 0:00:01.725706 13815 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T11:00:40.510042+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T10:00:00+00:00 PythonOperator 2021-04-05T11:00:20.831281+00:00 2021-04-05T11:00:23.785324+00:00 0:00:02.954043 13814 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T11:00:18.492295+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T09:00:00+00:00 TriggerDagRunOperator 2021-04-05T10:10:14.632809+00:00 2021-04-05T10:10:15.310436+00:00 0:00:00.677627 13806 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T10:10:12.280643+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T09:00:00+00:00 TriggerDagRunOperator 2021-04-05T10:10:14.608530+00:00 2021-04-05T10:10:15.149565+00:00 0:00:00.541035 13805 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T10:10:12.280593+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T09:00:00+00:00 EmrJobFlowSensor 2021-04-05T10:01:01.525558+00:00 2021-04-05T10:10:04.243208+00:00 0:09:02.717650 13801 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T10:00:59.313347+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T10:00:31.710072+00:00 2021-04-05T10:00:33.524513+00:00 0:00:01.814441 13800 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T10:00:29.359895+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T09:00:00+00:00 PythonOperator 2021-04-05T10:00:09.722520+00:00 2021-04-05T10:00:12.593262+00:00 0:00:02.870742 13799 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T10:00:07.273108+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T08:00:00+00:00 TriggerDagRunOperator 2021-04-05T09:11:14.281572+00:00 2021-04-05T09:11:14.817394+00:00 0:00:00.535822 13791 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T09:11:11.886977+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T08:00:00+00:00 TriggerDagRunOperator 2021-04-05T09:11:14.005228+00:00 2021-04-05T09:11:14.410464+00:00 0:00:00.405236 13790 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T09:11:11.887008+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T08:00:00+00:00 EmrJobFlowSensor 2021-04-05T09:00:59.092826+00:00 2021-04-05T09:11:01.937940+00:00 0:10:02.845114 13786 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T09:00:56.698779+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T09:00:39.122355+00:00 2021-04-05T09:00:40.810370+00:00 0:00:01.688015 13785 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T09:00:36.683801+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T08:00:00+00:00 PythonOperator 2021-04-05T09:00:16.925392+00:00 2021-04-05T09:00:19.808316+00:00 0:00:02.882924 13784 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T09:00:14.621266+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T07:00:00+00:00 TriggerDagRunOperator 2021-04-05T08:14:11.078125+00:00 2021-04-05T08:14:11.633171+00:00 0:00:00.555046 13777 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T08:14:08.186431+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T07:00:00+00:00 TriggerDagRunOperator 2021-04-05T08:14:10.682326+00:00 2021-04-05T08:14:11.146432+00:00 0:00:00.464106 13776 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T08:14:08.186462+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T07:00:00+00:00 EmrJobFlowSensor 2021-04-05T08:00:54.550590+00:00 2021-04-05T08:10:57.486957+00:00 0:10:02.936367 13771 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T08:00:51.991524+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T08:00:32.220289+00:00 2021-04-05T08:00:33.983065+00:00 0:00:01.762776 13770 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T08:00:29.964244+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T07:00:00+00:00 PythonOperator 2021-04-05T08:00:10.152538+00:00 2021-04-05T08:00:12.907409+00:00 0:00:02.754871 13769 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T08:00:07.888570+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T06:00:00+00:00 TriggerDagRunOperator 2021-04-05T07:09:35.589836+00:00 2021-04-05T07:09:35.974113+00:00 0:00:00.384277 13760 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T07:09:32.344567+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T06:00:00+00:00 TriggerDagRunOperator 2021-04-05T07:09:34.632942+00:00 2021-04-05T07:09:35.147976+00:00 0:00:00.515034 13759 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T07:09:32.344597+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T06:00:00+00:00 EmrJobFlowSensor 2021-04-05T07:00:57.789193+00:00 2021-04-05T07:09:00.352950+00:00 0:08:02.563757 13756 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T07:00:55.530792+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T07:00:27.821461+00:00 2021-04-05T07:00:29.706067+00:00 0:00:01.884606 13755 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T07:00:25.503218+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T06:00:00+00:00 PythonOperator 2021-04-05T07:00:05.836415+00:00 2021-04-05T07:00:08.593209+00:00 0:00:02.756794 13754 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T07:00:03.490147+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T05:00:00+00:00 TriggerDagRunOperator 2021-04-05T06:08:58.860943+00:00 2021-04-05T06:08:59.420350+00:00 0:00:00.559407 13747 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T06:08:56.459736+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T05:00:00+00:00 TriggerDagRunOperator 2021-04-05T06:08:58.814523+00:00 2021-04-05T06:08:59.296718+00:00 0:00:00.482195 13746 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T06:08:56.459700+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T05:00:00+00:00 EmrJobFlowSensor 2021-04-05T06:00:51.699816+00:00 2021-04-05T06:08:54.208533+00:00 0:08:02.508717 13741 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T06:00:49.486731+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T06:00:31.658890+00:00 2021-04-05T06:00:33.366480+00:00 0:00:01.707590 13740 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T06:00:29.456007+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T05:00:00+00:00 PythonOperator 2021-04-05T06:00:09.747659+00:00 2021-04-05T06:00:12.550047+00:00 0:00:02.802388 13739 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T06:00:07.430178+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T04:00:00+00:00 TriggerDagRunOperator 2021-04-05T05:11:32.930745+00:00 2021-04-05T05:11:33.386983+00:00 0:00:00.456238 13732 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T05:11:30.585865+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T04:00:00+00:00 TriggerDagRunOperator 2021-04-05T05:11:32.861576+00:00 2021-04-05T05:11:33.419068+00:00 0:00:00.557492 13731 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T05:11:30.585820+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T04:00:00+00:00 EmrJobFlowSensor 2021-04-05T05:01:14.705836+00:00 2021-04-05T05:11:17.544092+00:00 0:10:02.838256 13726 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T05:01:12.362735+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T05:00:42.585178+00:00 2021-04-05T05:00:44.306474+00:00 0:00:01.721296 13725 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T05:00:40.301563+00:00 2 default_pool
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 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 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 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 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 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 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-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 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 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 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-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 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 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 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-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T20:00:00+00:00 TriggerDagRunOperator 2021-04-04T21:12:03.909185+00:00 2021-04-04T21:12:04.360508+00:00 0:00:00.451323 13611 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T21:12:01.545003+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T20:00:00+00:00 TriggerDagRunOperator 2021-04-04T21:12:03.874437+00:00 2021-04-04T21:12:04.467722+00:00 0:00:00.593285 13610 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T21:12:01.545031+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T20:00:00+00:00 EmrJobFlowSensor 2021-04-04T21:00:52.535013+00:00 2021-04-04T21:11:55.491074+00:00 0:11:02.956061 13606 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T21:00:50.279068+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T21:00:30.766149+00:00 2021-04-04T21:00:32.495030+00:00 0:00:01.728881 13605 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T21:00:28.274211+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T20:00:00+00:00 PythonOperator 2021-04-04T21:00:09.149947+00:00 2021-04-04T21:00:11.920372+00:00 0:00:02.770425 13604 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T21:00:06.351982+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T19:00:00+00:00 TriggerDagRunOperator 2021-04-04T20:10:20.022393+00:00 2021-04-04T20:10:20.550485+00:00 0:00:00.528092 13596 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T20:10:17.515097+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T19:00:00+00:00 TriggerDagRunOperator 2021-04-04T20:10:19.805993+00:00 2021-04-04T20:10:20.227071+00:00 0:00:00.421078 13595 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T20:10:17.515145+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T19:00:00+00:00 EmrJobFlowSensor 2021-04-04T20:00:56.888559+00:00 2021-04-04T20:09:59.656788+00:00 0:09:02.768229 13591 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T20:00:54.586874+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T20:00:36.790320+00:00 2021-04-04T20:00:38.586483+00:00 0:00:01.796163 13590 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T20:00:34.547146+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T19:00:00+00:00 PythonOperator 2021-04-04T20:00:06.971057+00:00 2021-04-04T20:00:09.835452+00:00 0:00:02.864395 13589 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T20:00:04.489758+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T18:00:00+00:00 TriggerDagRunOperator 2021-04-04T19:08:56.381784+00:00 2021-04-04T19:08:56.903701+00:00 0:00:00.521917 13581 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T19:08:53.966252+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T18:00:00+00:00 TriggerDagRunOperator 2021-04-04T19:08:56.216814+00:00 2021-04-04T19:08:56.643556+00:00 0:00:00.426742 13580 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T19:08:53.966219+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T18:00:00+00:00 EmrJobFlowSensor 2021-04-04T19:00:47.419733+00:00 2021-04-04T19:08:50.061966+00:00 0:08:02.642233 13576 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T19:00:45.096458+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T19:00:25.566148+00:00 2021-04-04T19:00:27.369632+00:00 0:00:01.803484 13575 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T19:00:23.078742+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T18:00:00+00:00 PythonOperator 2021-04-04T19:00:05.660743+00:00 2021-04-04T19:00:08.542141+00:00 0:00:02.881398 13574 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T19:00:03.068260+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T17:00:00+00:00 TriggerDagRunOperator 2021-04-04T18:10:19.797439+00:00 2021-04-04T18:10:20.309092+00:00 0:00:00.511653 13566 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T18:10:17.344495+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T17:00:00+00:00 TriggerDagRunOperator 2021-04-04T18:10:19.588068+00:00 2021-04-04T18:10:20.018821+00:00 0:00:00.430753 13565 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T18:10:17.344465+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T17:00:00+00:00 EmrJobFlowSensor 2021-04-04T18:00:52.707820+00:00 2021-04-04T18:09:55.350805+00:00 0:09:02.642985 13561 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T18:00:50.392419+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T18:00:30.650158+00:00 2021-04-04T18:00:32.504273+00:00 0:00:01.854115 13560 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T18:00:28.346071+00:00 2 default_pool