Serhii Charykov
Serhii Charykov
Probably fixes #70
Using channel after CancelledError exception in basic_consume callback can cause connection to close
Python 3.8.1 aio-pika 6.4.1 aiormq 3.2.0 Consider callback example (using aio_pika): ```python async def callback(message: IncomingMessage): async with message.process(): await asyncio.sleep(0.1) ``` Or plain aiormq: ```python async def callback(message: DeliveredMessage):...
The same as #137 but for PubSub ## Checklist - Python version 3.8.5 - Using Python parser - Using asyncio event loop - Issue does exist against the `master` branch...
Fixes #234 ## Changes - [x] Clean dependencies: * Make `hiredis`, `email-validator` optional for public and required for dev dependencies. * Add `hiredis`, `email-validator` to package extras. * Remove `pptree`,...
# **This is a rough draft** ## What's is implemented: * `datetime.datetime` works as numeric index. * `datetime.date` works as numeric index. * `datetime.time` works as numeric index. ~~(very sketchy,...
When testing with `make test_oss` we get `TypeError: 'NoneType' object is not subscriptable` with Traceback in redis-py not in redis-om: ``` tests_sync/test_json_model.py:29: in if not has_redis_json(): redis_om/checks.py:17: in has_redis_json command_exists...
### Public: - six: is used only in ```python @classmethod def from_redis(cls, res: Any): # TODO: Parsing logic copied from redisearch-py. Evaluate. ``` Is it needed for anything else, do...
Small snippet to illustrate: ``` from fysom import FysomGlobal, FysomGlobalMixin class Model(FysomGlobalMixin, object): GSM = FysomGlobal( events=[('test', ('green', 'not_important'), '=')], initial='green', state_field='state' ) def __init__(self): self.state = None super(Model, self).__init__()...
* [x] This is a bug report * [ ] This is a feature request * [x] I searched existing issues before opening this one ### Expected behavior Docker ignores...
**Describe the bug** `on_start` lifespan callback starts without event loop. **To Reproduce** It's strange because sources already contain "test" file for lifespan, but for some reason lifespan is set to...