Ryan Marvin comments

Results 8 comments of


                                            Ryan Marvin

Stopping multiple consumers in a short window freezes on GroupCoordinator._heartbeat_routine()

I think it may be happening when stop() is called after a rebalance and that consumer might not be a part of the group anymore but I'm not sure. I'm...

Stopping multiple consumers in a short window freezes on GroupCoordinator._heartbeat_routine()

This code reproduces the issue. I've been able to make it happen on Python **3.8.10 and 3.9.6** but it does _not_ occur for Python **3.8.5**. This was running on a...

Stopping multiple consumers in a short window freezes on GroupCoordinator._heartbeat_routine()

Wow. This sounds consistent with the behaviour I've been seeing around other `wait_for` calls I tried to make. Besides downgrading the Python version, is there any other patch you'd recommend...

Stopping multiple consumers in a short window freezes on GroupCoordinator._heartbeat_routine()

Thanks. The biggest blocker is actually the AIOKafkaConsumer() stop call and having unreleased resources left over. I've mentioned that here https://github.com/python/cpython/pull/26097#issuecomment-903792466. Thank you for your suggestion around monkey-patching!

connection was closed in the middle of operation

> Since #313 is closed, I am reporting the error here as well. > > * **asyncpg version:** 0.18.2 and master > * **PostgreSQL version:** 9.6.10 and 10.6 > *...

support for websockets with ssl

I can confirm this worked for me. Thanks @milgner

Inconsistent behavior when using ExVCR to test logic that makes HTTP requests in spawned processes

It seems that network calls from spawned processes are not mocked at all. Upon switching off my wifi and running this test when a cassette is already populated, I receive...

maturin failed: Failed to normalize python source path `python`

In case anyone is having trouble reproducing this, doing this docker build on my ARM macbook with a linux/arm64 build target reproduces the error but succeeds when targetting linux/amd64 ```...