16 lines
333 B
Python
16 lines
333 B
Python
from taskiq_aio_pika import AioPikaBroker
|
|
from taskiq_postgresql import PostgresqlResultBackend
|
|
|
|
from backend.config import RABBITMQ_URL
|
|
from backend.session import DATABASE_URL
|
|
|
|
result_backend = PostgresqlResultBackend(
|
|
dsn=DATABASE_URL,
|
|
)
|
|
|
|
broker = AioPikaBroker(
|
|
RABBITMQ_URL,
|
|
).with_result_backend(
|
|
result_backend,
|
|
)
|