move folders

Author: xzrderek

eval_protocol/types/remote_rollout_processor.py

@@ -31,6 +31,7 @@ class StatusResponse(BaseModel):
     """Response model for GET /status endpoint."""
 
     terminated: bool
+    info: Optional[Dict[str, Any]] = None
 
 
 def create_langfuse_config_tags(init_request: InitRequest) -> List[str]:

tests/chinook/langfuse/remote_server.py tests/remote_server/remote_server.pytests/chinook/langfuse/remote_server.py renamed to tests/remote_server/remote_server.py

@@ -19,18 +19,6 @@
 
 _STATE: Dict[str, Dict[str, Any]] = {}
 
-ALLOWED_MESSAGE_FIELDS = {"role", "content", "tool_calls", "tool_call_id", "name"}
-
-
-def _clean_messages_for_api(messages: List[Message]) -> list[dict]:
-    cleaned: list[dict] = []
-    for msg in messages:
-        msg_dict = msg.model_dump()
-        cm = {k: v for k, v in msg_dict.items() if k in ALLOWED_MESSAGE_FIELDS and v is not None}
-        # Some providers dislike empty content on assistant messages; keep if present
-        cleaned.append(cm)
-    return cleaned
-
 
 @app.post("/init")
 def init(req: InitRequest):
@@ -44,7 +32,7 @@ def _worker():
 
             completion_kwargs = {
                 "model": req.model,
-                "messages": _clean_messages_for_api(req.messages),
+                "messages": req.messages,
                 "metadata": metadata,
             }
 

…langfuse/test_remote_langfuse_chinook.py …ts/remote_server/test_remote_langfuse.pytests/chinook/langfuse/test_remote_langfuse_chinook.py renamed to tests/remote_server/test_remote_langfuse.py tests/chinook/langfuse/test_remote_langfuse_chinook.py renamed to tests/remote_server/test_remote_langfuse.py

@@ -1,7 +1,7 @@
 # MANUAL SERVER STARTUP REQUIRED:
 # Before running this test, start the remote server manually:
 # cd /Users/derekxu/Documents/code/python-sdk
-# python -m tests.chinook.langfuse.remote_server
+# python -m tests.remote_server.remote_server
 #
 # The server should be running on http://127.0.0.1:7077
 
@@ -64,7 +64,7 @@ def rows() -> List[EvaluationRow]:
 async def test_remote_rollout_and_fetch_langfuse(row: EvaluationRow) -> EvaluationRow:
     """
     End-to-end test:
-    - REQUIRES MANUAL SERVER STARTUP: python -m tests.chinook.langfuse.remote_server
+    - REQUIRES MANUAL SERVER STARTUP: python -m tests.remote_server.remote_server
     - trigger remote rollout via RemoteRolloutProcessor (calls init/status)
     - fetch traces from Langfuse filtered by metadata via output_data_loader; FAIL if none found
     """

…st_remote_langfuse_chinook_typescript.py …erver/test_remote_langfuse_typescript.pytests/chinook/langfuse/test_remote_langfuse_chinook_typescript.py renamed to tests/remote_server/test_remote_langfuse_typescript.py tests/chinook/langfuse/test_remote_langfuse_chinook_typescript.py renamed to tests/remote_server/test_remote_langfuse_typescript.py

@@ -1,6 +1,5 @@
 import os
 from typing import List
-import atexit
 
 import pytest
 

…ok/langfuse/typescript-server/.gitignore …mote_server/typescript-server/.gitignoretests/chinook/langfuse/typescript-server/.gitignore renamed to tests/remote_server/typescript-server/.gitignore tests/chinook/langfuse/typescript-server/.gitignore renamed to tests/remote_server/typescript-server/.gitignore

@@ -1,6 +1,6 @@
 import { NodeSDK } from "@opentelemetry/sdk-node";
 import { LangfuseSpanProcessor } from "@langfuse/otel";
-import "./env";
+import "./env.js";
 
 const sdk = new NodeSDK({
   spanProcessors: [