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