"""No-op Temporal workflows for managed scouter/laborious namespaces in E2E.""" from typing import Any from temporalio import workflow @workflow.defn(name='scouter') class ScouterStub: @workflow.run async def run(self, _input_data: dict[str, Any]) -> None: return None @workflow.defn(name='pi_web_api_scouter') class PiWebApiScouterStub: @workflow.run async def run(self, _input_data: dict[str, Any]) -> None: return None @workflow.defn(name='predictions_batch') class PredictionsBatchStub: @workflow.run async def run(self, _input_data: dict[str, Any]) -> None: return None @workflow.defn(name='xgboost_predictions_batch') class XgboostPredictionsBatchStub: @workflow.run async def run(self, _input_data: dict[str, Any]) -> None: return None @workflow.defn(name='drift') class DriftStub: @workflow.run async def run(self, _input_data: dict[str, Any]) -> None: return None @workflow.defn(name='simple_metrics') class SimpleMetricsStub: @workflow.run async def run(self, _input_data: dict[str, Any]) -> None: return None @workflow.defn(name='minimal_retrain') class MinimalRetrainStub: @workflow.run async def run(self, _input_data: dict[str, Any]) -> None: return None @workflow.defn(name='xgboost_minimal_retrain') class XgboostMinimalRetrainStub: @workflow.run async def run(self, _input_data: dict[str, Any]) -> None: return None STUB_WORKFLOW_CLASSES = [ ScouterStub, PiWebApiScouterStub, PredictionsBatchStub, XgboostPredictionsBatchStub, DriftStub, SimpleMetricsStub, MinimalRetrainStub, XgboostMinimalRetrainStub, ]