from app.workers.celery_app import celery_app

expected = {
    "app.workers.discovery.daily_global_scan_task",
    "app.workers.ingest.ingest_security_task",
    "app.workers.ingest.ingest_universe_task",
    "app.workers.peer_groups.recompute_universe_task",
    "app.workers.recompute.recompute_security_task",
    "app.workers.token_cleanup.prune_expired_revoked_tokens_task",
}

registered = set(celery_app.tasks)

print("registered_tasks=", len(registered))

missing = sorted(expected - registered)

if missing:
    print("MISSING TASKS:")
    for task in missing:
        print(task)
    raise SystemExit(1)

for task in sorted(expected):
    print("PASS:", task)

print("SL-002 CELERY REGISTRY PASS")