from app.application.delivery.subscriptions import run_subscription_cycle
from app.core.constants import ActorValue
from app.tasks.app import celery_app
from app.tasks.constants import TASK_RUN_SUBSCRIPTION_CYCLE


@celery_app.task(name=TASK_RUN_SUBSCRIPTION_CYCLE)
def run_subscription_cycle_task(
    actor: str = ActorValue.SCHEDULER,
) -> dict:
    return run_subscription_cycle(actor=actor)