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