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
committed by Trenton H
parent 7e0dc2bca4
commit f7172a94e2
-1
View File
@@ -1122,7 +1122,6 @@ def before_task_publish_handler(
return
try:
close_old_connections()
_, task_kwargs, _ = body
task_id = headers["id"]