.

models.py

@@ -77,7 +77,6 @@ class UserInfo(BaseModel):
     # JsonIgnore MonitorIPs in C#: we do not include it here
 
 
-
 class LLMServiceObj(BaseModel):
     # allow using field names or aliases
     model_config = ConfigDict(populate_by_name=True)
@@ -128,7 +127,8 @@ class LLMServiceObj(BaseModel):
     IsFunctionCallError: bool = False
     IsFunctionCallStatus: bool = False
     IsFunctionStillRunning: bool = False
-# ---------- ResultObj (from your C#) ----------
+
+
 class ResultObj(BaseModel):
     Message: str = ""
     Success: bool = False

rabbit_repo.py

@@ -22,18 +22,20 @@ class RabbitRepo(RabbitBase):
 
     async def publish(self, exchange: str, obj: Any, routing_key: str = ""):
         ex = await self.ensure_exchange(exchange)
+        # rabbit_repo.py
         evt = CloudEvent.wrap(
             event_id=str(uuid.uuid4()),
             event_type=(obj.__class__.__name__ if obj is not None else "NullOrEmpty"),
             source=self._source,
-            data=obj if not hasattr(obj, "model_dump") else obj.model_dump(),
-        )
+            data=obj if not hasattr(obj, "model_dump") else obj.model_dump(by_alias=True),
+)
         body = evt.model_dump_json(exclude_none=True).encode("utf-8")
+
         await ex.publish(aio_pika.Message(body=body), routing_key=routing_key)
 
     async def publish_jsonz(self, exchange: str, obj: Any, routing_key: str = "", with_id: Optional[str] = None) -> str:
         ex = await self.ensure_exchange(exchange)
-        datajson = to_json(obj if not hasattr(obj, "model_dump") else obj.model_dump())
+        datajson = to_json(obj if not hasattr(obj, "model_dump") else obj.model_dump(by_alias=True))
         datajsonZ = json_compress_str(datajson)
         payload: Any = (datajsonZ, with_id) if with_id else datajsonZ
 

service.py

@@ -115,7 +115,7 @@ class LLMService:
                     pass
 
             # Create runner from factory (pass a plain dict for decoupling)
-            runner = await self._runner_factory(llm.model_dump())
+            runner = await self._runner_factory(llm.model_dump(by_alias=True))
             if not runner.IsEnabled:
                 await self._emit_result(
                     llm,
@@ -129,7 +129,7 @@ class LLMService:
                 llm, f"Starting {runner.Type} {settings.SERVICE_ID} Expert", True, "llmServiceMessage", check_system=True
             )
 
-            await runner.StartProcess(llm.model_dump())
+            await await runner.StartProcess(llm.model_dump(by_alias=True))
 
             self._sessions[session_id] = _Session(Runner=runner, FullSessionId=session_id)
 
@@ -214,7 +214,7 @@ class LLMService:
             return
 
         # Let runner push partials itself if desired; we still return a small ack
-        await r.SendInputAndGetResponse(llm.model_dump())
+        await r.SendInputAndGetResponse(llm.model_dump(by_alias=True))
 
     async def QueryIndexResult(self, payload: Any) -> None:
         """