I need to return a value in async function. I tried to use synchronous form of return: output: 0 [Finished in 204ms] But it just return value of the first loop, which is not expexted. So changed the code as below: output: TypeError: ‘async_generator’ object is not iterable by using async generator…
Tag: python-asyncio
asyncio.sleep required after cancelling tasks?
To test a man-in-the-middle tcp proxy I have coded an echo tcp server and a tcp client. After each one of the tests I want the proxy and the server to go down, to make sure each test starts on a clean environment, so I have coded: Now, the problem is: unless I add in the method tearDown the last
asyncio.gather not executing tasks when caller function requests input from STDIN?
In the following contrived example I am attempting to get input from STDIN and execute a list of coroutine tasks concurrently using asyncio.gather based on the input from STDIN.: However when executing the above code the output does not contain the desired output when the corresponding option is entered. Inpu…
asyncio.wait_for does not propagate CancelledError, if waited on future is “done” before cancellation
I’m working on an application that features tasks that can be started by the user. These tasks can also be aborted by the user. The notable thing is, that the cancellation can happen at any given time. I implemented this by using asyncio.tasks.Task which I cancel if the user aborts. I recently updated f…
Grouping asynchronous functions to run
I have a code that outputs numbers from 1 to 10: Output: 1 2 3 4 5 6 7 8 9 10 It is noticeable that in the example above, 10 functions are simultaneously launched at once. How can I fix the code so that the number of concurrent launched functions main() is equal to count_group? That is, immediately the
asyncio python coroutine cancelled while task still pending reading from redis channel
I have multiple couroutines each of which waits for content in a queue to start processing. The content for the queues is populated by channel subscribers whose job is only to receive messages a push an item in the appropriate queue. After the data is consumed by one queue processor and new data is generated …
add task to running loop and run until complete
I have a function called from an async function without await, and my function needs to call async functions. I can do this with asyncio.get_running_loop().create_task(sleep()) but the run_until_complete at the top level doesn’t run until the new task is complete. How do I get the event loop to run unti…
Fire-and-forget upload to S3 from a Lambda function
I have a lambda function where, after computation is finished, some calls are made to store metadata on S3 and DynamoDB. The S3 upload step is the biggest bottleneck in the function, so I’m wondering if there is a way to “fire-and-forget” these calls so I don’t have do wait for them be…
Use the same websocket connection in multiple asynchronous loops (Python)
I am running two loops asynchronously, and want both to have access to the same websocket connection. One function periodic_fetch() fetches some data periodically (every 60 seconds) and sends a message to the websocket if a condition is met. The other retrieve_websocket() receives messages from the websocket …
Run a Child Coroutine without Blocking Parent Coroutine
I’m running a Loop to listening information from some API. When I get any response from the API, I want to call a child coroutine that will sleep for few seconds, then process the Information and send it to my Telegram Account, this child coroutine can’t be non-async. I want to keep listening to t…