from temporalio.testing import WorkflowEnvironment
from temporalio.worker import Worker
-TASK_TIMEOUT = timedelta(seconds=0.5)
-EXECUTION_TIMEOUT = timedelta(seconds=1)
+# Prevent the tasks from running indefinitely
+TASK_TIMEOUT = timedelta(seconds=5)
+# Prevent the workflow from running indefinitely
+EXECUTION_TIMEOUT = timedelta(seconds=10)
class TestException(Exception):
]
)
class TestVimWorkflow(TestVimWorkflowsBase):
+ workflow_name: str
+
async def test_nominal_case_updates_vim_state_and_vim_op_state(self):
activities = [
mock_test_vim_connectivity,