lavkach3

1
import taskiq_fastapi
2
from taskiq import InMemoryBroker
3
from taskiq_nats import NatsBroker
4
from taskiq_redis import RedisAsyncResultBackend
5

6
from fastapi_app.settings import settings
7

8
broker = NatsBroker(
9
    settings.nats_urls.split(","),
10
    queue="fastapi_app_queue",
11
).with_result_backend(
12
    RedisAsyncResultBackend(settings.redis_url),
13
)
14

15
# Actually, you can remove this line and test agains real
16
# broker. Which is more preferable in some cases.
17
if settings.env.lower() == "pytest":
18
    broker = InMemoryBroker()
19

20

21
taskiq_fastapi.init(broker, "fastapi_app.__main__:get_app")