7,935 questions
1
vote
0
answers
34
views
LangGraph astream_events hangs on node with external api call
I am building a LangGraph pipeline. Nodes 1 and 2 stream fine via astream_events. Node 3 calls an external API then an llm and the stream just hangs forever. No errors and no timeouts.
Sync invoke() ...
- reputation score 59
Best practices
1
vote
4
replies
146
views
How to remove an item from a Python asyncio Queue?
Is it possible to remove a specific item that could be at any position in an asyncio.Queue?
Suppose I use a asyncio.Queue for queuing tasks in a fastapi app to process one single task at a time ...
- reputation score 381
Best practices
0
votes
5
replies
159
views
__await__: may it be called several times and then wait again?
For iterators, there is a clear protocol: once they are exhausted, they remain exhausted.
It is not allowed to create an iterator whose __next__() raises StopIteration and, called once again, return a ...
- reputation score 91690
-1
votes
1
answer
180
views
What does awaiting an object of a user-defined class do?
The Python documentation says:
await is a Python keyword that’s commonly used in one of two different ways:
await task
await coroutine
In a crucial way, the behavior of await depends on the type of ...
- reputation score 6451
1
vote
1
answer
239
views
Why does Python asyncio performance decrease when creating too many small tasks?
I'm experimenting with Python asyncio and noticed that performance becomes worse when I create a very large number of very small async tasks.
import asyncio
import time
async def tiny_task():
...
- reputation score 19
2
votes
0
answers
109
views
grpc.aio + uvloop raises BlockingIOError: [Errno 35] Resource temporarily unavailable
I migrated a Python service from sync grpcio calls wrapped in asyncio.to_thread(...) to native grpc.aio to reduce per-call latency, but after the switch I started seeing this error repeatedly in the ...
- reputation score 1
Advice
0
votes
7
replies
118
views
How to Schedule Weekly Asyncio Tasks
Currently working on a bot for Stoat (a Discord alternative) and was working with asyncio to hopefully have tasks done at a specific time each day or each week. For example, one would execute my ...
- reputation score 1
Advice
0
votes
2
replies
75
views
What is the best way for a django application to query a remote noise meter and update the live data in a users browser?
As the title implies, I am attempting to write a Django application to query noise meters remotely and display the real time information in a web page. Currently I am able to display live data in the ...
- reputation score 1
1
vote
2
answers
119
views
One aync lock call or multiple async lock calls, what is better and safer in Python?
I trying to make ratelimiter for users in aiogram bot with middlware, now I created class for requests and class for ratelimiter, where reuqest are. My problem is what is better for performance and ...
- reputation score 75
0
votes
2
answers
75
views
Why can't I continue to submit jobs to a async io loop that has been started with run forever
I am trying to model a system that uses asyncio and an event loop. I find that if I create an event loop, and start it with run forever it will not process new tasks, unless it has an unfinished ...
- reputation score 12430
3
votes
1
answer
90
views
How can I use asyncio in a script that I also run as a Jupyter notebook?
I often create Jupyter notebooks as plain .py files with # %% cell delimiters, like this:
# %%
import polars as pl
import numpy as np
# %%
df = pl.read_parquet('my_cool.parquet')
...
I can then run ...
- reputation score 2176
Best practices
0
votes
0
replies
37
views
httpx.AsyncClient - single or multiple pools per domain
I am creating an async FastAPI service that trigger models via post requests.
Each model has a different domain.
It should support high throughput and low latency.
What is the best way managing it? ...
- reputation score 711
Best practices
0
votes
0
replies
75
views
waiting for asyncio.Task completion, propagate exceptions
For asyncio workloads there's this convenience function that executes passed list of asyncio.Tasks until either
a timeout is hit;
first Task raises an exception; or
all tasks succeed
First two ...
- reputation score 609
0
votes
1
answer
77
views
Why does asyncio.gather with pandas DataFrame rows not run concurrently?
I'm processing a large pandas DataFrame (500k rows) where each row requires an HTTP request. I switched from requests to aiohttp + asyncio expecting a significant speedup, but the async version runs ...
- reputation score 37
2
votes
1
answer
120
views
What are the advantages/disadvantages of starting a new `ThreadPoolExecutor` when doing `loop.run_in_executor`?
Looking at the documentation for Event Loop, there is this example:
import asyncio
import concurrent.futures
def blocking_io():
# File operations (such as logging) can block the
# event loop: ...
- reputation score 33
