from datetime import timedelta
from osm_common.temporal.activities.lcm import UpdateNsLcmOperationState
-from osm_common.temporal.workflows.base import BaseWorkflow
from osm_common.temporal.states import LcmOperationState
+from osm_common.temporal.workflows.base import BaseWorkflow
from temporalio import workflow
from temporalio.common import RetryPolicy
from temporalio.exceptions import ActivityError, ChildWorkflowError
nslcmop: dict
- @abstractmethod
- async def wrap_nslcmop(self, workflow_input: Input) -> None:
- pass
-
@abstractmethod
async def run(self, workflow_input: Input) -> None:
pass