Hi, I used ray’s queue to send data. To avoid blocking, I used put_async, however, it returns the following warning:
RuntimeWarning: coroutine 'Queue.put_async' was never awaited
from ray.util.queue import Queue
queue = Queue(maxsize=10)
queue.put_async(10)
Should I use asyncio to run the async object? Say: asyncio.run(queue.put_async(10))