Spaces:
Runtime error
Runtime error
| from core.pipeline.step import PipelineStep | |
| class StructureStep(PipelineStep): | |
| name = "structure_service" | |
| def __init__(self, structure_service): | |
| self.service = structure_service | |
| async def run(self, context): | |
| if self.service: | |
| from domain.training.run import Run | |
| for run_item in context.runs: | |
| run_obj = run_item | |
| if isinstance(run_item, dict): | |
| # Convert to Run entity for service compatibility | |
| run_obj = Run(**run_item) | |
| self.service.process_run_for_structure(run_obj, context.runner_profile.runner_id) | |