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",
}

print("BEFORE_LOADER_IMPORT_REGISTERED=", len(celery_app.tasks))

# This is the actual Celery loader path used to load configured imports.
celery_app.loader.import_default_modules()

registered = set(celery_app.tasks)

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

missing = sorted(expected - registered)

for task in sorted(expected):
    if task in registered:
        print("PASS:", task)
    else:
        print("FAIL:", task)

if missing:
    print("MISSING=", missing)
    raise SystemExit(1)

print("SL-002 FINAL CELERY RUNTIME VERIFICATION=PASS")