diff --git a/gso/tasks/massive_redeploy_base_config.py b/gso/tasks/massive_redeploy_base_config.py index cb072d557dbe346c2e81fad8948bae10152deb2e..011df8dac042af59d2d580484917c947852c59fb 100644 --- a/gso/tasks/massive_redeploy_base_config.py +++ b/gso/tasks/massive_redeploy_base_config.py @@ -105,13 +105,6 @@ def massive_redeploy_base_config_task( callback_route: str, ) -> None: """Kicks off one Celery subtask per router, then runs the final callback.""" - # 1. De dupe and fetch FQDNs (so subtasks don't hit the DB twice) unique_ids = list(dict.fromkeys(selected_routers)) - router_map = {} - for rid in unique_ids: - sub = Router.from_subscription(rid) - router_map[rid] = sub.router.router_fqdn - - # 2. Build a chord: all process_one_router subtasks → finalize_massive_redeploy header = [process_one_router.s(rid, tt_number) for rid in unique_ids] # type: ignore[attr-defined] chord(header)(finalize_massive_redeploy.s(callback_route, unique_ids)) # type: ignore[attr-defined]