src/core/pipeline/step.py

from observability import logger as obs_logger
from observability import components as obs_components

class PipelineStep:
    name = "pipeline_step"

    async def execute(self, context):
        with obs_logger.start_span(self.name, obs_components.ORCHESTRATOR):
            await self.run(context)

    async def run(self, context):
        raise NotImplementedError