taskiq-nats
taskiq-nats copied to clipboard
taskiq-python
NATS broker and result backend for taskiq
picking up from #13 - use official pre-commit repos for mypy and ruff - upgraded taskiq in order to use PickleSerializer - use standard taskiq exception - removed old linters...
I'm trying to run the PushBasedJetStreamBroker as shown in the example. But when I run the main python file, I get an error - **"consumer name already in use"** My...
When we start worker and code with broker that using streams it trying to create new stream every time. Added check if stream created. If not it will be created
```py # broker.py import asyncio from taskiq_redis import RedisAsyncResultBackend, RedisStreamBroker from taskiq_nats import NatsBroker result_backend = RedisAsyncResultBackend( redis_url="redis://default:P@[email protected]:6379", ) # Or you can use PubSubBroker if you need broadcasting #...
