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

Compare commits

base: self:49634845a14dc9fc8a89482b49ad963a7867d96e
Branches Tags
self:master
self:prod
self:metric
self:dev
..
compare: self:e02646a1a2a1abb66b7e8f171eb609fedca8fb33
Branches Tags
self:master
self:prod
self:metric
self:dev

No commits in common. "49634845a14dc9fc8a89482b49ad963a7867d96e" and "e02646a1a2a1abb66b7e8f171eb609fedca8fb33" have entirely different histories.
49634845a1 ... e02646a1a2

1 changed files with 4 additions and 1 deletions
Show Stats Expand all files Collapse all files

5
daemons/mailbox.py
View File

@ -24,7 +24,10 @@ 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'], 60) locks.acquire(task['id'])
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)