taskiq in process

[theobouwman]

Hi,

It states in the docs that you should run "taskiq scheduler module:scheduler" separately like taskiq scheduler module:scheduler.

This is what we do in our worker service:

#
# DI container
#
container, broker = make_container()

app = AsgiFastStream(
    broker,
    asgi_routes=[
        ("/health", make_ping_asgi(broker, timeout=10.0)),
    ]
)

taskiq_broker = AppWrapper(app)

scheduler = StreamScheduler(
    broker=taskiq_broker,
    sources=[LabelScheduleSource(taskiq_broker)],
)

#
# cron tasks
#
taskiq_broker.task(
    list="scheduled.task.every_minute_fetch_discover_fill_cache",
    schedule=[{
        "cron": "* * * * *",
    }],
)

@broker.subscriber(
    list="scheduled.task.every_minute_fetch_discover_fill_cache",
)
@inject
async def task_every_minute_fetch_discover_fill_cache(
    redis_service: Annotated[RedisService, FromDishka()]
):
    try:
        # await discover_service.get_discover(use_cache=False)
        # await discover_service.get_discover_stories(use_cache=False)
        # await discover_service.get_discover_feed(use_cache=False)
        await redis_service.publish(list='cache.discover.refresh')
    except Exception as e:
        sentry_sdk.capture_exception(e)
        raise e

And in our container we do this CMD uvicorn worker.app:app --host 0.0.0.0 --port 9999 --loop uvloop

But what would be needed if we want to run the scheduler in this container as well?