diff --git a/src/daemon/dispatcher.py b/src/daemon/dispatcher.py index f34173b..567963c 100644 --- a/src/daemon/dispatcher.py +++ b/src/daemon/dispatcher.py @@ -205,6 +205,7 @@ class Dispatcher: new_session=(level == DispatchLevel.ESCALATE), task_id=task.id, on_complete=on_complete, + use_main_session=getattr(task, 'project_id', None) == "_mail", ) self._record_routing(task, decision, "dispatched",