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

18
broker = InMemoryBroker()
19

20

21
taskiq_fastapi.init(broker, "app.bus.bus_server:app")