The pre_run handler is in the same process, not the worker, so a close_old isn't needed here

This commit is contained in:
Trenton Holmes
2026-05-02 15:12:01 -07:00
parent b38d112691
commit 37496775c0
-1
View File
@@ -1122,7 +1122,6 @@ def before_task_publish_handler(
return
try:
close_old_connections()
_, task_kwargs, _ = body
task_id = headers["id"]