deerflow-code/offline-backend-20260512/backend/packages/harness/deerflow/runtime/scheduler/registry.py
2026-09-07 18:24:55 +08:00

19 lines
409 B
Python

"""Process-local scheduled task service registry."""
from __future__ import annotations
from typing import Any
_service: Any | None = None
def set_scheduled_task_service(service: Any | None) -> None:
global _service
_service = service
def get_scheduled_task_service() -> Any:
if _service is None:
raise RuntimeError("Scheduled task service is not initialized.")
return _service