From df2a7c3bb18ce80940e7ba32ff699d218b1244a6 Mon Sep 17 00:00:00 2001 From: emmatveev Date: Mon, 2 Dec 2024 22:38:50 +0300 Subject: [PATCH] Update daemons/mailbox.py --- daemons/mailbox.py | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) 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)