py-amqp
py-amqp copied to clipboard
celery
amqplib fork
The bot created this issue to inform you that pyup.io has been set up on this repo. Once you have closed it, the bot will open pull requests for updates...
The rationale behind these changes is to catch linter errors (pep8) automatically before developers submit their changes and pull-requests. These changes will help us become proactive with the apply of...
`_AbstractTransport.__repr__` (or `Connection.__repr__`) might crash. In a report/issue from/in Sentry `self` was reported as "broken repr" in https://github.com/celery/py-amqp/blob/7300741f9fc202083e87abd10e1cb38c28efad92/amqp/transport.py#L352. `_AbstractTransport.__repr__`: https://github.com/celery/py-amqp/blob/7300741f9fc202083e87abd10e1cb38c28efad92/amqp/transport.py#L100-L106 `Connection.__repr__`: https://github.com/celery/py-amqp/blob/7300741f9fc202083e87abd10e1cb38c28efad92/amqp/connection.py#L281-L287 The full traceback: ``` ConnectionResetError: [Errno 104] Connection...
should not work now as expected as it's an early experiment. some changes are needed to work properly.
About 60 seconds after starting a channel.basic_consume followed by a channel.wait(), the connection closes with a Socket Closed error, as here: Traceback (most recent call last): File "./rmqtools.py", line 437,...
**Actual result:** When clicking to py-amqp documentation, user is redirected to latest readthedocs documentation. But it is showing documentation for old py-amqp v. 2.4.2:  **Desirate result:** https://amqp.readthedocs.io should show...
This PR uses hypothesis to check if arrays & dictionaries are serialized and deserialized correctly. I also fixed our integer serialization and deserialization code, bytes string serialization and small string...
``` TimeoutError: [Errno 110] Connection timed out ... ch.connection.drain_events(timeout=1) File "amqp/connection.py", line 471, in drain_events while not self.blocking_read(timeout): File "amqp/connection.py", line 476, in blocking_read frame = self.transport.read_frame() File "amqp/transport.py", line...
Current performance advantage is unclear as I'm aiming for feature parity at the moment. I have added some benchmarks which we will use later on to measure how we're doing.
``` ./extra/update_comments_from_spec.py:13: DeprecationWarning: invalid escape sequence \s '(?Pdef\s+(?P[a-zA-Z0-9_]+)\(.*?\)' ./extra/update_comments_from_spec.py:14: DeprecationWarning: invalid escape sequence \s ':\n+\s+""")(?P.*?)(?=""")', ./extra/update_comments_from_spec.py:52: DeprecationWarning: invalid escape sequence \s regex = ('(?Pdef\s+' + ./extra/update_comments_from_spec.py:54: DeprecationWarning: invalid escape sequence...
