Closed enlike closed 11 months ago
Can you try updating to 0.10.1?
I tested with these versions:
taskiq 0.10.1
taskiq-aio-pika 0.4.0
Here's the code:
import asyncio
from taskiq_aio_pika import AioPikaBroker
broker = AioPikaBroker("amqp://guest:guest@localhost:5672")
@broker.task(task_name="left")
async def my_task(val: int):
print("left", val)
async def main():
await broker.startup()
await my_task.kiq(11)
await broker.shutdown()
if __name__ == "__main__":
asyncio.run(main())
I tried two commands:
taskiq worker a:broker --max-prefetch 20
and
taskiq worker a:broker
To send a task I simply executed provided script with python a.py
.
Should be fixed in https://github.com/taskiq-python/taskiq/releases/tag/0.10.2.
fixed in 0.10.2 thx
Hi!
Facing issue when run taskiq
task_broker.py code below:
deps:
Run configuration:
taskiq worker core.taskiq.task_broker:broker
Full error: