| import asyncio | |
| from typing import Callable, Any, Dict | |
| from app.core.config import settings | |
| class JobRunner: | |
| def __init__(self): | |
| self.is_hf_mode = settings.HF_SINGLE_PROCESS_MODE | |
| async def run_task(self, func: Callable, *args, **kwargs): | |
| if self.is_hf_mode: | |
| # In-process async task | |
| return asyncio.create_task(func(*args, **kwargs)) | |
| else: | |
| # Celery mode (stub) | |
| # In real production, this would call .delay() | |
| print(f"Queueing task to Celery: {func.__name__}") | |
| return None | |
| job_runner = JobRunner() | |