18 lines
534 B
Python
18 lines
534 B
Python
from taskiq import TaskiqScheduler
|
|
from taskiq.schedule_sources import LabelScheduleSource
|
|
from taskiq_redis import RedisAsyncResultBackend, RedisStreamBroker
|
|
|
|
# taskiq_broker = AioPikaBroker(backend.config.RABBITMQ_URL)
|
|
result_backend = RedisAsyncResultBackend(
|
|
redis_url="redis://redis:6379",
|
|
result_ex_time=1000
|
|
)
|
|
taskiq_broker = RedisStreamBroker(
|
|
url="redis://redis:6379"
|
|
).with_result_backend(result_backend)
|
|
|
|
scheduler = TaskiqScheduler(
|
|
broker=taskiq_broker,
|
|
sources=[LabelScheduleSource(taskiq_broker)]
|
|
)
|