marius/Open_Ultra_SAST
1
0
Fork 0
mirror of https://github.com/norandom/OpenUltraSAST.git synced 2026-10-16 11:49:28 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(plane): runner drops the fields ax's server sets before validating

Browse Source 
On the live cluster ax hands AX_TASK_YAML with metadata.creationTimestamp and a
status block; the strict authoring schema rejected it, readiness never turned
green and every resume timed out. Other unknown fields still fail. up.sh retries
the first resume while the golden snapshot builds.

Co-Authored-By: Claude Opus 5.5 <[email protected]>
Claude-Session: https://claude.ai/code/session_01EmM1j46qgKMh3zqD1QMwEo
This commit is contained in:
Marius Ciepluch
2026-09-29 19:17:19 +02:00
co-authored by Claude Opus 5.5
parent 8e6485e577
commit 2e7e0550b2
3 changed files with 37 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/openultrasast/plane/runner.py
+17 -2
View File
@@ -119,6 +119,21 @@ class DeliveryError(RuntimeError):
# --- manifests ---------------------------------------------------------------------------------------------------
# Fields ax's API server sets on what it hands the runner (ax.proto: ObjectMeta.creation_timestamp, Task.status).
# They are not authoring fields, so they are dropped before the strict schema sees the document; any other
# unknown field still fails.
_SERVER_META = ("creationTimestamp", "creation_timestamp")
def _without_server_fields(document: object) -> object:
if not isinstance(document, dict):
return document
cleaned = {k: v for k, v in document.items() if k != "status"}
meta = cleaned.get("metadata")
if isinstance(meta, dict):
cleaned["metadata"] = {k: v for k, v in meta.items() if k not in _SERVER_META}
return cleaned
def load_task(text: str) -> Task:
"""Parse ``AX_TASK_YAML``; raise :class:`RunnerError` unless it is exactly one Task."""
@@ -129,7 +144,7 @@ def load_task(text: str) -> Task:
if len(documents) != 1:
raise RunnerError(f"AX_TASK_YAML must hold exactly one Task document, found {len(documents)}")
try:
manifest = parse_manifest(documents[0], source="AX_TASK_YAML")
manifest = parse_manifest(_without_server_fields(documents[0]), source="AX_TASK_YAML")
except ManifestError as exc:
raise RunnerError(str(exc)) from exc
if not isinstance(manifest, Task):
@@ -146,7 +161,7 @@ def load_workspaces(text: str) -> dict[str, Workspace]:
workspaces: dict[str, Workspace] = {}
for index, document in enumerate(documents):
try:
manifest = parse_manifest(document, source=f"AX_WORKSPACES_YAML[{index}]")
manifest = parse_manifest(_without_server_fields(document), source=f"AX_WORKSPACES_YAML[{index}]")
except ManifestError as exc:
raise RunnerError(str(exc)) from exc
if not isinstance(manifest, Workspace):