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-05-08T21:00:00+00:00 PythonOperator 2021-05-08T22:00:16.254057+00:00 2021-05-08T22:00:19.336429+00:00 0:00:03.082372 25960 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T22:00:13.853374+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T20:00:00+00:00 TriggerDagRunOperator 2021-05-08T21:11:12.583079+00:00 2021-05-08T21:11:13.120783+00:00 0:00:00.537704 25952 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T21:11:10.299581+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T20:00:00+00:00 TriggerDagRunOperator 2021-05-08T21:11:12.519947+00:00 2021-05-08T21:11:12.972123+00:00 0:00:00.452176 25951 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T21:11:10.299540+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T20:00:00+00:00 EmrJobFlowSensor 2021-05-08T21:00:50.898101+00:00 2021-05-08T21:10:53.686056+00:00 0:10:02.787955 25947 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T21:00:48.801814+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T21:00:29.427475+00:00 2021-05-08T21:00:31.223982+00:00 0:00:01.796507 25946 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T21:00:26.850817+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T20:00:00+00:00 PythonOperator 2021-05-08T21:00:08.984246+00:00 2021-05-08T21:00:12.084932+00:00 0:00:03.100686 25945 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T21:00:06.713395+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T19:00:00+00:00 TriggerDagRunOperator 2021-05-08T20:09:29.903500+00:00 2021-05-08T20:09:30.414713+00:00 0:00:00.511213 25937 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T20:09:27.147557+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T19:00:00+00:00 TriggerDagRunOperator 2021-05-08T20:09:29.459622+00:00 2021-05-08T20:09:29.856442+00:00 0:00:00.396820 25936 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T20:09:27.147604+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T19:00:00+00:00 EmrJobFlowSensor 2021-05-08T20:01:06.321392+00:00 2021-05-08T20:09:08.845806+00:00 0:08:02.524414 25932 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T20:01:04.186154+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T20:00:44.206182+00:00 2021-05-08T20:00:45.919911+00:00 0:00:01.713729 25931 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T20:00:42.125363+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T19:00:00+00:00 PythonOperator 2021-05-08T20:00:24.524390+00:00 2021-05-08T20:00:27.561382+00:00 0:00:03.036992 25930 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T20:00:22.103058+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T18:00:00+00:00 TriggerDagRunOperator 2021-05-08T19:10:18.856540+00:00 2021-05-08T19:10:19.359582+00:00 0:00:00.503042 25922 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T19:10:16.341684+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T18:00:00+00:00 TriggerDagRunOperator 2021-05-08T19:10:18.585327+00:00 2021-05-08T19:10:19.013680+00:00 0:00:00.428353 25921 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T19:10:16.341633+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T18:00:00+00:00 EmrJobFlowSensor 2021-05-08T19:01:05.246966+00:00 2021-05-08T19:10:08.041545+00:00 0:09:02.794579 25917 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T19:01:03.096774+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T19:00:41.097674+00:00 2021-05-08T19:00:42.977299+00:00 0:00:01.879625 25916 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T19:00:38.892598+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T18:00:00+00:00 PythonOperator 2021-05-08T19:00:21.214986+00:00 2021-05-08T19:00:24.486948+00:00 0:00:03.271962 25915 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T19:00:18.836239+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T17:00:00+00:00 TriggerDagRunOperator 2021-05-08T18:09:15.488322+00:00 2021-05-08T18:09:16.068665+00:00 0:00:00.580343 25907 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T18:09:12.967270+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T17:00:00+00:00 TriggerDagRunOperator 2021-05-08T18:09:15.333195+00:00 2021-05-08T18:09:15.858048+00:00 0:00:00.524853 25906 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T18:09:12.967318+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T17:00:00+00:00 EmrJobFlowSensor 2021-05-08T18:01:06.319315+00:00 2021-05-08T18:09:09.019159+00:00 0:08:02.699844 25902 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T18:01:03.841408+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T18:00:45.821644+00:00 2021-05-08T18:00:47.658697+00:00 0:00:01.837053 25901 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T18:00:43.581082+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T17:00:00+00:00 PythonOperator 2021-05-08T18:00:23.829642+00:00 2021-05-08T18:00:27.007743+00:00 0:00:03.178101 25900 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T18:00:21.560484+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T16:00:00+00:00 TriggerDagRunOperator 2021-05-08T17:10:25.701053+00:00 2021-05-08T17:10:26.242759+00:00 0:00:00.541706 25892 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T17:10:23.395331+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T16:00:00+00:00 TriggerDagRunOperator 2021-05-08T17:10:25.557141+00:00 2021-05-08T17:10:25.999325+00:00 0:00:00.442184 25891 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T17:10:23.395383+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T16:00:00+00:00 EmrJobFlowSensor 2021-05-08T17:00:58.796006+00:00 2021-05-08T17:10:01.536722+00:00 0:09:02.740716 25887 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T17:00:56.463640+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T17:00:38.566994+00:00 2021-05-08T17:00:40.283367+00:00 0:00:01.716373 25886 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T17:00:36.318497+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T16:00:00+00:00 PythonOperator 2021-05-08T17:00:16.785830+00:00 2021-05-08T17:00:19.909006+00:00 0:00:03.123176 25885 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T17:00:14.350868+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T15:00:00+00:00 TriggerDagRunOperator 2021-05-08T16:10:18.340638+00:00 2021-05-08T16:10:18.865614+00:00 0:00:00.524976 25877 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T16:10:15.880372+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T15:00:00+00:00 TriggerDagRunOperator 2021-05-08T16:10:17.998146+00:00 2021-05-08T16:10:18.502033+00:00 0:00:00.503887 25876 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T16:10:15.880324+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T15:00:00+00:00 EmrJobFlowSensor 2021-05-08T16:00:50.911422+00:00 2021-05-08T16:09:53.740637+00:00 0:09:02.829215 25872 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T16:00:48.697055+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T16:00:29.043789+00:00 2021-05-08T16:00:30.843767+00:00 0:00:01.799978 25871 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T16:00:26.648283+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T15:00:00+00:00 PythonOperator 2021-05-08T16:00:08.815985+00:00 2021-05-08T16:00:11.933744+00:00 0:00:03.117759 25870 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T16:00:06.634979+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T14:00:00+00:00 TriggerDagRunOperator 2021-05-08T15:11:42.202396+00:00 2021-05-08T15:11:42.790746+00:00 0:00:00.588350 25863 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T15:11:39.812513+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T14:00:00+00:00 TriggerDagRunOperator 2021-05-08T15:11:42.129805+00:00 2021-05-08T15:11:42.530059+00:00 0:00:00.400254 25862 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T15:11:39.812485+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T14:00:00+00:00 EmrJobFlowSensor 2021-05-08T15:01:05.980967+00:00 2021-05-08T15:11:08.876032+00:00 0:10:02.895065 25857 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T15:01:03.895666+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T15:00:43.962057+00:00 2021-05-08T15:00:45.665895+00:00 0:00:01.703838 25856 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T15:00:41.812627+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T14:00:00+00:00 PythonOperator 2021-05-08T15:00:22.077542+00:00 2021-05-08T15:00:25.182717+00:00 0:00:03.105175 25855 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T15:00:19.792176+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T13:00:00+00:00 TriggerDagRunOperator 2021-05-08T14:14:26.133065+00:00 2021-05-08T14:14:26.739897+00:00 0:00:00.606832 25848 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T14:14:22.951056+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T13:00:00+00:00 TriggerDagRunOperator 2021-05-08T14:14:25.746275+00:00 2021-05-08T14:14:26.150009+00:00 0:00:00.403734 25847 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T14:14:22.951100+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T13:00:00+00:00 EmrJobFlowSensor 2021-05-08T14:01:04.002848+00:00 2021-05-08T14:14:07.182115+00:00 0:13:03.179267 25842 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T14:01:01.883284+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T14:00:41.913613+00:00 2021-05-08T14:00:43.618601+00:00 0:00:01.704988 25841 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T14:00:39.817336+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T13:00:00+00:00 PythonOperator 2021-05-08T14:00:20.432517+00:00 2021-05-08T14:00:23.534752+00:00 0:00:03.102235 25840 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T14:00:17.862812+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T12:00:00+00:00 TriggerDagRunOperator 2021-05-08T13:10:17.210071+00:00 2021-05-08T13:10:17.749769+00:00 0:00:00.539698 25833 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T13:10:14.805667+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T12:00:00+00:00 TriggerDagRunOperator 2021-05-08T13:10:17.061732+00:00 2021-05-08T13:10:17.459046+00:00 0:00:00.397314 25832 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T13:10:14.805638+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T12:00:00+00:00 EmrJobFlowSensor 2021-05-08T13:00:54.334143+00:00 2021-05-08T13:09:56.980397+00:00 0:09:02.646254 25827 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T13:00:51.954402+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T13:00:34.285297+00:00 2021-05-08T13:00:36.139197+00:00 0:00:01.853900 25826 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T13:00:31.861840+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T12:00:00+00:00 PythonOperator 2021-05-08T13:00:11.971339+00:00 2021-05-08T13:00:15.082289+00:00 0:00:03.110950 25825 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T13:00:09.803395+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T11:00:00+00:00 TriggerDagRunOperator 2021-05-08T12:09:06.903798+00:00 2021-05-08T12:09:07.428077+00:00 0:00:00.524279 25818 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T12:09:04.502611+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T11:00:00+00:00 TriggerDagRunOperator 2021-05-08T12:09:06.781553+00:00 2021-05-08T12:09:07.175161+00:00 0:00:00.393608 25817 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T12:09:04.502647+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T11:00:00+00:00 EmrJobFlowSensor 2021-05-08T12:00:46.990677+00:00 2021-05-08T12:08:49.572432+00:00 0:08:02.581755 25812 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T12:00:44.758141+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T12:00:26.721725+00:00 2021-05-08T12:00:28.458405+00:00 0:00:01.736680 25811 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T12:00:24.604631+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T11:00:00+00:00 PythonOperator 2021-05-08T12:00:04.857680+00:00 2021-05-08T12:00:07.917500+00:00 0:00:03.059820 25810 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T12:00:02.589845+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T10:00:00+00:00 TriggerDagRunOperator 2021-05-08T11:10:04.314621+00:00 2021-05-08T11:10:04.847723+00:00 0:00:00.533102 25803 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T11:10:01.788041+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T10:00:00+00:00 TriggerDagRunOperator 2021-05-08T11:10:04.018034+00:00 2021-05-08T11:10:04.464583+00:00 0:00:00.446549 25802 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T11:10:01.788073+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T10:00:00+00:00 EmrJobFlowSensor 2021-05-08T11:00:51.422783+00:00 2021-05-08T11:09:54.165243+00:00 0:09:02.742460 25797 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T11:00:49.325258+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T11:00:29.880081+00:00 2021-05-08T11:00:31.678155+00:00 0:00:01.798074 25796 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T11:00:27.307395+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T10:00:00+00:00 PythonOperator 2021-05-08T11:00:07.424534+00:00 2021-05-08T11:00:10.495649+00:00 0:00:03.071115 25795 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T11:00:05.284886+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T09:00:00+00:00 TriggerDagRunOperator 2021-05-08T10:11:12.469174+00:00 2021-05-08T10:11:12.987810+00:00 0:00:00.518636 25788 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T10:11:09.954299+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T09:00:00+00:00 TriggerDagRunOperator 2021-05-08T10:11:12.404038+00:00 2021-05-08T10:11:12.800859+00:00 0:00:00.396821 25787 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T10:11:09.954268+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T09:00:00+00:00 EmrJobFlowSensor 2021-05-08T10:01:04.357728+00:00 2021-05-08T10:11:07.222836+00:00 0:10:02.865108 25782 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T10:01:01.962436+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T10:00:42.092895+00:00 2021-05-08T10:00:43.749816+00:00 0:00:01.656921 25781 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T10:00:39.954103+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T09:00:00+00:00 PythonOperator 2021-05-08T10:00:20.114617+00:00 2021-05-08T10:00:23.171748+00:00 0:00:03.057131 25780 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T10:00:17.823962+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T08:00:00+00:00 TriggerDagRunOperator 2021-05-08T09:12:13.489396+00:00 2021-05-08T09:12:14.037564+00:00 0:00:00.548168 25773 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T09:12:11.187215+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T08:00:00+00:00 TriggerDagRunOperator 2021-05-08T09:12:13.335323+00:00 2021-05-08T09:12:13.741872+00:00 0:00:00.406549 25772 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T09:12:11.187242+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T08:00:00+00:00 EmrJobFlowSensor 2021-05-08T09:02:48.667166+00:00 2021-05-08T09:11:51.355571+00:00 0:09:02.688405 25768 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T09:02:46.381150+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T09:02:26.699661+00:00 2021-05-08T09:02:28.520560+00:00 0:00:01.820899 25767 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T09:02:24.307386+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T08:00:00+00:00 PythonOperator 2021-05-08T09:02:04.788290+00:00 2021-05-08T09:02:07.848892+00:00 0:00:03.060602 25766 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T09:02:02.286948+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T07:00:00+00:00 TriggerDagRunOperator 2021-05-08T08:11:04.947676+00:00 2021-05-08T08:11:05.461793+00:00 0:00:00.514117 25758 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T08:11:01.848225+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T07:00:00+00:00 TriggerDagRunOperator 2021-05-08T08:11:04.114747+00:00 2021-05-08T08:11:04.509567+00:00 0:00:00.394820 25757 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T08:11:01.848196+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T07:00:00+00:00 EmrJobFlowSensor 2021-05-08T08:00:57.416377+00:00 2021-05-08T08:11:00.457750+00:00 0:10:03.041373 25753 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T08:00:55.115969+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T08:00:35.712040+00:00 2021-05-08T08:00:37.532846+00:00 0:00:01.820806 25752 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T08:00:33.160680+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T07:00:00+00:00 PythonOperator 2021-05-08T08:00:16.038476+00:00 2021-05-08T08:00:19.170920+00:00 0:00:03.132444 25751 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T08:00:13.147682+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T06:00:00+00:00 TriggerDagRunOperator 2021-05-08T07:11:12.759871+00:00 2021-05-08T07:11:13.329233+00:00 0:00:00.569362 25743 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T07:11:10.435712+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T06:00:00+00:00 TriggerDagRunOperator 2021-05-08T07:11:12.708738+00:00 2021-05-08T07:11:13.102222+00:00 0:00:00.393484 25742 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T07:11:10.435739+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T06:00:00+00:00 EmrJobFlowSensor 2021-05-08T07:00:51.349166+00:00 2021-05-08T07:10:54.122088+00:00 0:10:02.772922 25738 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T07:00:49.188408+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T07:00:31.396485+00:00 2021-05-08T07:00:33.086893+00:00 0:00:01.690408 25737 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T07:00:29.146971+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T06:00:00+00:00 PythonOperator 2021-05-08T07:00:10.190848+00:00 2021-05-08T07:00:13.316062+00:00 0:00:03.125214 25736 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T07:00:07.066708+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T05:00:00+00:00 TriggerDagRunOperator 2021-05-08T06:10:10.637297+00:00 2021-05-08T06:10:11.163509+00:00 0:00:00.526212 25728 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T06:10:08.290610+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T05:00:00+00:00 TriggerDagRunOperator 2021-05-08T06:10:10.570486+00:00 2021-05-08T06:10:10.972880+00:00 0:00:00.402394 25727 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T06:10:08.290574+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T05:00:00+00:00 EmrJobFlowSensor 2021-05-08T06:00:49.804896+00:00 2021-05-08T06:09:52.509988+00:00 0:09:02.705092 25723 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T06:00:47.375152+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T06:00:29.491858+00:00 2021-05-08T06:00:31.190719+00:00 0:00:01.698861 25722 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T06:00:27.302275+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T05:00:00+00:00 PythonOperator 2021-05-08T06:00:07.739108+00:00 2021-05-08T06:00:10.874408+00:00 0:00:03.135300 25721 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T06:00:05.286297+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T04:00:00+00:00 TriggerDagRunOperator 2021-05-08T05:10:15.914800+00:00 2021-05-08T05:10:16.493244+00:00 0:00:00.578444 25713 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T05:10:13.559348+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T04:00:00+00:00 TriggerDagRunOperator 2021-05-08T05:10:15.863987+00:00 2021-05-08T05:10:16.286460+00:00 0:00:00.422473 25712 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T05:10:13.559317+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T04:00:00+00:00 EmrJobFlowSensor 2021-05-08T05:01:00.777780+00:00 2021-05-08T05:10:03.535071+00:00 0:09:02.757291 25708 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T05:00:58.566822+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T05:00:38.752198+00:00 2021-05-08T05:00:40.472480+00:00 0:00:01.720282 25707 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T05:00:36.418128+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T04:00:00+00:00 PythonOperator 2021-05-08T05:00:16.773904+00:00 2021-05-08T05:00:19.858985+00:00 0:00:03.085081 25706 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T05:00:14.397010+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T03:00:00+00:00 TriggerDagRunOperator 2021-05-08T04:10:24.583023+00:00 2021-05-08T04:10:25.105321+00:00 0:00:00.522298 25698 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T04:10:22.136577+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T03:00:00+00:00 TriggerDagRunOperator 2021-05-08T04:10:24.402707+00:00 2021-05-08T04:10:24.808490+00:00 0:00:00.405783 25697 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T04:10:22.136608+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T03:00:00+00:00 EmrJobFlowSensor 2021-05-08T04:01:07.358938+00:00 2021-05-08T04:10:10.176000+00:00 0:09:02.817062 25693 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T04:01:05.045850+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T04:00:45.133235+00:00 2021-05-08T04:00:46.817070+00:00 0:00:01.683835 25692 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T04:00:42.895307+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T03:00:00+00:00 PythonOperator 2021-05-08T04:00:25.106030+00:00 2021-05-08T04:00:28.147892+00:00 0:00:03.041862 25691 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T04:00:22.837734+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T02:00:00+00:00 TriggerDagRunOperator 2021-05-08T03:11:41.108572+00:00 2021-05-08T03:11:41.656284+00:00 0:00:00.547712 25683 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T03:11:38.885617+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T02:00:00+00:00 TriggerDagRunOperator 2021-05-08T03:11:41.049692+00:00 2021-05-08T03:11:41.460647+00:00 0:00:00.410955 25682 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T03:11:38.885649+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T02:00:00+00:00 EmrJobFlowSensor 2021-05-08T03:01:19.893032+00:00 2021-05-08T03:11:22.740913+00:00 0:10:02.847881 25678 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T03:01:17.669892+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T03:00:54.090828+00:00 2021-05-08T03:00:55.941563+00:00 0:00:01.850735 25677 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T03:00:51.641692+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T02:00:00+00:00 PythonOperator 2021-05-08T03:00:21.907681+00:00 2021-05-08T03:00:25.056460+00:00 0:00:03.148779 25676 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T03:00:19.640660+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T01:00:00+00:00 TriggerDagRunOperator 2021-05-08T02:11:25.816247+00:00 2021-05-08T02:11:26.416876+00:00 0:00:00.600629 25668 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T02:11:23.437417+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T01:00:00+00:00 TriggerDagRunOperator 2021-05-08T02:11:25.685829+00:00 2021-05-08T02:11:26.071122+00:00 0:00:00.385293 25667 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T02:11:23.437383+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T01:00:00+00:00 EmrJobFlowSensor 2021-05-08T02:01:02.512216+00:00 2021-05-08T02:11:05.322634+00:00 0:10:02.810418 25663 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T02:01:00.230220+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T02:00:40.486922+00:00 2021-05-08T02:00:42.159820+00:00 0:00:01.672898 25662 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T02:00:38.263024+00:00 2 default_pool