self/botalka
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Update daemons/mailbox.py #27

Merged
emmatveev merged 1 commits from master into dev 2024-12-02 22:39:11 +03:00
Conversation 0 Commits 1 Files Changed 1 +1 -4
1 changed files with 1 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
daemons/mailbox.py
View File

@ -24,10 +24,7 @@ class Daemon(base.Daemon, queues.TasksHandlerMixin):
return 'botalka_mailbox' return 'botalka_mailbox'
def before_execute(self, task: dict): def before_execute(self, task: dict):
locks.acquire(task['id']) locks.acquire(task['id'], 60)
def after_execute(self, task: dict):
locks.release(task['id'])
def process(self, payload: dict): def process(self, payload: dict):
message = Message.model_validate(payload) message = Message.model_validate(payload)