sync: 142 file da Baida98/AI@ab42bd1e (2026-08-08 08:23 UTC) [deploy-all]

api/agent.py

@@ -522,12 +522,12 @@ async def agent_kernel_dispatch(body: AgentKernelDispatchIn, role: AuthRole = De
                 'goal':    goal,
                 'mode':    mode,
                 'dispatch_id': _dispatch_id,
+                'metadata': {'workflow': 'agent-kernel.yml'},
             },
             priority='HIGH',
-            metadata={'workflow': 'agent-kernel.yml'},
         )).add_done_callback(_log_task_exc)
         asyncio.create_task(_kernel.publish_event(
-            event_type='agent.kernel.dispatched',
+            topic='agent.kernel.dispatched',
             payload={'goal': goal[:200], 'mode': mode},
         )).add_done_callback(_log_task_exc)
     import httpx as _httpx
@@ -579,10 +579,10 @@ async def _create_task_internal(task_id: str, goal: str, job: dict) -> dict:
                 "goal":      goal,
                 "max_steps": job.get("max_steps", 20),
                 "source":    "job_queue",
+                "metadata": {"job_queue": True},
             },
             priority="NORMAL",
             session_id=job.get("session_id", ""),
-            metadata={"job_queue": True},
         )).add_done_callback(_log_task_exc)
     return {"taskId": task_id, "status": "QUEUED"}
 
@@ -649,13 +649,13 @@ async def create_agent_task(body: AgentTaskIn, role: AuthRole = Depends(require_
                 'max_steps': body.max_steps,
                 'persona':   body.persona,
                 'source':    'agent_api',
+                'metadata': {'agent_api': True},
             },
             priority='NORMAL',
             session_id=body.session_id,
-            metadata={'agent_api': True},
         )).add_done_callback(_log_task_exc)
         asyncio.create_task(_kernel.publish_event(
-            event_type='task.created',
+            topic='task.created',
             payload={'task_id': task_id, 'goal': body.goal[:200], 'status': 'QUEUED'},
         )).add_done_callback(_log_task_exc)
     return {'taskId': task_id, 'status': 'QUEUED'}
@@ -939,7 +939,7 @@ async def stream_agent_task(task_id: str, request: Request, resume: int = 0, rol
         # ARCH-K2.2: pubblica lifecycle event via Kernel
         if _KERNEL_AVAILABLE and _kernel is not None:
             asyncio.create_task(_kernel.publish_event(
-                event_type='task.running',
+                topic='task.running',
                 payload={'task_id': task_id, 'status': 'RUNNING'},
             )).add_done_callback(_log_task_exc)
         _prune_agent_tasks()
@@ -1286,7 +1286,7 @@ async def stream_agent_task(task_id: str, request: Request, resume: int = 0, rol
                 # ARCH-K2.2: pubblica lifecycle event via Kernel
                 if _KERNEL_AVAILABLE and _kernel is not None:
                     asyncio.create_task(_kernel.publish_event(
-                        event_type='task.completed',
+                        topic='task.completed',
                         payload={'task_id': task_id, 'status': 'SUCCESS'},
                     )).add_done_callback(_log_task_exc)
                 _result_text = str(result.get('output', result) if isinstance(result, dict) else result)
@@ -1309,7 +1309,7 @@ async def stream_agent_task(task_id: str, request: Request, resume: int = 0, rol
                 # ARCH-K2.2: pubblica lifecycle event via Kernel
                 if _KERNEL_AVAILABLE and _kernel is not None:
                     asyncio.create_task(_kernel.publish_event(
-                        event_type='task.cancelled',
+                        topic='task.cancelled',
                         payload={'task_id': task_id, 'status': 'CANCELLED'},
                     )).add_done_callback(_log_task_exc)
                 _sse('task_cancelled', {'taskId': task_id})
@@ -1330,7 +1330,7 @@ async def stream_agent_task(task_id: str, request: Request, resume: int = 0, rol
                 # ARCH-K2.2: pubblica lifecycle event via Kernel
                 if _KERNEL_AVAILABLE and _kernel is not None:
                     asyncio.create_task(_kernel.publish_event(
-                        event_type='task.failed',
+                        topic='task.failed',
                         payload={'task_id': task_id, 'status': 'ERROR', 'error': str(err)[:500]},
                     )).add_done_callback(_log_task_exc)
                 _logger.error('[agent/stream] %s error: %s', task_id, err, exc_info=True)