Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-16T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-16T19:05:34.882062+00:00 2021-04-16T19:05:36.689750+00:00 0:00:01.807688 17919 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T19:05:32.651293+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-16T18:05:00+00:00 PythonOperator 2021-04-16T19:05:12.924109+00:00 2021-04-16T19:05:15.804246+00:00 0:00:02.880137 17918 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T19:05:10.598223+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T18:00:00+00:00 EmrJobFlowSensor 2021-04-16T19:00:52.694838+00:00 2021-04-16T19:09:55.419939+00:00 0:09:02.725101 17917 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T19:00:50.059274+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T19:00:28.868541+00:00 2021-04-16T19:00:30.555485+00:00 0:00:01.686944 17916 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T19:00:26.043622+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T18:00:00+00:00 PythonOperator 2021-04-16T19:00:08.342826+00:00 2021-04-16T19:00:11.344698+00:00 0:00:03.001872 17915 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T19:00:05.987444+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-16T17:00:00+00:00 EmrJobFlowSensor 2021-04-16T18:10:07.146427+00:00 2021-04-16T18:20:09.981688+00:00 0:10:02.835261 17913 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T18:10:04.790434+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-16T17:00:00+00:00 EmrJobFlowSensor 2021-04-16T18:09:54.925490+00:00 2021-04-16T18:19:57.649772+00:00 0:10:02.724282 17912 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T18:09:52.729165+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-16T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T18:09:46.905756+00:00 2021-04-16T18:09:49.339570+00:00 0:00:02.433814 17911 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T18:09:44.723199+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-16T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T18:09:32.949845+00:00 2021-04-16T18:09:34.723884+00:00 0:00:01.774039 17910 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T18:09:30.708617+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-16T17:00:00+00:00 PythonOperator 2021-04-16T18:09:25.248903+00:00 2021-04-16T18:09:28.370419+00:00 0:00:03.121516 17909 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T18:09:22.701779+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-16T17:00:00+00:00 PythonOperator 2021-04-16T18:09:13.260752+00:00 2021-04-16T18:09:16.167116+00:00 0:00:02.906364 17908 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T18:09:10.690195+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T17:00:00+00:00 TriggerDagRunOperator 2021-04-16T18:09:07.160451+00:00 2021-04-16T18:09:07.572129+00:00 0:00:00.411678 17907 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T18:09:04.746804+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T17:00:00+00:00 TriggerDagRunOperator 2021-04-16T18:09:06.976858+00:00 2021-04-16T18:09:07.545779+00:00 0:00:00.568921 17906 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T18:09:04.746834+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-16T17:05:00+00:00 EmrJobFlowSensor 2021-04-16T18:06:10.567694+00:00 2021-04-16T18:15:13.097467+00:00 0:09:02.529773 17905 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T18:06:08.408741+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-16T17:05:00+00:00 EmrCreateJobFlowOperator 2021-04-16T18:05:48.727696+00:00 2021-04-16T18:05:50.420954+00:00 0:00:01.693258 17904 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T18:05:46.451623+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-16T17:05:00+00:00 PythonOperator 2021-04-16T18:05:16.449673+00:00 2021-04-16T18:05:19.308840+00:00 0:00:02.859167 17903 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T18:05:14.360694+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T17:00:00+00:00 EmrJobFlowSensor 2021-04-16T18:01:00.441872+00:00 2021-04-16T18:09:03.054964+00:00 0:08:02.613092 17902 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T18:00:58.079013+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T18:00:34.697177+00:00 2021-04-16T18:00:36.586707+00:00 0:00:01.889530 17901 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T18:00:32.006223+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T17:00:00+00:00 PythonOperator 2021-04-16T18:00:12.527430+00:00 2021-04-16T18:00:15.466164+00:00 0:00:02.938734 17900 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T18:00:09.989832+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-16T16:00:00+00:00 EmrJobFlowSensor 2021-04-16T17:12:24.337890+00:00 2021-04-16T17:21:26.988653+00:00 0:09:02.650763 17898 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T17:12:21.955419+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-16T16:00:00+00:00 EmrJobFlowSensor 2021-04-16T17:12:18.375499+00:00 2021-04-16T17:22:21.195510+00:00 0:10:02.820011 17897 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T17:12:15.959765+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-16T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T17:12:02.236222+00:00 2021-04-16T17:12:04.100886+00:00 0:00:01.864664 17896 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T17:11:59.946840+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-16T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T17:11:58.247028+00:00 2021-04-16T17:12:00.076288+00:00 0:00:01.829260 17895 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T17:11:55.834835+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-16T16:00:00+00:00 PythonOperator 2021-04-16T17:11:41.990301+00:00 2021-04-16T17:11:44.882347+00:00 0:00:02.892046 17894 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T17:11:39.820416+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-16T16:00:00+00:00 PythonOperator 2021-04-16T17:11:36.110201+00:00 2021-04-16T17:11:39.605004+00:00 0:00:03.494803 17893 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T17:11:33.816309+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T16:00:00+00:00 TriggerDagRunOperator 2021-04-16T17:11:22.312010+00:00 2021-04-16T17:11:22.877231+00:00 0:00:00.565221 17892 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T17:11:19.860804+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T16:00:00+00:00 TriggerDagRunOperator 2021-04-16T17:11:22.224630+00:00 2021-04-16T17:11:22.669449+00:00 0:00:00.444819 17891 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T17:11:19.860774+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-16T16:05:00+00:00 EmrJobFlowSensor 2021-04-16T17:05:59.363018+00:00 2021-04-16T17:15:02.049326+00:00 0:09:02.686308 17890 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T17:05:57.115643+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-16T16:05:00+00:00 EmrCreateJobFlowOperator 2021-04-16T17:05:37.307972+00:00 2021-04-16T17:05:38.945330+00:00 0:00:01.637358 17889 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T17:05:35.097286+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-16T16:05:00+00:00 PythonOperator 2021-04-16T17:05:17.253318+00:00 2021-04-16T17:05:20.202976+00:00 0:00:02.949658 17888 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T17:05:15.058440+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T16:00:00+00:00 EmrJobFlowSensor 2021-04-16T17:00:54.536129+00:00 2021-04-16T17:10:57.215410+00:00 0:10:02.679281 17887 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T17:00:52.305596+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T17:00:32.702892+00:00 2021-04-16T17:00:34.968408+00:00 0:00:02.265516 17886 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T17:00:30.282635+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T16:00:00+00:00 PythonOperator 2021-04-16T17:00:10.449889+00:00 2021-04-16T17:00:13.383638+00:00 0:00:02.933749 17885 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T17:00:08.203967+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-16T15:00:00+00:00 EmrJobFlowSensor 2021-04-16T16:35:53.898606+00:00 2021-04-16T16:45:56.589122+00:00 0:10:02.690516 17884 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T16:35:51.711863+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-16T15:00:00+00:00 EmrJobFlowSensor 2021-04-16T16:35:45.930035+00:00 2021-04-16T16:44:48.699301+00:00 0:09:02.769266 17883 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T16:35:43.710902+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-16T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T16:35:30.261301+00:00 2021-04-16T16:35:31.926702+00:00 0:00:01.665401 17882 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T16:35:27.691979+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-16T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T16:35:18.114507+00:00 2021-04-16T16:35:19.807435+00:00 0:00:01.692928 17881 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T16:35:15.663687+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-16T15:00:00+00:00 PythonOperator 2021-04-16T16:35:05.969082+00:00 2021-04-16T16:35:08.868487+00:00 0:00:02.899405 17880 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T16:35:03.650775+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-16T15:00:00+00:00 PythonOperator 2021-04-16T16:34:55.786190+00:00 2021-04-16T16:34:59.108792+00:00 0:00:03.322602 17879 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T16:34:53.644932+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T15:00:00+00:00 TriggerDagRunOperator 2021-04-16T16:34:40.565431+00:00 2021-04-16T16:34:41.001225+00:00 0:00:00.435794 17878 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T16:34:37.683593+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T15:00:00+00:00 TriggerDagRunOperator 2021-04-16T16:34:40.394228+00:00 2021-04-16T16:34:40.934574+00:00 0:00:00.540346 17877 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T16:34:37.683627+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-16T15:05:00+00:00 EmrJobFlowSensor 2021-04-16T16:25:32.794026+00:00 2021-04-16T16:34:35.417096+00:00 0:09:02.623070 17876 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T16:25:30.559881+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T15:00:00+00:00 EmrJobFlowSensor 2021-04-16T16:25:26.787593+00:00 2021-04-16T16:34:29.510253+00:00 0:09:02.722660 17875 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T16:25:24.531098+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-16T15:05:00+00:00 EmrCreateJobFlowOperator 2021-04-16T16:25:10.731254+00:00 2021-04-16T16:25:12.375170+00:00 0:00:01.643916 17874 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T16:25:08.518104+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T16:25:06.676669+00:00 2021-04-16T16:25:08.399702+00:00 0:00:01.723033 17873 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T16:25:04.515362+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-16T15:05:00+00:00 PythonOperator 2021-04-16T16:24:50.686878+00:00 2021-04-16T16:24:53.602493+00:00 0:00:02.915615 17872 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T16:24:48.502276+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T15:00:00+00:00 PythonOperator 2021-04-16T16:24:45.337541+00:00 2021-04-16T16:24:48.431158+00:00 0:00:03.093617 17871 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T16:24:42.518989+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-16T14:00:00+00:00 EmrJobFlowSensor 2021-04-16T15:11:17.223349+00:00 2021-04-16T15:19:19.735146+00:00 0:08:02.511797 17869 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T15:11:14.960313+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-16T14:00:00+00:00 EmrJobFlowSensor 2021-04-16T15:11:17.185463+00:00 2021-04-16T15:20:19.934184+00:00 0:09:02.748721 17868 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T15:11:14.960280+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-16T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T15:10:55.197826+00:00 2021-04-16T15:10:56.994933+00:00 0:00:01.797107 17867 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T15:10:52.840681+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-16T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T15:10:55.077970+00:00 2021-04-16T15:10:56.789008+00:00 0:00:01.711038 17866 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T15:10:52.840649+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-16T14:00:00+00:00 PythonOperator 2021-04-16T15:10:35.524408+00:00 2021-04-16T15:10:38.483656+00:00 0:00:02.959248 17865 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T15:10:32.849329+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-16T14:00:00+00:00 PythonOperator 2021-04-16T15:10:35.375526+00:00 2021-04-16T15:10:38.537079+00:00 0:00:03.161553 17864 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T15:10:32.849281+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T14:00:00+00:00 TriggerDagRunOperator 2021-04-16T15:10:19.328593+00:00 2021-04-16T15:10:19.745725+00:00 0:00:00.417132 17863 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T15:10:16.849196+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T14:00:00+00:00 TriggerDagRunOperator 2021-04-16T15:10:19.166321+00:00 2021-04-16T15:10:19.706724+00:00 0:00:00.540403 17862 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T15:10:16.849146+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-16T14:05:00+00:00 EmrJobFlowSensor 2021-04-16T15:05:58.457564+00:00 2021-04-16T15:15:01.217703+00:00 0:09:02.760139 17861 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T15:05:56.136113+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-16T14:05:00+00:00 EmrCreateJobFlowOperator 2021-04-16T15:05:36.246782+00:00 2021-04-16T15:05:37.906162+00:00 0:00:01.659380 17860 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T15:05:34.115992+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-16T14:05:00+00:00 PythonOperator 2021-04-16T15:05:14.322448+00:00 2021-04-16T15:05:17.174719+00:00 0:00:02.852271 17859 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T15:05:12.093744+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T14:00:00+00:00 EmrJobFlowSensor 2021-04-16T15:01:04.160507+00:00 2021-04-16T15:10:06.815398+00:00 0:09:02.654891 17858 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T15:01:01.752081+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T15:00:41.924476+00:00 2021-04-16T15:00:43.806044+00:00 0:00:01.881568 17857 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T15:00:39.733131+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T14:00:00+00:00 PythonOperator 2021-04-16T15:00:20.822070+00:00 2021-04-16T15:00:23.794395+00:00 0:00:02.972325 17856 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T15:00:17.741887+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-16T13:00:00+00:00 EmrJobFlowSensor 2021-04-16T14:11:18.547156+00:00 2021-04-16T14:21:21.439794+00:00 0:10:02.892638 17854 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T14:11:16.053400+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-16T13:00:00+00:00 EmrJobFlowSensor 2021-04-16T14:11:12.222100+00:00 2021-04-16T14:21:15.178637+00:00 0:10:02.956537 17853 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T14:11:09.986453+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-16T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T14:10:58.227450+00:00 2021-04-16T14:11:00.009005+00:00 0:00:01.781555 17852 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T14:10:55.965445+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-16T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T14:10:50.510943+00:00 2021-04-16T14:10:52.297011+00:00 0:00:01.786068 17851 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T14:10:47.927205+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-16T13:00:00+00:00 PythonOperator 2021-04-16T14:10:36.585602+00:00 2021-04-16T14:10:39.994597+00:00 0:00:03.408995 17850 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T14:10:33.915492+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-16T13:00:00+00:00 PythonOperator 2021-04-16T14:10:30.520722+00:00 2021-04-16T14:10:33.434336+00:00 0:00:02.913614 17849 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T14:10:27.963529+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T13:00:00+00:00 TriggerDagRunOperator 2021-04-16T14:10:24.270586+00:00 2021-04-16T14:10:24.718593+00:00 0:00:00.448007 17848 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T14:10:21.907563+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T13:00:00+00:00 TriggerDagRunOperator 2021-04-16T14:10:24.207679+00:00 2021-04-16T14:10:24.793360+00:00 0:00:00.585681 17847 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T14:10:21.907534+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-16T13:05:00+00:00 EmrJobFlowSensor 2021-04-16T14:05:59.992143+00:00 2021-04-16T14:15:02.759587+00:00 0:09:02.767444 17846 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T14:05:57.285360+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-16T13:05:00+00:00 EmrCreateJobFlowOperator 2021-04-16T14:05:39.559980+00:00 2021-04-16T14:05:41.214531+00:00 0:00:01.654551 17845 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T14:05:37.266448+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-16T13:05:00+00:00 PythonOperator 2021-04-16T14:05:13.513217+00:00 2021-04-16T14:05:16.400919+00:00 0:00:02.887702 17844 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T14:05:11.243322+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T13:00:00+00:00 EmrJobFlowSensor 2021-04-16T14:00:57.633599+00:00 2021-04-16T14:10:00.160289+00:00 0:09:02.526690 17843 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T14:00:54.925540+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T14:00:35.247585+00:00 2021-04-16T14:00:37.076962+00:00 0:00:01.829377 17842 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T14:00:32.906194+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T13:00:00+00:00 PythonOperator 2021-04-16T14:00:13.230783+00:00 2021-04-16T14:00:16.719074+00:00 0:00:03.488291 17841 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T14:00:10.891633+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-16T12:00:00+00:00 EmrJobFlowSensor 2021-04-16T13:12:20.689071+00:00 2021-04-16T13:21:23.328685+00:00 0:09:02.639614 17839 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T13:12:18.499765+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-16T12:00:00+00:00 EmrJobFlowSensor 2021-04-16T13:12:18.853768+00:00 2021-04-16T13:20:21.456390+00:00 0:08:02.602622 17838 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T13:12:16.509296+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-16T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T13:11:59.270000+00:00 2021-04-16T13:12:00.957997+00:00 0:00:01.687997 17837 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T13:11:56.484580+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-16T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T13:11:58.777207+00:00 2021-04-16T13:12:00.850954+00:00 0:00:02.073747 17836 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T13:11:56.484609+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-16T12:00:00+00:00 PythonOperator 2021-04-16T13:11:38.590713+00:00 2021-04-16T13:11:41.711134+00:00 0:00:03.120421 17835 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T13:11:36.393239+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-16T12:00:00+00:00 PythonOperator 2021-04-16T13:11:36.665486+00:00 2021-04-16T13:11:39.827838+00:00 0:00:03.162352 17834 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T13:11:34.390385+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T12:00:00+00:00 TriggerDagRunOperator 2021-04-16T13:11:14.715883+00:00 2021-04-16T13:11:15.239509+00:00 0:00:00.523626 17833 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T13:11:12.334071+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T12:00:00+00:00 TriggerDagRunOperator 2021-04-16T13:11:14.507208+00:00 2021-04-16T13:11:14.922780+00:00 0:00:00.415572 17832 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T13:11:12.334104+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-16T12:05:00+00:00 EmrJobFlowSensor 2021-04-16T13:05:58.075295+00:00 2021-04-16T13:15:00.537231+00:00 0:09:02.461936 17831 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T13:05:55.901867+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-16T12:05:00+00:00 EmrCreateJobFlowOperator 2021-04-16T13:05:32.719587+00:00 2021-04-16T13:05:34.464701+00:00 0:00:01.745114 17830 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T13:05:29.883004+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-16T12:05:00+00:00 PythonOperator 2021-04-16T13:05:10.207712+00:00 2021-04-16T13:05:13.087500+00:00 0:00:02.879788 17829 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T13:05:07.863867+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T12:00:00+00:00 EmrJobFlowSensor 2021-04-16T13:00:55.613299+00:00 2021-04-16T13:10:58.362129+00:00 0:10:02.748830 17828 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T13:00:53.446326+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T13:00:35.597091+00:00 2021-04-16T13:00:37.558766+00:00 0:00:01.961675 17827 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T13:00:33.432263+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T12:00:00+00:00 PythonOperator 2021-04-16T13:00:14.490497+00:00 2021-04-16T13:00:17.412732+00:00 0:00:02.922235 17826 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T13:00:11.540884+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-16T11:00:00+00:00 EmrJobFlowSensor 2021-04-16T12:12:26.497168+00:00 2021-04-16T12:21:29.050502+00:00 0:09:02.553334 17824 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T12:12:24.178348+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-16T11:00:00+00:00 EmrJobFlowSensor 2021-04-16T12:12:16.281445+00:00 2021-04-16T12:22:19.146550+00:00 0:10:02.865105 17823 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T12:12:14.110849+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-16T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T12:12:04.448821+00:00 2021-04-16T12:12:06.478819+00:00 0:00:02.029998 17822 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T12:12:01.771408+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-16T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T12:11:54.035628+00:00 2021-04-16T12:11:55.804787+00:00 0:00:01.769159 17821 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T12:11:51.692233+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-16T11:00:00+00:00 PythonOperator 2021-04-16T12:11:42.662799+00:00 2021-04-16T12:11:45.790120+00:00 0:00:03.127321 17820 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T12:11:39.687770+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-16T11:00:00+00:00 PythonOperator 2021-04-16T12:11:34.046259+00:00 2021-04-16T12:11:36.983227+00:00 0:00:02.936968 17819 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T12:11:31.631823+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T11:00:00+00:00 TriggerDagRunOperator 2021-04-16T12:11:23.946296+00:00 2021-04-16T12:11:24.470300+00:00 0:00:00.524004 17818 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T12:11:21.621361+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T11:00:00+00:00 TriggerDagRunOperator 2021-04-16T12:11:23.793789+00:00 2021-04-16T12:11:24.209842+00:00 0:00:00.416053 17817 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T12:11:21.621390+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-16T11:05:00+00:00 EmrJobFlowSensor 2021-04-16T12:05:51.266213+00:00 2021-04-16T12:14:53.953090+00:00 0:09:02.686877 17816 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T12:05:49.128058+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-16T11:05:00+00:00 EmrCreateJobFlowOperator 2021-04-16T12:05:29.279284+00:00 2021-04-16T12:05:31.220913+00:00 0:00:01.941629 17815 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T12:05:27.109706+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-16T11:05:00+00:00 PythonOperator 2021-04-16T12:05:07.194452+00:00 2021-04-16T12:05:10.045995+00:00 0:00:02.851543 17814 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T12:05:05.097736+00:00 2 default_pool