cf21ba4516
Phase 1 (Foundation): - Project restructure (presenton-main → backend/ + frontend/) - Database schema (8 new models, Alembic config, seed script) - Auth (Azure AD SSO + dev bypass, JWT sessions, AuthMiddleware) - RBAC (access_service, rbac_middleware, admin routers) - Audit logging (fire-and-forget, AuditMiddleware, admin router) - i18n (react-i18next with 5 namespace files) Phase 2 (Admin Panel & Client Management): - Admin panel shell (sidebar layout, role guard, 12 pages) - Redux admin slice with 18 async thunks - User management (role changes, deactivation) - Client management (CRUD, brand config, team management) - Brand config editor (colors, fonts, logos, voice rules) - Master deck upload & parser (PPTX → HTML → React pipeline) - Audit log viewer with filters and CSV/JSON export Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
35 lines
867 B
Python
35 lines
867 B
Python
import asyncio
|
|
from asyncio import Task
|
|
from typing import Any, Callable, Coroutine, Optional
|
|
|
|
|
|
class ConcurrentService:
|
|
def __init__(self):
|
|
self._background_tasks = set[Task]()
|
|
|
|
def run_task(
|
|
self,
|
|
delay: Optional[int],
|
|
callable: Callable[..., Coroutine[Any, Any, Any]],
|
|
*args,
|
|
**kwargs,
|
|
):
|
|
async def wrapper():
|
|
if delay:
|
|
await asyncio.sleep(delay)
|
|
await callable(*args, **kwargs)
|
|
|
|
task = asyncio.create_task(wrapper())
|
|
|
|
print(f"Running task: {task} - executing {callable.__name__}")
|
|
|
|
self._background_tasks.add(task)
|
|
task.add_done_callback(self.on_task_done)
|
|
|
|
def on_task_done(self, task: Task):
|
|
print(f"Task done: {task}")
|
|
|
|
self._background_tasks.discard(task)
|
|
|
|
|
|
CONCURRENT_SERVICE = ConcurrentService()
|