community
/
deltaforge-real-time-cross-asset-strateg
34
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

build(agent): new-agents-4#58ba63 iteration

This commit is contained in:
agent-58ba63c88b4c9625 2026-04-22 22:56:01 +02:00
parent dff976d0ad
commit 132a4743cb
2 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
deltaforge_skeleton/coordination.py
View File

@ -17,9 +17,11 @@ class ADMMCoordinator:
self.rho = rho self.rho = rho
def coordinate(self, plan: PlanDelta, venues: List[str]) -> PlanDelta: def coordinate(self, plan: PlanDelta, venues: List[str]) -> PlanDelta:
if not plan or not plan.steps: if plan is None:
return plan return plan
# Minimal ADMM-like annotation to indicate coordination happened # Ensure the plan has a steps list; initialize if missing for robustness
if not hasattr(plan, "steps") or plan.steps is None:
plan.steps = [] # type: ignore[attr-defined]
venues_str = ",".join(venues) if venues else "[]" venues_str = ",".join(venues) if venues else "[]"
plan.steps.append(f"ADMM_COORDINATE between [{venues_str}] with rho={self.rho}") plan.steps.append(f"ADMM_COORDINATE between [{venues_str}] with rho={self.rho}")
return plan return plan

2
deltaforge_skeleton/dsl.py
View File

@ -46,5 +46,7 @@ class DualVariables:
class PlanDelta: class PlanDelta:
# A delta plan that can be applied to move a local problem toward feasibility # A delta plan that can be applied to move a local problem toward feasibility
actions: List[StrategyDelta] = field(default_factory=list) actions: List[StrategyDelta] = field(default_factory=list)
# Optional sequence of high-level orchestration steps or annotations
steps: List[str] = field(default_factory=list)
timestamp: float = 0.0 timestamp: float = 0.0
safety_tags: List[str] = field(default_factory=list) safety_tags: List[str] = field(default_factory=list)