Tor Arvid Lund
Tor Arvid Lund
@mosquito yeah, we have noticed improved resilience towards network blips with the later releases, so kudos for all the recent improvements 🎉
@mosquito that could be true, but remember: before I made the most recent change today, only a single commit was in the PR, and it didn't have any special handling...
@mosquito I found out some details by hacking `channel_max` to be `2` (instead of `2047`) [here](https://github.com/torarvid/aiormq/blob/fffa397a905f1d30442f6e2ad719f6bb585d8176/aiormq/connection.py#L471). Looks like there's some wrapping happening that probably gets worse and worse when channel_max...
@mosquito I think my idea is mostly that we should (both for Futures and Tasks) ensure that if the caller does not await the future, we don't swallow exceptions. And...
@mosquito I see that there is a FutureStore instance, and it also has a parent FutureStore. It looks like a single future could be added both to the child and...
I did a bit more debugging. 1. I set `channel_max = 20` 2. I added a counter that prints every time we run the TaskWrapper ctor (in total, 264 tasks...
Oh, wow, I just tested this branch, and it seems like it fixes a problem we're having in production, where a burst of message can cause the lock in basic_publish...
@dgoeries To be honest, I'm not sure what burst numbers are needed to trigger it. Someone on my team made a test script to reproduce on a local rabbit server....
Hi. Just wanted to mention that this sounds like a breaking change, and if implemented, would probably have to wait for version 4.0.0.
Hi. I probably don't understand half of the code in this repo, but after experimenting with `uv pip install -vv` locally, I think I might have found a clue: https://github.com/astral-sh/uv/blob/661787b0cbb542f2e8e3bb4fbcc834a42af59f4b/crates/uv-client/src/registry_client.rs#L512-L515...