Compare commits
6 Commits
Author | SHA1 | Date | |
---|---|---|---|
1c135352ab | |||
bea73c9322 | |||
0112b5c0e4 | |||
57669cf6bd | |||
9a55a4f822 | |||
8bd6dc2701 |
@ -22,6 +22,7 @@ services:
|
||||
networks:
|
||||
- configurator
|
||||
- queues
|
||||
- monitoring
|
||||
environment:
|
||||
STAGE: "production"
|
||||
command: mailbox
|
||||
@ -38,3 +39,5 @@ networks:
|
||||
external: true
|
||||
queues:
|
||||
external: true
|
||||
monitoring:
|
||||
external: true
|
||||
|
@ -2,7 +2,6 @@ from concurrent.futures import ThreadPoolExecutor
|
||||
import datetime
|
||||
import json
|
||||
import os
|
||||
import traceback
|
||||
import uuid
|
||||
import zoneinfo
|
||||
import requests
|
||||
@ -58,7 +57,6 @@ class TasksHandlerMixin:
|
||||
success = True
|
||||
except Exception as exc:
|
||||
print(f'Error processing message id={task["id"]}, payload={task["payload"]}, exc={exc}')
|
||||
traceback.print_stack()
|
||||
success = False
|
||||
end = datetime.datetime.now(zoneinfo.ZoneInfo("Europe/Moscow"))
|
||||
if success:
|
||||
|
Loading…
Reference in New Issue
Block a user