angee.work.tasks

Celery entrypoints for work-owned scheduled maintenance.

wake_due_snoozes

@shared_task(name="work.wake_due_snoozes")
def wake_due_snoozes(timestamp: int | None = None) -> int

Clear every task snooze whose inclusive wake instant has arrived.

generate_cycles

@shared_task(name="work.generate_cycles")
def generate_cycles(timestamp: int | None = None) -> int

Maintain generated cadence and close every cycle whose end day passed.