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_cluster_and_add_emr_steps 2023-05-26T14:00:00+00:00 EmrCreateJobFlowOperator 2023-05-26T15:03:08.958600+00:00 2023-05-26T15:03:09.954780+00:00 0:00:00.996180 386216 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-26T15:03:06.900906+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-26T14:00:00+00:00 PythonOperator 2023-05-26T15:02:47.283164+00:00 2023-05-26T15:02:48.145201+00:00 0:00:00.862037 386214 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-26T15:02:44.880608+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-26T13:00:00+00:00 TriggerDagRunOperator 2023-05-26T14:11:22.743759+00:00 2023-05-26T14:11:23.179680+00:00 0:00:00.435921 386205 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T14:11:20.104443+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-26T13:00:00+00:00 TriggerDagRunOperator 2023-05-26T14:11:22.700815+00:00 2023-05-26T14:11:23.135817+00:00 0:00:00.435002 386204 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T14:11:20.104473+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-26T13:00:00+00:00 EmrJobFlowSensor 2023-05-26T14:01:04.547018+00:00 2023-05-26T14:11:06.132193+00:00 0:10:01.585175 386197 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-26T14:01:02.439723+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-26T13:00:00+00:00 EmrCreateJobFlowOperator 2023-05-26T14:00:42.470184+00:00 2023-05-26T14:00:43.332348+00:00 0:00:00.862164 386195 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-26T14:00:40.420716+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-26T13:00:00+00:00 PythonOperator 2023-05-26T14:00:22.533585+00:00 2023-05-26T14:00:23.420999+00:00 0:00:00.887414 386193 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-26T14:00:20.398697+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-26T12:00:00+00:00 TriggerDagRunOperator 2023-05-26T13:24:57.828302+00:00 2023-05-26T13:24:58.275118+00:00 0:00:00.446816 386184 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T13:24:55.592022+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-26T12:00:00+00:00 TriggerDagRunOperator 2023-05-26T13:24:57.804052+00:00 2023-05-26T13:24:58.280742+00:00 0:00:00.476690 386183 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T13:24:55.592052+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-26T12:00:00+00:00 EmrJobFlowSensor 2023-05-26T13:11:46.100814+00:00 2023-05-26T13:21:47.883807+00:00 0:10:01.782993 386179 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-26T13:11:43.956819+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-26T12:00:00+00:00 EmrCreateJobFlowOperator 2023-05-26T13:11:24.020054+00:00 2023-05-26T13:11:24.935987+00:00 0:00:00.915933 386175 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-26T13:11:21.935654+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-26T12:00:00+00:00 PythonOperator 2023-05-26T13:11:04.460967+00:00 2023-05-26T13:11:05.392974+00:00 0:00:00.932007 386173 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-26T13:11:01.977040+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-26T11:00:00+00:00 TriggerDagRunOperator 2023-05-26T12:18:31.966352+00:00 2023-05-26T12:18:32.384707+00:00 0:00:00.418355 386165 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T12:18:29.659341+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-26T11:00:00+00:00 TriggerDagRunOperator 2023-05-26T12:18:31.928186+00:00 2023-05-26T12:18:32.375084+00:00 0:00:00.446898 386164 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T12:18:29.659311+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-26T11:00:00+00:00 EmrJobFlowSensor 2023-05-26T12:01:07.838699+00:00 2023-05-26T12:11:09.598292+00:00 0:10:01.759593 386157 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-26T12:01:05.405517+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-26T11:00:00+00:00 EmrCreateJobFlowOperator 2023-05-26T12:00:45.531745+00:00 2023-05-26T12:00:46.420636+00:00 0:00:00.888891 386154 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-26T12:00:43.384933+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-26T11:00:00+00:00 PythonOperator 2023-05-26T12:00:25.644222+00:00 2023-05-26T12:00:26.540938+00:00 0:00:00.896716 386153 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-26T12:00:23.321308+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-26T10:00:00+00:00 TriggerDagRunOperator 2023-05-26T11:11:22.074509+00:00 2023-05-26T11:11:22.544826+00:00 0:00:00.470317 386142 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T11:11:19.772578+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-26T10:00:00+00:00 TriggerDagRunOperator 2023-05-26T11:11:22.094073+00:00 2023-05-26T11:11:22.581966+00:00 0:00:00.487893 386141 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T11:11:19.772549+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-26T10:00:00+00:00 EmrJobFlowSensor 2023-05-26T11:00:58.060276+00:00 2023-05-26T11:10:59.815179+00:00 0:10:01.754903 386133 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-26T11:00:55.902860+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-26T10:00:00+00:00 EmrCreateJobFlowOperator 2023-05-26T11:00:36.039043+00:00 2023-05-26T11:00:36.975320+00:00 0:00:00.936277 386131 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-26T11:00:33.888695+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-26T10:00:00+00:00 PythonOperator 2023-05-26T11:00:14.124335+00:00 2023-05-26T11:00:15.004242+00:00 0:00:00.879907 386129 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-26T11:00:11.817196+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-26T09:00:00+00:00 TriggerDagRunOperator 2023-05-26T10:11:14.625415+00:00 2023-05-26T10:11:15.085540+00:00 0:00:00.460125 386120 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T10:11:12.305795+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-26T09:00:00+00:00 TriggerDagRunOperator 2023-05-26T10:11:14.481767+00:00 2023-05-26T10:11:14.951373+00:00 0:00:00.469606 386119 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T10:11:12.305825+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-26T09:00:00+00:00 EmrJobFlowSensor 2023-05-26T10:00:54.668777+00:00 2023-05-26T10:10:56.350352+00:00 0:10:01.681575 386112 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-26T10:00:52.591767+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-26T09:00:00+00:00 EmrCreateJobFlowOperator 2023-05-26T10:00:32.622430+00:00 2023-05-26T10:00:33.555365+00:00 0:00:00.932935 386110 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-26T10:00:30.526045+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-26T09:00:00+00:00 PythonOperator 2023-05-26T10:00:12.667916+00:00 2023-05-26T10:00:13.551145+00:00 0:00:00.883229 386108 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-26T10:00:10.490161+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-26T08:00:00+00:00 TriggerDagRunOperator 2023-05-26T09:11:20.441690+00:00 2023-05-26T09:11:20.872360+00:00 0:00:00.430670 386100 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T09:11:17.804764+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-26T08:00:00+00:00 TriggerDagRunOperator 2023-05-26T09:11:20.291508+00:00 2023-05-26T09:11:20.756585+00:00 0:00:00.465077 386099 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T09:11:17.804791+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-26T08:00:00+00:00 EmrJobFlowSensor 2023-05-26T09:00:59.072225+00:00 2023-05-26T09:11:00.975315+00:00 0:10:01.903090 386093 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-26T09:00:56.899390+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-26T08:00:00+00:00 EmrCreateJobFlowOperator 2023-05-26T09:00:37.426384+00:00 2023-05-26T09:00:38.350711+00:00 0:00:00.924327 386091 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-26T09:00:34.818355+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-26T08:00:00+00:00 PythonOperator 2023-05-26T09:00:16.877132+00:00 2023-05-26T09:00:17.810225+00:00 0:00:00.933093 386089 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-26T09:00:14.804115+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-26T07:00:00+00:00 TriggerDagRunOperator 2023-05-26T08:11:48.741804+00:00 2023-05-26T08:11:49.164051+00:00 0:00:00.422247 386078 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T08:11:46.380428+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-26T07:00:00+00:00 TriggerDagRunOperator 2023-05-26T08:11:48.694453+00:00 2023-05-26T08:11:49.127329+00:00 0:00:00.432876 386077 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T08:11:46.380398+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-26T07:00:00+00:00 EmrJobFlowSensor 2023-05-26T08:01:38.364250+00:00 2023-05-26T08:11:40.181993+00:00 0:10:01.817743 386071 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-26T08:01:36.333556+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-26T07:00:00+00:00 EmrCreateJobFlowOperator 2023-05-26T08:01:16.341529+00:00 2023-05-26T08:01:17.209232+00:00 0:00:00.867703 386069 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-26T08:01:14.310995+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-26T07:00:00+00:00 PythonOperator 2023-05-26T08:00:56.364279+00:00 2023-05-26T08:00:57.216424+00:00 0:00:00.852145 386067 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-26T08:00:54.293888+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-26T06:00:00+00:00 TriggerDagRunOperator 2023-05-26T07:14:44.909504+00:00 2023-05-26T07:14:45.432798+00:00 0:00:00.523294 386057 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T07:14:42.634166+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-26T06:00:00+00:00 TriggerDagRunOperator 2023-05-26T07:14:44.870107+00:00 2023-05-26T07:14:45.464267+00:00 0:00:00.594160 386056 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T07:14:42.634195+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-26T06:00:00+00:00 EmrJobFlowSensor 2023-05-26T07:04:25.588403+00:00 2023-05-26T07:14:27.492517+00:00 0:10:01.904114 386049 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-26T07:04:23.573998+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-26T06:00:00+00:00 EmrCreateJobFlowOperator 2023-05-26T07:04:05.551279+00:00 2023-05-26T07:04:06.785133+00:00 0:00:01.233854 386047 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-26T07:04:03.563371+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-26T06:00:00+00:00 PythonOperator 2023-05-26T07:03:44.080086+00:00 2023-05-26T07:03:44.980736+00:00 0:00:00.900650 386045 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-26T07:03:41.536610+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-26T05:00:00+00:00 TriggerDagRunOperator 2023-05-26T06:11:06.199196+00:00 2023-05-26T06:11:06.659390+00:00 0:00:00.460194 386035 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T06:11:04.163071+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-26T05:00:00+00:00 TriggerDagRunOperator 2023-05-26T06:11:06.144612+00:00 2023-05-26T06:11:06.633775+00:00 0:00:00.489163 386034 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T06:11:04.163041+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-26T05:00:00+00:00 EmrJobFlowSensor 2023-05-26T06:00:49.305540+00:00 2023-05-26T06:10:51.212125+00:00 0:10:01.906585 386029 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-26T06:00:47.231034+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-26T05:00:00+00:00 EmrCreateJobFlowOperator 2023-05-26T06:00:27.225150+00:00 2023-05-26T06:00:28.221327+00:00 0:00:00.996177 386027 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-26T06:00:25.209756+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-26T05:00:00+00:00 PythonOperator 2023-05-26T06:00:07.328666+00:00 2023-05-26T06:00:08.174602+00:00 0:00:00.845936 386025 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-26T06:00:05.196563+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-26T04:00:00+00:00 TriggerDagRunOperator 2023-05-26T05:10:56.348835+00:00 2023-05-26T05:10:56.790909+00:00 0:00:00.442074 386014 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T05:10:54.288349+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-26T04:00:00+00:00 TriggerDagRunOperator 2023-05-26T05:10:56.329185+00:00 2023-05-26T05:10:56.768927+00:00 0:00:00.439742 386013 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T05:10:54.288378+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-26T04:00:00+00:00 EmrJobFlowSensor 2023-05-26T05:00:47.736287+00:00 2023-05-26T05:10:49.495521+00:00 0:10:01.759234 386006 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-26T05:00:45.741262+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-26T04:00:00+00:00 EmrCreateJobFlowOperator 2023-05-26T05:00:25.939596+00:00 2023-05-26T05:00:26.851586+00:00 0:00:00.911990 386004 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-26T05:00:23.722880+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-26T04:00:00+00:00 PythonOperator 2023-05-26T05:00:04.161320+00:00 2023-05-26T05:00:05.076120+00:00 0:00:00.914800 386002 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-26T05:00:01.697835+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-26T03:00:00+00:00 TriggerDagRunOperator 2023-05-26T04:11:26.196637+00:00 2023-05-26T04:11:26.674846+00:00 0:00:00.478209 385993 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T04:11:23.982760+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-26T03:00:00+00:00 TriggerDagRunOperator 2023-05-26T04:11:26.096548+00:00 2023-05-26T04:11:26.575816+00:00 0:00:00.479268 385992 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T04:11:23.982732+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-26T03:00:00+00:00 EmrJobFlowSensor 2023-05-26T04:01:11.255374+00:00 2023-05-26T04:11:12.960094+00:00 0:10:01.704720 385986 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-26T04:01:09.236516+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-26T03:00:00+00:00 EmrCreateJobFlowOperator 2023-05-26T04:00:49.178773+00:00 2023-05-26T04:00:50.125960+00:00 0:00:00.947187 385984 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-26T04:00:47.214855+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-26T03:00:00+00:00 PythonOperator 2023-05-26T04:00:29.693300+00:00 2023-05-26T04:00:30.809462+00:00 0:00:01.116162 385982 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-26T04:00:27.196806+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-26T02:00:00+00:00 TriggerDagRunOperator 2023-05-26T03:15:45.926605+00:00 2023-05-26T03:15:46.377568+00:00 0:00:00.450963 385971 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T03:15:43.336946+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-26T02:00:00+00:00 TriggerDagRunOperator 2023-05-26T03:15:45.885475+00:00 2023-05-26T03:15:46.377540+00:00 0:00:00.492065 385970 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T03:15:43.336983+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-26T02:00:00+00:00 EmrJobFlowSensor 2023-05-26T03:00:52.202080+00:00 2023-05-26T03:10:54.034523+00:00 0:10:01.832443 385962 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-26T03:00:50.191659+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-26T02:00:00+00:00 EmrCreateJobFlowOperator 2023-05-26T03:00:30.357576+00:00 2023-05-26T03:00:31.434244+00:00 0:00:01.076668 385960 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-26T03:00:28.110646+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-26T02:00:00+00:00 PythonOperator 2023-05-26T03:00:10.268145+00:00 2023-05-26T03:00:11.182384+00:00 0:00:00.914239 385958 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-26T03:00:08.093437+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-26T01:00:00+00:00 TriggerDagRunOperator 2023-05-26T02:11:26.384388+00:00 2023-05-26T02:11:26.847155+00:00 0:00:00.462767 385948 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T02:11:23.805211+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-26T01:00:00+00:00 TriggerDagRunOperator 2023-05-26T02:11:26.306137+00:00 2023-05-26T02:11:26.723014+00:00 0:00:00.416877 385947 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T02:11:23.805182+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-26T01:00:00+00:00 EmrJobFlowSensor 2023-05-26T02:02:11.283736+00:00 2023-05-26T02:11:12.910913+00:00 0:09:01.627177 385942 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-26T02:02:09.153286+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-26T01:00:00+00:00 EmrCreateJobFlowOperator 2023-05-26T02:00:39.700199+00:00 2023-05-26T02:00:40.628272+00:00 0:00:00.928073 385938 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-26T02:00:37.683029+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-26T01:00:00+00:00 PythonOperator 2023-05-26T02:00:19.695064+00:00 2023-05-26T02:00:20.582605+00:00 0:00:00.887541 385936 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-26T02:00:17.672343+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-26T00:00:00+00:00 TriggerDagRunOperator 2023-05-26T01:11:12.748462+00:00 2023-05-26T01:11:13.172663+00:00 0:00:00.424201 385915 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T01:11:10.206033+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-26T00:00:00+00:00 TriggerDagRunOperator 2023-05-26T01:11:12.755593+00:00 2023-05-26T01:11:13.190909+00:00 0:00:00.435316 385914 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T01:11:10.206061+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-26T00:00:00+00:00 EmrJobFlowSensor 2023-05-26T01:01:46.138204+00:00 2023-05-26T01:10:47.945536+00:00 0:09:01.807332 385908 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-26T01:01:44.005111+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-26T00:00:00+00:00 EmrCreateJobFlowOperator 2023-05-26T01:00:43.199733+00:00 2023-05-26T01:00:44.180965+00:00 0:00:00.981232 385905 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-26T01:00:40.822153+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-26T00:00:00+00:00 PythonOperator 2023-05-26T01:00:23.143820+00:00 2023-05-26T01:00:23.993838+00:00 0:00:00.850018 385903 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-26T01:00:20.804810+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-25T23:00:00+00:00 TriggerDagRunOperator 2023-05-26T00:11:02.089164+00:00 2023-05-26T00:11:02.515577+00:00 0:00:00.426413 385892 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T00:10:59.603718+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-25T23:00:00+00:00 TriggerDagRunOperator 2023-05-26T00:11:01.991151+00:00 2023-05-26T00:11:02.388371+00:00 0:00:00.397220 385891 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T00:10:59.603746+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-25T23:00:00+00:00 EmrJobFlowSensor 2023-05-26T00:01:41.123907+00:00 2023-05-26T00:10:42.895741+00:00 0:09:01.771834 385885 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-26T00:01:39.071295+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-25T23:00:00+00:00 EmrCreateJobFlowOperator 2023-05-26T00:00:42.716263+00:00 2023-05-26T00:00:43.570272+00:00 0:00:00.854009 385882 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-26T00:00:40.703925+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-25T23:00:00+00:00 PythonOperator 2023-05-26T00:00:20.660451+00:00 2023-05-26T00:00:21.538286+00:00 0:00:00.877835 385880 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-26T00:00:18.685083+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-25T22:00:00+00:00 TriggerDagRunOperator 2023-05-25T23:11:07.411466+00:00 2023-05-25T23:11:07.846141+00:00 0:00:00.434675 385869 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T23:11:04.904900+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-25T22:00:00+00:00 TriggerDagRunOperator 2023-05-25T23:11:07.390422+00:00 2023-05-25T23:11:07.846296+00:00 0:00:00.455874 385868 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T23:11:04.904928+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-25T22:00:00+00:00 EmrJobFlowSensor 2023-05-25T23:00:51.178600+00:00 2023-05-25T23:10:52.861058+00:00 0:10:01.682458 385860 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-25T23:00:49.120974+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-25T22:00:00+00:00 EmrCreateJobFlowOperator 2023-05-25T23:00:31.167124+00:00 2023-05-25T23:00:32.098871+00:00 0:00:00.931747 385857 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-25T23:00:29.102938+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-25T22:00:00+00:00 PythonOperator 2023-05-25T23:00:09.055651+00:00 2023-05-25T23:00:09.910339+00:00 0:00:00.854688 385854 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-25T23:00:07.081228+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-25T21:00:00+00:00 TriggerDagRunOperator 2023-05-25T22:11:00.367821+00:00 2023-05-25T22:11:00.823460+00:00 0:00:00.455639 385843 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T22:10:57.696486+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-25T21:00:00+00:00 TriggerDagRunOperator 2023-05-25T22:11:00.367339+00:00 2023-05-25T22:11:00.771427+00:00 0:00:00.404088 385842 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T22:10:57.696516+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-25T21:00:00+00:00 EmrJobFlowSensor 2023-05-25T22:00:53.439814+00:00 2023-05-25T22:10:55.163219+00:00 0:10:01.723405 385832 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-25T22:00:51.437304+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-25T21:00:00+00:00 EmrCreateJobFlowOperator 2023-05-25T22:00:33.427256+00:00 2023-05-25T22:00:34.490868+00:00 0:00:01.063612 385830 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-25T22:00:31.417996+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-25T21:00:00+00:00 PythonOperator 2023-05-25T22:00:11.394680+00:00 2023-05-25T22:00:12.248711+00:00 0:00:00.854031 385828 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-25T22:00:09.371097+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-25T20:00:00+00:00 TriggerDagRunOperator 2023-05-25T21:10:38.689271+00:00 2023-05-25T21:10:39.138825+00:00 0:00:00.449554 385817 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T21:10:36.008059+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-25T20:00:00+00:00 TriggerDagRunOperator 2023-05-25T21:10:38.721940+00:00 2023-05-25T21:10:39.173596+00:00 0:00:00.451656 385816 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T21:10:36.008088+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-25T20:00:00+00:00 EmrJobFlowSensor 2023-05-25T21:01:24.558480+00:00 2023-05-25T21:10:26.144264+00:00 0:09:01.585784 385810 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-25T21:01:22.183108+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-25T20:00:00+00:00 EmrCreateJobFlowOperator 2023-05-25T21:00:40.227080+00:00 2023-05-25T21:00:41.141199+00:00 0:00:00.914119 385807 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-25T21:00:38.321708+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-25T20:00:00+00:00 PythonOperator 2023-05-25T21:00:18.670251+00:00 2023-05-25T21:00:19.516770+00:00 0:00:00.846519 385805 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-25T21:00:16.300199+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-25T19:00:00+00:00 TriggerDagRunOperator 2023-05-25T20:10:35.763881+00:00 2023-05-25T20:10:36.226579+00:00 0:00:00.462698 385794 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T20:10:33.586880+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-25T19:00:00+00:00 TriggerDagRunOperator 2023-05-25T20:10:35.707048+00:00 2023-05-25T20:10:36.109814+00:00 0:00:00.402766 385793 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T20:10:33.586852+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-25T19:00:00+00:00 EmrJobFlowSensor 2023-05-25T20:01:29.329753+00:00 2023-05-25T20:10:31.264453+00:00 0:09:01.934700 385787 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-25T20:01:27.204569+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-25T19:00:00+00:00 EmrCreateJobFlowOperator 2023-05-25T20:00:38.021437+00:00 2023-05-25T20:00:38.958393+00:00 0:00:00.936956 385783 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-25T20:00:35.915047+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-25T19:00:00+00:00 PythonOperator 2023-05-25T20:00:18.016420+00:00 2023-05-25T20:00:18.942804+00:00 0:00:00.926384 385781 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-25T20:00:15.898319+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-25T18:00:00+00:00 TriggerDagRunOperator 2023-05-25T19:11:02.163285+00:00 2023-05-25T19:11:02.621049+00:00 0:00:00.457764 385769 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T19:11:00.108477+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-25T18:00:00+00:00 TriggerDagRunOperator 2023-05-25T19:11:02.079381+00:00 2023-05-25T19:11:02.485686+00:00 0:00:00.406305 385768 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T19:11:00.108450+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-25T18:00:00+00:00 EmrJobFlowSensor 2023-05-25T19:00:55.158140+00:00 2023-05-25T19:10:56.887059+00:00 0:10:01.728919 385760 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-25T19:00:53.111988+00:00 2 default_pool