sogno-platform / sogno-job-queue Goto Github PK

The get_connection() and get_channel() methods determine if the channel/connection is healthy and don't reestablish them if they are.
Connection.is_closed is False even if the message broker terminated the connection due to timeout making that health check impossible.

Currently consumers only recieve the message of the body. This is a problem because:

1. Routing keys can give information about how to handle the message.
2. Long running handling (like training a neural network) should ack the message before starting the task to avoid timeout.

Current work around: Use the get_message() method in a loop to get the whole message.

Describe the bug
Missing sognojq.my_retry package on setuptools

To Reproduce
Steps to reproduce the behavior:
2. Run on Python

import sognojq
from sognojq.amqp import AmqpPublisher
from sognojq.my_retry import retry

Expected behavior

from sognojq.amqp import AmqpPublisher
Traceback (most recent call last):
  File "<stdin>", line 1, in <module>
  File "/home/ubuntu/.local/lib/python3.8/site-packages/sognojq/amqp.py", line 11, in <module>
    from sognojq.my_retry import retry
ModuleNotFoundError: No module named 'sognojq.my_retry'

from sognojq.my_retry import retry
Traceback (most recent call last):
  File "<stdin>", line 1, in <module>
**ModuleNotFoundError: No module named 'sognojq.my_retry'**

Desktop (please complete the following information):

• OS: Ubuntu 20.04 LTS
• Python 3.8.10