Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-flow-job_v002 trigger_dagrun_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 vc-asset-import_v002 check_cluster_status 2021-04-30T10:05:00+00:00 EmrJobFlowSensor 2021-04-30T11:05:57.411396+00:00 2021-04-30T11:15:00.089179+00:00 0:09:02.677783 22901 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T11:05:55.066776+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-30T10:05:00+00:00 EmrCreateJobFlowOperator 2021-04-30T11:05:37.414420+00:00 2021-04-30T11:05:39.057674+00:00 0:00:01.643254 22900 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T11:05:35.047696+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-30T10:05:00+00:00 PythonOperator 2021-04-30T11:05:15.181154+00:00 2021-04-30T11:05:18.152589+00:00 0:00:02.971435 22899 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T11:05:12.916706+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-history-job_v002 check_cluster_status 2021-04-30T09:00:00+00:00 EmrJobFlowSensor 2021-04-30T10:10:25.887081+00:00 2021-04-30T10:19:28.696922+00:00 0:09:02.809841 22894 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T10:10:23.560533+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-30T09:00:00+00:00 EmrJobFlowSensor 2021-04-30T10:10:21.819211+00:00 2021-04-30T10:19:24.657154+00:00 0:09:02.837943 22893 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T10:10:19.556576+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-30T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T10:10:04.147210+00:00 2021-04-30T10:10:05.839623+00:00 0:00:01.692413 22892 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T10:10:01.537618+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-30T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T10:10:01.761686+00:00 2021-04-30T10:10:03.880200+00:00 0:00:02.118514 22891 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T10:09:59.551149+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-30T09:00:00+00:00 PythonOperator 2021-04-30T10:09:42.352081+00:00 2021-04-30T10:09:45.488767+00:00 0:00:03.136686 22890 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T10:09:39.506613+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-30T09:00:00+00:00 PythonOperator 2021-04-30T10:09:40.121345+00:00 2021-04-30T10:09:43.803604+00:00 0:00:03.682259 22889 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T10:09:37.568231+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 vc-asset-import_v002 check_cluster_status 2021-04-30T09:05:00+00:00 EmrJobFlowSensor 2021-04-30T10:05:51.281176+00:00 2021-04-30T10:14:53.950451+00:00 0:09:02.669275 22886 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T10:05:49.150209+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-30T09:05:00+00:00 EmrCreateJobFlowOperator 2021-04-30T10:05:31.342589+00:00 2021-04-30T10:05:33.095884+00:00 0:00:01.753295 22885 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T10:05:29.105401+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-30T09:05:00+00:00 PythonOperator 2021-04-30T10:05:09.401412+00:00 2021-04-30T10:05:12.430179+00:00 0:00:03.028767 22884 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T10:05:07.086648+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-history-job_v002 check_cluster_status 2021-04-30T08:00:00+00:00 EmrJobFlowSensor 2021-04-30T09:12:11.125480+00:00 2021-04-30T09:21:14.121517+00:00 0:09:02.996037 22879 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T09:12:08.705477+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-30T08:00:00+00:00 EmrJobFlowSensor 2021-04-30T09:12:11.146685+00:00 2021-04-30T09:21:13.868209+00:00 0:09:02.721524 22878 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T09:12:08.705442+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-30T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T09:11:51.376500+00:00 2021-04-30T09:11:53.070589+00:00 0:00:01.694089 22877 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T09:11:48.659067+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-30T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T09:11:49.221856+00:00 2021-04-30T09:11:51.193866+00:00 0:00:01.972010 22876 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T09:11:46.659257+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-30T08:00:00+00:00 PythonOperator 2021-04-30T09:11:29.294069+00:00 2021-04-30T09:11:32.673055+00:00 0:00:03.378986 22875 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T09:11:26.679950+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-30T08:00:00+00:00 PythonOperator 2021-04-30T09:11:26.954884+00:00 2021-04-30T09:11:29.983236+00:00 0:00:03.028352 22874 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T09:11:24.664219+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 vc-asset-import_v002 check_cluster_status 2021-04-30T08:05:00+00:00 EmrJobFlowSensor 2021-04-30T09:05:54.433174+00:00 2021-04-30T09:14:57.025361+00:00 0:09:02.592187 22871 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T09:05:52.203149+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-30T08:05:00+00:00 EmrCreateJobFlowOperator 2021-04-30T09:05:32.396670+00:00 2021-04-30T09:05:34.138072+00:00 0:00:01.741402 22870 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T09:05:30.190961+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-30T08:05:00+00:00 PythonOperator 2021-04-30T09:05:10.416215+00:00 2021-04-30T09:05:13.383250+00:00 0:00:02.967035 22869 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T09:05:08.154877+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 booking-processing-job_v002 check_cluster_status 2021-04-30T07:00:00+00:00 EmrJobFlowSensor 2021-04-30T08:11:47.030391+00:00 2021-04-30T08:21:49.830528+00:00 0:10:02.800137 22864 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T08:11:44.898573+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-30T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T08:11:25.349413+00:00 2021-04-30T08:11:27.167161+00:00 0:00:01.817748 22863 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T08:11:22.951410+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-30T07:00:00+00:00 EmrJobFlowSensor 2021-04-30T08:11:17.126048+00:00 2021-04-30T08:21:19.936420+00:00 0:10:02.810372 22862 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T08:11:14.825524+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-30T07:00:00+00:00 PythonOperator 2021-04-30T08:11:03.424218+00:00 2021-04-30T08:11:06.674414+00:00 0:00:03.250196 22861 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T08:11:01.040635+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-30T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T08:10:53.075886+00:00 2021-04-30T08:10:54.712921+00:00 0:00:01.637035 22860 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T08:10:50.640865+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-30T07:00:00+00:00 PythonOperator 2021-04-30T08:10:31.431680+00:00 2021-04-30T08:10:34.524911+00:00 0:00:03.093231 22859 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T08:10:28.611938+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 vc-asset-import_v002 check_cluster_status 2021-04-30T07:05:00+00:00 EmrJobFlowSensor 2021-04-30T08:05:48.598457+00:00 2021-04-30T08:14:51.251811+00:00 0:09:02.653354 22856 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T08:05:46.167530+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-30T07:05:00+00:00 EmrCreateJobFlowOperator 2021-04-30T08:05:26.158875+00:00 2021-04-30T08:05:27.788118+00:00 0:00:01.629243 22855 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T08:05:24.021982+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-30T07:05:00+00:00 PythonOperator 2021-04-30T08:05:06.255713+00:00 2021-04-30T08:05:09.247570+00:00 0:00:02.991857 22854 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T08:05:04.006532+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-history-job_v002 check_cluster_status 2021-04-30T06:00:00+00:00 EmrJobFlowSensor 2021-04-30T07:11:23.615766+00:00 2021-04-30T07:20:26.359855+00:00 0:09:02.744089 22849 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T07:11:21.188550+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-30T06:00:00+00:00 EmrJobFlowSensor 2021-04-30T07:11:21.442248+00:00 2021-04-30T07:21:24.157434+00:00 0:10:02.715186 22848 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T07:11:19.187676+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-30T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T07:11:04.817595+00:00 2021-04-30T07:11:06.655213+00:00 0:00:01.837618 22847 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T07:11:01.152446+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-30T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T07:11:02.012816+00:00 2021-04-30T07:11:04.183125+00:00 0:00:02.170309 22846 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T07:10:59.161606+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-30T06:00:00+00:00 PythonOperator 2021-04-30T07:10:41.462378+00:00 2021-04-30T07:10:44.483975+00:00 0:00:03.021597 22845 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T07:10:39.121241+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-30T06:00:00+00:00 PythonOperator 2021-04-30T07:10:39.583708+00:00 2021-04-30T07:10:42.891093+00:00 0:00:03.307385 22844 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T07:10:37.144025+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 vc-asset-import_v002 check_cluster_status 2021-04-30T06:05:00+00:00 EmrJobFlowSensor 2021-04-30T07:06:04.837059+00:00 2021-04-30T07:15:07.575045+00:00 0:09:02.737986 22841 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T07:06:02.539447+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-30T06:05:00+00:00 EmrCreateJobFlowOperator 2021-04-30T07:05:42.667680+00:00 2021-04-30T07:05:44.337519+00:00 0:00:01.669839 22840 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T07:05:40.517508+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-30T06:05:00+00:00 PythonOperator 2021-04-30T07:05:20.798214+00:00 2021-04-30T07:05:23.785341+00:00 0:00:02.987127 22839 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T07:05:18.498450+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-history-job_v002 check_cluster_status 2021-04-30T05:00:00+00:00 EmrJobFlowSensor 2021-04-30T06:12:25.909051+00:00 2021-04-30T06:21:28.462737+00:00 0:09:02.553686 22834 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T06:12:23.486518+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-30T05:00:00+00:00 EmrJobFlowSensor 2021-04-30T06:12:19.612553+00:00 2021-04-30T06:22:22.451709+00:00 0:10:02.839156 22833 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T06:12:17.412114+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-30T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T06:12:03.632682+00:00 2021-04-30T06:12:05.411514+00:00 0:00:01.778832 22832 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T06:12:01.396393+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-30T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T06:11:57.657823+00:00 2021-04-30T06:11:59.333180+00:00 0:00:01.675357 22831 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T06:11:55.403103+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-30T05:00:00+00:00 PythonOperator 2021-04-30T06:11:43.544435+00:00 2021-04-30T06:11:46.650833+00:00 0:00:03.106398 22830 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T06:11:41.344270+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-30T05:00:00+00:00 PythonOperator 2021-04-30T06:11:37.895534+00:00 2021-04-30T06:11:41.134468+00:00 0:00:03.238934 22829 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T06:11:35.330922+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 vc-asset-import_v002 check_cluster_status 2021-04-30T05:05:00+00:00 EmrJobFlowSensor 2021-04-30T06:06:02.880959+00:00 2021-04-30T06:14:05.360063+00:00 0:08:02.479104 22826 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T06:06:00.455478+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-30T05:05:00+00:00 EmrCreateJobFlowOperator 2021-04-30T06:05:40.680367+00:00 2021-04-30T06:05:42.316599+00:00 0:00:01.636232 22825 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T06:05:38.297652+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-30T05:05:00+00:00 PythonOperator 2021-04-30T06:05:18.928964+00:00 2021-04-30T06:05:21.894897+00:00 0:00:02.965933 22824 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T06:05:16.283083+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 booking-processing-job_v002 check_cluster_status 2021-04-30T04:00:00+00:00 EmrJobFlowSensor 2021-04-30T05:11:20.240974+00:00 2021-04-30T05:20:22.739095+00:00 0:09:02.498121 22819 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T05:11:17.961636+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-30T04:00:00+00:00 EmrJobFlowSensor 2021-04-30T05:11:16.433078+00:00 2021-04-30T05:20:19.282235+00:00 0:09:02.849157 22818 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T05:11:13.971610+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-30T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T05:10:58.008187+00:00 2021-04-30T05:10:59.725358+00:00 0:00:01.717171 22817 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T05:10:55.786247+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-30T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T05:10:54.124113+00:00 2021-04-30T05:10:55.886284+00:00 0:00:01.762171 22816 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T05:10:51.763365+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-30T04:00:00+00:00 PythonOperator 2021-04-30T05:10:38.467484+00:00 2021-04-30T05:10:41.992549+00:00 0:00:03.525065 22815 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T05:10:35.692847+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-30T04:00:00+00:00 PythonOperator 2021-04-30T05:10:34.201685+00:00 2021-04-30T05:10:37.838689+00:00 0:00:03.637004 22814 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T05:10:31.692510+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 vc-asset-import_v002 check_cluster_status 2021-04-30T04:05:00+00:00 EmrJobFlowSensor 2021-04-30T05:05:55.316266+00:00 2021-04-30T05:14:57.905284+00:00 0:09:02.589018 22811 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T05:05:53.123595+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-30T04:05:00+00:00 EmrCreateJobFlowOperator 2021-04-30T05:05:33.290382+00:00 2021-04-30T05:05:35.079621+00:00 0:00:01.789239 22810 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T05:05:31.109444+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-30T04:05:00+00:00 PythonOperator 2021-04-30T05:05:11.316578+00:00 2021-04-30T05:05:14.407000+00:00 0:00:03.090422 22809 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T05:05:09.085694+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 vc-asset-import_v002 check_cluster_status 2021-04-30T03:05:00+00:00 EmrJobFlowSensor 2021-04-30T04:13:12.761171+00:00 2021-04-30T04:14:14.365534+00:00 0:01:01.604363 22804 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T04:13:10.530391+00:00 3 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-30T03:00:00+00:00 EmrJobFlowSensor 2021-04-30T04:11:26.304410+00:00 2021-04-30T04:21:29.095453+00:00 0:10:02.791043 22803 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T04:11:24.170535+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-30T03:00:00+00:00 EmrJobFlowSensor 2021-04-30T04:11:24.553786+00:00 2021-04-30T04:20:27.359779+00:00 0:09:02.805993 22802 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T04:11:22.159943+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-30T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T04:11:06.788400+00:00 2021-04-30T04:11:08.539406+00:00 0:00:01.751006 22801 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T04:11:04.143163+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-30T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T04:11:04.491735+00:00 2021-04-30T04:11:06.694780+00:00 0:00:02.203045 22800 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T04:11:02.140803+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-30T03:00:00+00:00 PythonOperator 2021-04-30T04:10:42.337990+00:00 2021-04-30T04:10:45.615943+00:00 0:00:03.277953 22799 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T04:10:40.084265+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-30T03:00:00+00:00 PythonOperator 2021-04-30T04:10:41.056440+00:00 2021-04-30T04:10:44.169010+00:00 0:00:03.112570 22798 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T04:10:38.140875+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