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-06-01T10:00:00+00:00 EmrCreateJobFlowOperator 2023-06-01T11:00:30.836719+00:00 2023-06-01T11:00:31.841587+00:00 0:00:01.004868 389350 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-01T11:00:28.317514+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-01T10:00:00+00:00 PythonOperator 2023-06-01T11:00:08.429664+00:00 2023-06-01T11:00:09.390257+00:00 0:00:00.960593 389348 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-01T11:00:06.296038+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-01T09:00:00+00:00 TriggerDagRunOperator 2023-06-01T10:11:30.616180+00:00 2023-06-01T10:11:31.160591+00:00 0:00:00.544411 389339 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T10:11:28.404651+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-01T09:00:00+00:00 TriggerDagRunOperator 2023-06-01T10:11:30.548584+00:00 2023-06-01T10:11:31.094111+00:00 0:00:00.545527 389338 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T10:11:28.404623+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-01T09:00:00+00:00 EmrJobFlowSensor 2023-06-01T10:01:23.459921+00:00 2023-06-01T10:11:25.188023+00:00 0:10:01.728102 389332 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-01T10:01:21.401840+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-01T09:00:00+00:00 EmrCreateJobFlowOperator 2023-06-01T10:01:01.515115+00:00 2023-06-01T10:01:02.579899+00:00 0:00:01.064784 389330 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-01T10:00:59.380093+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-01T09:00:00+00:00 PythonOperator 2023-06-01T10:00:41.366674+00:00 2023-06-01T10:00:42.324900+00:00 0:00:00.958226 389328 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-01T10:00:39.308536+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-01T08:00:00+00:00 TriggerDagRunOperator 2023-06-01T09:24:59.545821+00:00 2023-06-01T09:24:59.980580+00:00 0:00:00.434759 389319 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T09:24:57.013906+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-01T08:00:00+00:00 TriggerDagRunOperator 2023-06-01T09:24:59.479527+00:00 2023-06-01T09:24:59.914641+00:00 0:00:00.435114 389318 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T09:24:57.013865+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-01T08:00:00+00:00 EmrJobFlowSensor 2023-06-01T09:06:30.129352+00:00 2023-06-01T09:16:31.947367+00:00 0:10:01.818015 389313 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-01T09:06:27.967352+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-01T08:00:00+00:00 EmrCreateJobFlowOperator 2023-06-01T09:06:10.097740+00:00 2023-06-01T09:06:11.006126+00:00 0:00:00.908386 389310 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-01T09:06:07.948469+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-01T08:00:00+00:00 PythonOperator 2023-06-01T09:05:48.369780+00:00 2023-06-01T09:05:49.310978+00:00 0:00:00.941198 389307 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-01T09:05:45.937566+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-01T07:00:00+00:00 TriggerDagRunOperator 2023-06-01T08:12:02.773979+00:00 2023-06-01T08:12:03.413038+00:00 0:00:00.639059 389296 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T08:11:59.898804+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-01T07:00:00+00:00 TriggerDagRunOperator 2023-06-01T08:12:02.264670+00:00 2023-06-01T08:12:02.707255+00:00 0:00:00.442585 389295 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T08:11:59.898840+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-01T07:00:00+00:00 EmrJobFlowSensor 2023-06-01T08:00:47.555572+00:00 2023-06-01T08:10:49.265785+00:00 0:10:01.710213 389290 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-01T08:00:45.473069+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-01T07:00:00+00:00 EmrCreateJobFlowOperator 2023-06-01T08:00:28.346811+00:00 2023-06-01T08:00:29.282205+00:00 0:00:00.935394 389289 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-01T08:00:25.455942+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-01T07:00:00+00:00 PythonOperator 2023-06-01T08:00:06.055042+00:00 2023-06-01T08:00:07.031439+00:00 0:00:00.976397 389287 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-01T08:00:03.446332+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-01T06:00:00+00:00 TriggerDagRunOperator 2023-06-01T07:12:15.460526+00:00 2023-06-01T07:12:15.896840+00:00 0:00:00.436314 389278 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T07:12:13.342922+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-01T06:00:00+00:00 TriggerDagRunOperator 2023-06-01T07:12:15.367303+00:00 2023-06-01T07:12:15.796806+00:00 0:00:00.429503 389277 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T07:12:13.342954+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-01T06:00:00+00:00 EmrJobFlowSensor 2023-06-01T07:00:57.012128+00:00 2023-06-01T07:11:58.961253+00:00 0:11:01.949125 389270 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-01T07:00:54.974487+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-01T06:00:00+00:00 EmrCreateJobFlowOperator 2023-06-01T07:00:35.096389+00:00 2023-06-01T07:00:35.977558+00:00 0:00:00.881169 389268 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-01T07:00:32.956648+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-01T06:00:00+00:00 PythonOperator 2023-06-01T07:00:15.203996+00:00 2023-06-01T07:00:16.194636+00:00 0:00:00.990640 389266 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-01T07:00:12.943633+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-01T05:00:00+00:00 TriggerDagRunOperator 2023-06-01T06:12:37.444516+00:00 2023-06-01T06:12:37.859591+00:00 0:00:00.415075 389257 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T06:12:34.997832+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-01T05:00:00+00:00 TriggerDagRunOperator 2023-06-01T06:12:37.375651+00:00 2023-06-01T06:12:37.839196+00:00 0:00:00.463545 389256 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T06:12:34.997874+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-01T05:00:00+00:00 EmrJobFlowSensor 2023-06-01T06:02:29.570348+00:00 2023-06-01T06:12:31.329247+00:00 0:10:01.758899 389250 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-01T06:02:27.452697+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-01T05:00:00+00:00 EmrCreateJobFlowOperator 2023-06-01T06:02:07.466421+00:00 2023-06-01T06:02:08.391993+00:00 0:00:00.925572 389247 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-01T06:02:05.428977+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-01T05:00:00+00:00 PythonOperator 2023-06-01T06:01:47.519653+00:00 2023-06-01T06:01:48.437724+00:00 0:00:00.918071 389246 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-01T06:01:45.413697+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-01T04:00:00+00:00 TriggerDagRunOperator 2023-06-01T05:27:17.472591+00:00 2023-06-01T05:27:17.905390+00:00 0:00:00.432799 389235 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T05:27:15.072358+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-01T04:00:00+00:00 TriggerDagRunOperator 2023-06-01T05:27:17.438872+00:00 2023-06-01T05:27:17.853584+00:00 0:00:00.414712 389234 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T05:27:15.072392+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-01T04:00:00+00:00 EmrJobFlowSensor 2023-06-01T05:01:06.280626+00:00 2023-06-01T05:11:08.063192+00:00 0:10:01.782566 389231 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-01T05:01:04.088719+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-01T04:00:00+00:00 EmrCreateJobFlowOperator 2023-06-01T05:00:44.281093+00:00 2023-06-01T05:00:45.213173+00:00 0:00:00.932080 389229 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-01T05:00:42.100151+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-01T04:00:00+00:00 PythonOperator 2023-06-01T05:00:22.097217+00:00 2023-06-01T05:00:22.990609+00:00 0:00:00.893392 389227 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-01T05:00:20.007340+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-01T03:00:00+00:00 TriggerDagRunOperator 2023-06-01T04:17:07.228680+00:00 2023-06-01T04:17:07.677287+00:00 0:00:00.448607 389218 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T04:17:04.987110+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-01T03:00:00+00:00 TriggerDagRunOperator 2023-06-01T04:17:07.199720+00:00 2023-06-01T04:17:07.627667+00:00 0:00:00.427947 389217 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T04:17:04.987138+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-01T03:00:00+00:00 EmrJobFlowSensor 2023-06-01T04:06:44.692669+00:00 2023-06-01T04:16:46.625911+00:00 0:10:01.933242 389212 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-01T04:06:42.623606+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-01T03:00:00+00:00 EmrCreateJobFlowOperator 2023-06-01T04:06:24.690569+00:00 2023-06-01T04:06:25.651394+00:00 0:00:00.960825 389209 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-01T04:06:22.597383+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-01T03:00:00+00:00 PythonOperator 2023-06-01T04:06:02.847006+00:00 2023-06-01T04:06:03.829738+00:00 0:00:00.982732 389206 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-01T04:06:00.576992+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-01T02:00:00+00:00 TriggerDagRunOperator 2023-06-01T03:11:25.325727+00:00 2023-06-01T03:11:25.786858+00:00 0:00:00.461131 389195 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T03:11:23.135601+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-01T02:00:00+00:00 TriggerDagRunOperator 2023-06-01T03:11:25.314793+00:00 2023-06-01T03:11:25.789812+00:00 0:00:00.475019 389194 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T03:11:23.135630+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-01T02:00:00+00:00 EmrJobFlowSensor 2023-06-01T03:01:17.845796+00:00 2023-06-01T03:11:19.614210+00:00 0:10:01.768414 389188 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-01T03:01:15.766846+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-01T02:00:00+00:00 EmrCreateJobFlowOperator 2023-06-01T03:00:55.814264+00:00 2023-06-01T03:00:56.738599+00:00 0:00:00.924335 389186 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-01T03:00:53.741535+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-01T02:00:00+00:00 PythonOperator 2023-06-01T03:00:33.952389+00:00 2023-06-01T03:00:34.858913+00:00 0:00:00.906524 389184 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-01T03:00:31.724055+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-01T01:00:00+00:00 TriggerDagRunOperator 2023-06-01T02:11:26.742482+00:00 2023-06-01T02:11:27.218835+00:00 0:00:00.476353 389176 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T02:11:24.653748+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-01T01:00:00+00:00 TriggerDagRunOperator 2023-06-01T02:11:26.719671+00:00 2023-06-01T02:11:27.151742+00:00 0:00:00.432071 389175 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T02:11:24.653712+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-01T01:00:00+00:00 EmrJobFlowSensor 2023-06-01T02:01:03.748273+00:00 2023-06-01T02:11:05.687788+00:00 0:10:01.939515 389168 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-01T02:01:01.799542+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-01T01:00:00+00:00 EmrCreateJobFlowOperator 2023-06-01T02:00:43.818757+00:00 2023-06-01T02:00:44.734305+00:00 0:00:00.915548 389166 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-01T02:00:41.781018+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-01T01:00:00+00:00 PythonOperator 2023-06-01T02:00:22.228852+00:00 2023-06-01T02:00:23.141066+00:00 0:00:00.912214 389164 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-01T02:00:19.803915+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-01T00:00:00+00:00 TriggerDagRunOperator 2023-06-01T01:23:51.878055+00:00 2023-06-01T01:23:52.371523+00:00 0:00:00.493468 389146 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T01:23:49.700338+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-01T00:00:00+00:00 TriggerDagRunOperator 2023-06-01T01:23:51.856110+00:00 2023-06-01T01:23:52.286176+00:00 0:00:00.430066 389145 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T01:23:49.700366+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-01T00:00:00+00:00 EmrJobFlowSensor 2023-06-01T01:13:32.778521+00:00 2023-06-01T01:23:34.532117+00:00 0:10:01.753596 389142 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-01T01:13:30.658501+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-01T00:00:00+00:00 EmrCreateJobFlowOperator 2023-06-01T01:13:10.583033+00:00 2023-06-01T01:13:11.632051+00:00 0:00:01.049018 389138 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-01T01:13:08.638291+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-01T00:00:00+00:00 PythonOperator 2023-06-01T01:12:50.845255+00:00 2023-06-01T01:12:51.922877+00:00 0:00:01.077622 389136 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-01T01:12:48.619119+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-31T23:00:00+00:00 TriggerDagRunOperator 2023-06-01T00:11:17.065579+00:00 2023-06-01T00:11:17.513397+00:00 0:00:00.447818 389124 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T00:11:14.603375+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-31T23:00:00+00:00 TriggerDagRunOperator 2023-06-01T00:11:17.002624+00:00 2023-06-01T00:11:17.413764+00:00 0:00:00.411140 389123 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T00:11:14.603346+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-31T23:00:00+00:00 EmrJobFlowSensor 2023-06-01T00:00:54.797532+00:00 2023-06-01T00:10:56.554612+00:00 0:10:01.757080 389116 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-01T00:00:52.791726+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-31T23:00:00+00:00 EmrCreateJobFlowOperator 2023-06-01T00:00:34.728064+00:00 2023-06-01T00:00:35.670689+00:00 0:00:00.942625 389114 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-01T00:00:32.730239+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-31T23:00:00+00:00 PythonOperator 2023-06-01T00:00:12.782446+00:00 2023-06-01T00:00:13.726797+00:00 0:00:00.944351 389112 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-01T00:00:10.711568+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-31T22:00:00+00:00 TriggerDagRunOperator 2023-05-31T23:11:11.978168+00:00 2023-05-31T23:11:12.493238+00:00 0:00:00.515070 389101 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T23:11:09.725370+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-31T22:00:00+00:00 TriggerDagRunOperator 2023-05-31T23:11:11.934627+00:00 2023-05-31T23:11:12.450906+00:00 0:00:00.516279 389100 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T23:11:09.725398+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-31T22:00:00+00:00 EmrJobFlowSensor 2023-05-31T23:01:03.746714+00:00 2023-05-31T23:11:05.526992+00:00 0:10:01.780278 389092 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-31T23:01:01.703807+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-31T22:00:00+00:00 EmrCreateJobFlowOperator 2023-05-31T23:00:41.747023+00:00 2023-05-31T23:00:43.054470+00:00 0:00:01.307447 389088 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-31T23:00:39.681451+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-31T22:00:00+00:00 PythonOperator 2023-05-31T23:00:21.736571+00:00 2023-05-31T23:00:22.698401+00:00 0:00:00.961830 389086 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-31T23:00:19.668571+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-31T21:00:00+00:00 TriggerDagRunOperator 2023-05-31T22:11:16.455211+00:00 2023-05-31T22:11:16.930882+00:00 0:00:00.475671 389075 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T22:11:14.215570+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-31T21:00:00+00:00 TriggerDagRunOperator 2023-05-31T22:11:16.446337+00:00 2023-05-31T22:11:16.868873+00:00 0:00:00.422536 389074 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T22:11:14.215543+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-31T21:00:00+00:00 EmrJobFlowSensor 2023-05-31T22:01:05.203267+00:00 2023-05-31T22:11:07.031401+00:00 0:10:01.828134 389067 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-31T22:01:03.108857+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-31T21:00:00+00:00 EmrCreateJobFlowOperator 2023-05-31T22:00:43.155215+00:00 2023-05-31T22:00:44.026713+00:00 0:00:00.871498 389065 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-31T22:00:41.090567+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-31T21:00:00+00:00 PythonOperator 2023-05-31T22:00:23.118993+00:00 2023-05-31T22:00:24.004710+00:00 0:00:00.885717 389063 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-31T22:00:21.069027+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-31T20:00:00+00:00 TriggerDagRunOperator 2023-05-31T21:11:19.812208+00:00 2023-05-31T21:11:20.255744+00:00 0:00:00.443536 389052 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T21:11:17.203452+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-31T20:00:00+00:00 TriggerDagRunOperator 2023-05-31T21:11:19.728355+00:00 2023-05-31T21:11:20.162430+00:00 0:00:00.434075 389051 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T21:11:17.203423+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-31T20:00:00+00:00 EmrJobFlowSensor 2023-05-31T21:01:06.105888+00:00 2023-05-31T21:11:07.945288+00:00 0:10:01.839400 389044 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-31T21:01:03.995532+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-31T20:00:00+00:00 EmrCreateJobFlowOperator 2023-05-31T21:00:44.028218+00:00 2023-05-31T21:00:44.973797+00:00 0:00:00.945579 389042 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-31T21:00:42.016920+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-31T20:00:00+00:00 PythonOperator 2023-05-31T21:00:23.969297+00:00 2023-05-31T21:00:24.928828+00:00 0:00:00.959531 389040 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-31T21:00:21.919924+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-31T19:00:00+00:00 TriggerDagRunOperator 2023-05-31T20:11:17.103525+00:00 2023-05-31T20:11:17.559359+00:00 0:00:00.455834 389029 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T20:11:14.502941+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-31T19:00:00+00:00 TriggerDagRunOperator 2023-05-31T20:11:17.006346+00:00 2023-05-31T20:11:17.448018+00:00 0:00:00.441672 389028 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T20:11:14.502912+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-31T19:00:00+00:00 EmrJobFlowSensor 2023-05-31T20:00:55.373961+00:00 2023-05-31T20:10:57.142423+00:00 0:10:01.768462 389020 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-31T20:00:53.240680+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-31T19:00:00+00:00 EmrCreateJobFlowOperator 2023-05-31T20:00:35.385703+00:00 2023-05-31T20:00:36.244848+00:00 0:00:00.859145 389018 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-31T20:00:33.218506+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-31T19:00:00+00:00 PythonOperator 2023-05-31T20:00:13.379455+00:00 2023-05-31T20:00:14.324322+00:00 0:00:00.944867 389016 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-31T20:00:11.199073+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-31T18:00:00+00:00 TriggerDagRunOperator 2023-05-31T19:11:22.541065+00:00 2023-05-31T19:11:22.994975+00:00 0:00:00.453910 389004 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T19:11:20.438950+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-31T18:00:00+00:00 TriggerDagRunOperator 2023-05-31T19:11:22.383186+00:00 2023-05-31T19:11:22.825881+00:00 0:00:00.442695 389003 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T19:11:20.438976+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-31T18:00:00+00:00 EmrJobFlowSensor 2023-05-31T19:01:02.168008+00:00 2023-05-31T19:11:03.870634+00:00 0:10:01.702626 388995 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-31T19:01:00.073723+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-31T18:00:00+00:00 EmrCreateJobFlowOperator 2023-05-31T19:00:40.068184+00:00 2023-05-31T19:00:41.002249+00:00 0:00:00.934065 388994 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-31T19:00:37.991248+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-31T18:00:00+00:00 PythonOperator 2023-05-31T19:00:18.169112+00:00 2023-05-31T19:00:19.082879+00:00 0:00:00.913767 388992 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-31T19:00:15.971754+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-31T17:00:00+00:00 TriggerDagRunOperator 2023-05-31T18:11:21.337781+00:00 2023-05-31T18:11:21.771299+00:00 0:00:00.433518 388982 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T18:11:18.712865+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-31T17:00:00+00:00 TriggerDagRunOperator 2023-05-31T18:11:21.187106+00:00 2023-05-31T18:11:21.649217+00:00 0:00:00.462111 388981 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T18:11:18.712833+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-31T17:00:00+00:00 EmrJobFlowSensor 2023-05-31T18:00:54.690186+00:00 2023-05-31T18:10:56.478635+00:00 0:10:01.788449 388971 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-31T18:00:52.542941+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-31T17:00:00+00:00 EmrCreateJobFlowOperator 2023-05-31T18:00:34.561469+00:00 2023-05-31T18:00:35.545438+00:00 0:00:00.983969 388970 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-31T18:00:32.522523+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-31T17:00:00+00:00 PythonOperator 2023-05-31T18:00:12.762978+00:00 2023-05-31T18:00:13.669943+00:00 0:00:00.906965 388968 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-31T18:00:10.503482+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-31T16:00:00+00:00 TriggerDagRunOperator 2023-05-31T17:17:34.096807+00:00 2023-05-31T17:17:34.529342+00:00 0:00:00.432535 388959 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T17:17:31.803418+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-31T16:00:00+00:00 TriggerDagRunOperator 2023-05-31T17:17:34.021153+00:00 2023-05-31T17:17:34.462593+00:00 0:00:00.441440 388958 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T17:17:31.803446+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-31T16:00:00+00:00 EmrJobFlowSensor 2023-05-31T17:01:04.385000+00:00 2023-05-31T17:11:06.081515+00:00 0:10:01.696515 388948 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-31T17:01:02.312864+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-31T16:00:00+00:00 EmrCreateJobFlowOperator 2023-05-31T17:00:42.610127+00:00 2023-05-31T17:00:43.540645+00:00 0:00:00.930518 388947 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-31T17:00:40.290471+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-31T16:00:00+00:00 PythonOperator 2023-05-31T17:00:22.392024+00:00 2023-05-31T17:00:23.325731+00:00 0:00:00.933707 388946 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-31T17:00:20.272282+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-31T15:00:00+00:00 TriggerDagRunOperator 2023-05-31T16:37:48.721692+00:00 2023-05-31T16:37:49.197072+00:00 0:00:00.475380 388940 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T16:37:46.362600+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-31T15:00:00+00:00 TriggerDagRunOperator 2023-05-31T16:37:48.653762+00:00 2023-05-31T16:37:49.151003+00:00 0:00:00.497241 388939 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T16:37:46.362627+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-31T15:00:00+00:00 EmrJobFlowSensor 2023-05-31T16:02:32.097023+00:00 2023-05-31T16:12:33.940372+00:00 0:10:01.843349 388933 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-31T16:02:29.956076+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-31T15:00:00+00:00 EmrCreateJobFlowOperator 2023-05-31T16:02:10.064919+00:00 2023-05-31T16:02:11.215229+00:00 0:00:01.150310 388930 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-31T16:02:07.933694+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-31T15:00:00+00:00 PythonOperator 2023-05-31T16:01:50.458549+00:00 2023-05-31T16:01:51.472001+00:00 0:00:01.013452 388929 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-31T16:01:47.924346+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-31T14:00:00+00:00 TriggerDagRunOperator 2023-05-31T15:11:10.361754+00:00 2023-05-31T15:11:10.804306+00:00 0:00:00.442552 388919 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T15:11:08.095074+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-31T14:00:00+00:00 TriggerDagRunOperator 2023-05-31T15:11:10.208279+00:00 2023-05-31T15:11:10.655509+00:00 0:00:00.447230 388918 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T15:11:08.095108+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-31T14:00:00+00:00 EmrJobFlowSensor 2023-05-31T15:01:03.971133+00:00 2023-05-31T15:11:05.672801+00:00 0:10:01.701668 388912 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-31T15:01:01.698904+00:00 2 default_pool