diff --git a/daemons/mailbox.py b/daemons/mailbox.py index 2589c6c..3e25e47 100644 --- a/daemons/mailbox.py +++ b/daemons/mailbox.py @@ -24,10 +24,7 @@ class Daemon(base.Daemon, queues.TasksHandlerMixin): return 'botalka_mailbox' def before_execute(self, task: dict): - locks.acquire(task['id']) - - def after_execute(self, task: dict): - locks.release(task['id']) + locks.acquire(task['id'], 60) def process(self, payload: dict): message = Message.model_validate(payload)