feat(mma_exec): integrate NativeOrchestrator for track metadata operations
This commit is contained in:
@@ -10,6 +10,30 @@ import datetime
|
|||||||
|
|
||||||
LOG_FILE: str = 'logs/errors/mma_delegation.log'
|
LOG_FILE: str = 'logs/errors/mma_delegation.log'
|
||||||
|
|
||||||
|
try:
|
||||||
|
from src import native_orchestrator
|
||||||
|
_NATIVE_ORCH_AVAILABLE = True
|
||||||
|
except ImportError:
|
||||||
|
_NATIVE_ORCH_AVAILABLE = False
|
||||||
|
|
||||||
|
def load_track_metadata(track_id: str, base_dir: str = ".") -> dict:
|
||||||
|
if _NATIVE_ORCH_AVAILABLE:
|
||||||
|
return native_orchestrator.read_metadata(track_id, base_dir)
|
||||||
|
return {}
|
||||||
|
|
||||||
|
def save_track_metadata(track_id: str, data: dict, base_dir: str = ".") -> None:
|
||||||
|
if _NATIVE_ORCH_AVAILABLE:
|
||||||
|
native_orchestrator.write_metadata(track_id, data, base_dir)
|
||||||
|
|
||||||
|
def load_track_plan(track_id: str, base_dir: str = ".") -> str:
|
||||||
|
if _NATIVE_ORCH_AVAILABLE:
|
||||||
|
return native_orchestrator.read_plan(track_id, base_dir)
|
||||||
|
return ""
|
||||||
|
|
||||||
|
def save_track_plan(track_id: str, content: str, base_dir: str = ".") -> None:
|
||||||
|
if _NATIVE_ORCH_AVAILABLE:
|
||||||
|
native_orchestrator.write_plan(track_id, content, base_dir)
|
||||||
|
|
||||||
|
|
||||||
def generate_skeleton(code: str) -> str:
|
def generate_skeleton(code: str) -> str:
|
||||||
"""
|
"""
|
||||||
|
|||||||
Reference in New Issue
Block a user