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-30T13:00:00+00:00 PythonOperator 2021-04-30T14:11:43.838765+00:00 2021-04-30T14:11:46.935001+00:00 0:00:03.096236 22941 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-30T14:11:41.217585+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-30T12:00:00+00:00 TriggerDagRunOperator 2021-04-30T13:11:00.245305+00:00 2021-04-30T13:11:00.810342+00:00 0:00:00.565037 22933 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T13:10:57.347426+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-30T12:00:00+00:00 TriggerDagRunOperator 2021-04-30T13:10:59.942080+00:00 2021-04-30T13:11:00.417998+00:00 0:00:00.475918 22932 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T13:10:57.347374+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-30T12:00:00+00:00 EmrJobFlowSensor 2021-04-30T13:00:52.402260+00:00 2021-04-30T13:10:55.268914+00:00 0:10:02.866654 22928 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T13:00:50.182464+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-30T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T13:00:32.461986+00:00 2021-04-30T13:00:34.381158+00:00 0:00:01.919172 22927 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-30T13:00:30.136154+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-30T12:00:00+00:00 PythonOperator 2021-04-30T13:00:04.762396+00:00 2021-04-30T13:00:07.850512+00:00 0:00:03.088116 22926 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-30T13:00:02.111296+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-30T11:00:00+00:00 TriggerDagRunOperator 2021-04-30T12:11:20.430660+00:00 2021-04-30T12:11:20.949168+00:00 0:00:00.518508 22918 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T12:11:17.985176+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-30T11:00:00+00:00 TriggerDagRunOperator 2021-04-30T12:11:20.208412+00:00 2021-04-30T12:11:20.614677+00:00 0:00:00.406265 22917 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T12:11:17.985147+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-30T11:00:00+00:00 EmrJobFlowSensor 2021-04-30T12:01:05.436794+00:00 2021-04-30T12:11:08.440800+00:00 0:10:03.004006 22913 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T12:01:03.084114+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-30T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T12:00:41.379577+00:00 2021-04-30T12:00:43.102919+00:00 0:00:01.723342 22912 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-30T12:00:39.060730+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-30T11:00:00+00:00 PythonOperator 2021-04-30T12:00:21.301908+00:00 2021-04-30T12:00:24.430874+00:00 0:00:03.128966 22911 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-30T12:00:18.993138+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-30T10:00:00+00:00 TriggerDagRunOperator 2021-04-30T11:11:45.896408+00:00 2021-04-30T11:11:46.313277+00:00 0:00:00.416869 22903 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T11:11:43.508036+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-30T10:00:00+00:00 TriggerDagRunOperator 2021-04-30T11:11:45.852596+00:00 2021-04-30T11:11:46.459830+00:00 0:00:00.607234 22902 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T11:11:43.508006+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-30T10:00:00+00:00 EmrJobFlowSensor 2021-04-30T11:01:26.703294+00:00 2021-04-30T11:11:29.484907+00:00 0:10:02.781613 22898 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T11:01:24.489523+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-30T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T11:01:04.933734+00:00 2021-04-30T11:01:06.829130+00:00 0:00:01.895396 22897 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-30T11:01:02.414397+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-30T10:00:00+00:00 PythonOperator 2021-04-30T11:00:42.788374+00:00 2021-04-30T11:00:45.799735+00:00 0:00:03.011361 22896 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-30T11:00:40.392643+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-30T09:00:00+00:00 TriggerDagRunOperator 2021-04-30T10:09:23.970680+00:00 2021-04-30T10:09:24.536947+00:00 0:00:00.566267 22888 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T10:09:21.494453+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-30T09:00:00+00:00 TriggerDagRunOperator 2021-04-30T10:09:23.889873+00:00 2021-04-30T10:09:24.292053+00:00 0:00:00.402180 22887 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T10:09:21.494483+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-30T09:00:00+00:00 EmrJobFlowSensor 2021-04-30T10:01:01.130219+00:00 2021-04-30T10:09:03.913222+00:00 0:08:02.783003 22883 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T10:00:58.761043+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-30T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T10:00:38.973920+00:00 2021-04-30T10:00:40.677553+00:00 0:00:01.703633 22882 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-30T10:00:36.647652+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-30T09:00:00+00:00 PythonOperator 2021-04-30T10:00:17.139082+00:00 2021-04-30T10:00:20.196516+00:00 0:00:03.057434 22881 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-30T10:00:14.654543+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-30T08:00:00+00:00 TriggerDagRunOperator 2021-04-30T09:11:05.436661+00:00 2021-04-30T09:11:05.977287+00:00 0:00:00.540626 22873 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T09:11:02.661817+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-30T08:00:00+00:00 TriggerDagRunOperator 2021-04-30T09:11:05.355419+00:00 2021-04-30T09:11:05.765800+00:00 0:00:00.410381 22872 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T09:11:02.661883+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-30T08:00:00+00:00 EmrJobFlowSensor 2021-04-30T09:00:48.053268+00:00 2021-04-30T09:10:51.027645+00:00 0:10:02.974377 22868 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T09:00:45.724017+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-30T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T09:00:26.219632+00:00 2021-04-30T09:00:27.931439+00:00 0:00:01.711807 22867 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-30T09:00:23.771870+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-30T08:00:00+00:00 PythonOperator 2021-04-30T09:00:06.346244+00:00 2021-04-30T09:00:09.388464+00:00 0:00:03.042220 22866 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-30T09:00:03.747603+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-30T07:00:00+00:00 TriggerDagRunOperator 2021-04-30T08:10:23.266137+00:00 2021-04-30T08:10:23.826422+00:00 0:00:00.560285 22858 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T08:10:20.599250+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-30T07:00:00+00:00 TriggerDagRunOperator 2021-04-30T08:10:23.192828+00:00 2021-04-30T08:10:23.590420+00:00 0:00:00.397592 22857 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T08:10:20.599294+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-30T07:00:00+00:00 EmrJobFlowSensor 2021-04-30T08:00:57.811849+00:00 2021-04-30T08:10:00.414506+00:00 0:09:02.602657 22853 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T08:00:55.479256+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-30T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T08:00:37.945239+00:00 2021-04-30T08:00:39.693598+00:00 0:00:01.748359 22852 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-30T08:00:35.451141+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-30T07:00:00+00:00 PythonOperator 2021-04-30T08:00:15.742071+00:00 2021-04-30T08:00:18.793827+00:00 0:00:03.051756 22851 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-30T08:00:13.322333+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-30T06:00:00+00:00 TriggerDagRunOperator 2021-04-30T07:10:15.731473+00:00 2021-04-30T07:10:16.279008+00:00 0:00:00.547535 22843 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T07:10:13.157716+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-30T06:00:00+00:00 TriggerDagRunOperator 2021-04-30T07:10:15.691294+00:00 2021-04-30T07:10:16.101724+00:00 0:00:00.410430 22842 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T07:10:13.157769+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-30T06:00:00+00:00 EmrJobFlowSensor 2021-04-30T07:00:50.346062+00:00 2021-04-30T07:09:52.981720+00:00 0:09:02.635658 22838 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T07:00:47.961886+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-30T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T07:00:30.618789+00:00 2021-04-30T07:00:32.455447+00:00 0:00:01.836658 22837 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-30T07:00:28.044229+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-30T06:00:00+00:00 PythonOperator 2021-04-30T07:00:08.626327+00:00 2021-04-30T07:00:11.724723+00:00 0:00:03.098396 22836 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-30T07:00:05.926439+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-30T05:00:00+00:00 TriggerDagRunOperator 2021-04-30T06:11:29.986607+00:00 2021-04-30T06:11:30.540250+00:00 0:00:00.553643 22828 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T06:11:27.235548+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-30T05:00:00+00:00 TriggerDagRunOperator 2021-04-30T06:11:29.717531+00:00 2021-04-30T06:11:30.152403+00:00 0:00:00.434872 22827 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T06:11:27.235501+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-30T05:00:00+00:00 EmrJobFlowSensor 2021-04-30T06:01:16.113384+00:00 2021-04-30T06:11:18.983402+00:00 0:10:02.870018 22823 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T06:01:13.754961+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-30T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T06:00:56.042443+00:00 2021-04-30T06:00:57.915264+00:00 0:00:01.872821 22822 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-30T06:00:53.661491+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-30T05:00:00+00:00 PythonOperator 2021-04-30T06:00:34.541108+00:00 2021-04-30T06:00:37.654878+00:00 0:00:03.113770 22821 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-30T06:00:31.622286+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-30T04:00:00+00:00 TriggerDagRunOperator 2021-04-30T05:10:16.288106+00:00 2021-04-30T05:10:16.819578+00:00 0:00:00.531472 22813 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T05:10:13.668030+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-30T04:00:00+00:00 TriggerDagRunOperator 2021-04-30T05:10:15.893040+00:00 2021-04-30T05:10:16.288916+00:00 0:00:00.395876 22812 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T05:10:13.668079+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-30T04:00:00+00:00 EmrJobFlowSensor 2021-04-30T05:01:04.959710+00:00 2021-04-30T05:10:07.791951+00:00 0:09:02.832241 22808 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T05:01:02.393794+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-30T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T05:00:42.543706+00:00 2021-04-30T05:00:44.274651+00:00 0:00:01.730945 22807 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-30T05:00:40.304898+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-30T04:00:00+00:00 PythonOperator 2021-04-30T05:00:21.029315+00:00 2021-04-30T05:00:24.235853+00:00 0:00:03.206538 22806 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-30T05:00:18.287356+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-30T03:00:00+00:00 TriggerDagRunOperator 2021-04-30T04:10:32.679050+00:00 2021-04-30T04:10:33.084671+00:00 0:00:00.405621 22797 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T04:10:30.148801+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-30T03:00:00+00:00 TriggerDagRunOperator 2021-04-30T04:10:32.654789+00:00 2021-04-30T04:10:33.193554+00:00 0:00:00.538765 22796 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T04:10:30.148844+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-30T03:00:00+00:00 EmrJobFlowSensor 2021-04-30T04:01:05.327805+00:00 2021-04-30T04:10:07.996923+00:00 0:09:02.669118 22792 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T04:01:02.885110+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-30T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T04:00:43.202276+00:00 2021-04-30T04:00:45.072513+00:00 0:00:01.870237 22791 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-30T04:00:40.828742+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-30T03:00:00+00:00 PythonOperator 2021-04-30T04:00:21.337453+00:00 2021-04-30T04:00:24.479466+00:00 0:00:03.142013 22790 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-30T04:00:18.865979+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-30T02:00:00+00:00 TriggerDagRunOperator 2021-04-30T03:11:23.920373+00:00 2021-04-30T03:11:24.474315+00:00 0:00:00.553942 22782 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T03:11:21.489404+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-30T02:00:00+00:00 TriggerDagRunOperator 2021-04-30T03:11:23.642336+00:00 2021-04-30T03:11:24.065402+00:00 0:00:00.423066 22781 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T03:11:21.489368+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-30T02:00:00+00:00 EmrJobFlowSensor 2021-04-30T03:01:00.701749+00:00 2021-04-30T03:11:03.667565+00:00 0:10:02.965816 22777 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T03:00:58.119568+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-30T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T03:00:38.490477+00:00 2021-04-30T03:00:40.285001+00:00 0:00:01.794524 22776 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-30T03:00:36.103481+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-30T02:00:00+00:00 PythonOperator 2021-04-30T03:00:16.604953+00:00 2021-04-30T03:00:19.660374+00:00 0:00:03.055421 22775 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-30T03:00:14.100218+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-30T01:00:00+00:00 TriggerDagRunOperator 2021-04-30T02:09:17.538962+00:00 2021-04-30T02:09:18.143244+00:00 0:00:00.604282 22767 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T02:09:14.651655+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-30T01:00:00+00:00 TriggerDagRunOperator 2021-04-30T02:09:17.094445+00:00 2021-04-30T02:09:17.649819+00:00 0:00:00.555374 22766 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T02:09:14.651610+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-30T01:00:00+00:00 EmrJobFlowSensor 2021-04-30T02:01:08.404140+00:00 2021-04-30T02:09:11.078609+00:00 0:08:02.674469 22762 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T02:01:05.873859+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-30T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T02:00:46.190378+00:00 2021-04-30T02:00:48.037098+00:00 0:00:01.846720 22761 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-30T02:00:43.797594+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-30T01:00:00+00:00 PythonOperator 2021-04-30T02:00:24.621557+00:00 2021-04-30T02:00:27.705659+00:00 0:00:03.084102 22760 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-30T02:00:21.763456+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-30T00:00:00+00:00 TriggerDagRunOperator 2021-04-30T01:10:59.859081+00:00 2021-04-30T01:11:00.398782+00:00 0:00:00.539701 22752 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T01:10:57.374770+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-30T00:00:00+00:00 TriggerDagRunOperator 2021-04-30T01:10:59.825132+00:00 2021-04-30T01:11:00.251629+00:00 0:00:00.426497 22751 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T01:10:57.374820+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-30T00:00:00+00:00 EmrJobFlowSensor 2021-04-30T01:00:46.124744+00:00 2021-04-30T01:10:49.044548+00:00 0:10:02.919804 22747 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T01:00:43.889421+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-30T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T01:00:26.043905+00:00 2021-04-30T01:00:27.780828+00:00 0:00:01.736923 22746 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-30T01:00:23.834908+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-30T00:00:00+00:00 PythonOperator 2021-04-30T01:00:04.173551+00:00 2021-04-30T01:00:07.212364+00:00 0:00:03.038813 22745 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-30T01:00:01.815310+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T23:00:00+00:00 TriggerDagRunOperator 2021-04-30T00:11:28.867855+00:00 2021-04-30T00:11:29.367493+00:00 0:00:00.499638 22737 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T00:11:26.211639+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T23:00:00+00:00 TriggerDagRunOperator 2021-04-30T00:11:28.553000+00:00 2021-04-30T00:11:29.001352+00:00 0:00:00.448352 22736 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T00:11:26.211600+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T23:00:00+00:00 EmrJobFlowSensor 2021-04-30T00:01:03.306373+00:00 2021-04-30T00:11:06.083621+00:00 0:10:02.777248 22732 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T00:01:00.569373+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T00:00:40.803283+00:00 2021-04-30T00:00:42.612340+00:00 0:00:01.809057 22731 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-30T00:00:38.452922+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T23:00:00+00:00 PythonOperator 2021-04-30T00:00:19.138665+00:00 2021-04-30T00:00:22.257728+00:00 0:00:03.119063 22730 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-30T00:00:16.558929+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T22:00:00+00:00 TriggerDagRunOperator 2021-04-29T23:16:15.713163+00:00 2021-04-29T23:16:16.117708+00:00 0:00:00.404545 22723 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T23:16:12.880146+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T22:00:00+00:00 TriggerDagRunOperator 2021-04-29T23:16:15.581056+00:00 2021-04-29T23:16:16.153133+00:00 0:00:00.572077 22722 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T23:16:12.880516+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T22:00:00+00:00 EmrJobFlowSensor 2021-04-29T23:01:15.583333+00:00 2021-04-29T23:11:18.332655+00:00 0:10:02.749322 22717 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T23:01:13.068351+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T23:00:53.237980+00:00 2021-04-29T23:00:55.042317+00:00 0:00:01.804337 22715 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T23:00:50.993493+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T22:00:00+00:00 PythonOperator 2021-04-29T23:00:33.201037+00:00 2021-04-29T23:00:36.183685+00:00 0:00:02.982648 22713 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T23:00:30.982240+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T21:00:00+00:00 TriggerDagRunOperator 2021-04-29T22:11:27.755168+00:00 2021-04-29T22:11:28.307680+00:00 0:00:00.552512 22705 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T22:11:24.821326+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T21:00:00+00:00 TriggerDagRunOperator 2021-04-29T22:11:27.681383+00:00 2021-04-29T22:11:28.103417+00:00 0:00:00.422034 22704 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T22:11:24.821356+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T21:00:00+00:00 EmrJobFlowSensor 2021-04-29T22:01:12.361248+00:00 2021-04-29T22:11:15.154873+00:00 0:10:02.793625 22699 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T22:01:09.943851+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T22:00:52.047150+00:00 2021-04-29T22:00:53.873655+00:00 0:00:01.826505 22698 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T22:00:49.810038+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T21:00:00+00:00 PythonOperator 2021-04-29T22:00:24.071749+00:00 2021-04-29T22:00:27.391511+00:00 0:00:03.319762 22697 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T22:00:21.781567+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T20:00:00+00:00 TriggerDagRunOperator 2021-04-29T21:11:11.327353+00:00 2021-04-29T21:11:11.934516+00:00 0:00:00.607163 22690 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T21:11:08.328408+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T20:00:00+00:00 TriggerDagRunOperator 2021-04-29T21:11:11.184953+00:00 2021-04-29T21:11:11.603784+00:00 0:00:00.418831 22689 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T21:11:08.328364+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T20:00:00+00:00 EmrJobFlowSensor 2021-04-29T21:00:54.370340+00:00 2021-04-29T21:10:57.072924+00:00 0:10:02.702584 22684 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T21:00:52.186066+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T21:00:32.434321+00:00 2021-04-29T21:00:34.154511+00:00 0:00:01.720190 22683 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T21:00:30.143790+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T20:00:00+00:00 PythonOperator 2021-04-29T21:00:10.397409+00:00 2021-04-29T21:00:13.439304+00:00 0:00:03.041895 22682 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T21:00:08.093241+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T19:00:00+00:00 TriggerDagRunOperator 2021-04-29T20:09:24.145442+00:00 2021-04-29T20:09:24.687519+00:00 0:00:00.542077 22673 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T20:09:20.891556+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T19:00:00+00:00 TriggerDagRunOperator 2021-04-29T20:09:23.981763+00:00 2021-04-29T20:09:24.405782+00:00 0:00:00.424019 22672 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T20:09:20.891599+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T19:00:00+00:00 EmrJobFlowSensor 2021-04-29T20:01:00.913622+00:00 2021-04-29T20:09:03.453446+00:00 0:08:02.539824 22667 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T20:00:58.189765+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T20:00:38.737906+00:00 2021-04-29T20:00:40.410078+00:00 0:00:01.672172 22666 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T20:00:36.166218+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T19:00:00+00:00 PythonOperator 2021-04-29T20:00:18.598125+00:00 2021-04-29T20:00:21.649459+00:00 0:00:03.051334 22665 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T20:00:16.150901+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T18:00:00+00:00 TriggerDagRunOperator 2021-04-29T19:11:13.532917+00:00 2021-04-29T19:11:14.087284+00:00 0:00:00.554367 22658 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T19:11:11.243224+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T18:00:00+00:00 TriggerDagRunOperator 2021-04-29T19:11:13.500429+00:00 2021-04-29T19:11:13.955974+00:00 0:00:00.455545 22657 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T19:11:11.243261+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T18:00:00+00:00 EmrJobFlowSensor 2021-04-29T19:00:55.009509+00:00 2021-04-29T19:10:57.826758+00:00 0:10:02.817249 22652 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T19:00:52.832004+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T19:00:33.157171+00:00 2021-04-29T19:00:34.988962+00:00 0:00:01.831791 22651 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T19:00:30.808996+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T18:00:00+00:00 PythonOperator 2021-04-29T19:00:11.237645+00:00 2021-04-29T19:00:14.312643+00:00 0:00:03.074998 22650 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T19:00:08.848456+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T17:00:00+00:00 TriggerDagRunOperator 2021-04-29T18:10:14.057143+00:00 2021-04-29T18:10:14.520213+00:00 0:00:00.463070 22643 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T18:10:11.360645+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T17:00:00+00:00 TriggerDagRunOperator 2021-04-29T18:10:14.017196+00:00 2021-04-29T18:10:14.560583+00:00 0:00:00.543387 22642 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T18:10:11.360689+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T17:00:00+00:00 EmrJobFlowSensor 2021-04-29T18:01:04.752157+00:00 2021-04-29T18:10:07.436243+00:00 0:09:02.684086 22637 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T18:01:02.066398+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T18:00:42.449883+00:00 2021-04-29T18:00:44.279682+00:00 0:00:01.829799 22636 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T18:00:40.044170+00:00 2 default_pool