Skip to content

Commit 8257841

Browse files
committed
skip if time-skipping server (does not support pause/unpause yet)
1 parent e055766 commit 8257841

File tree

1 file changed

+10
-2
lines changed

1 file changed

+10
-2
lines changed

tests/worker/test_workflow.py

Lines changed: 10 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -7692,7 +7692,11 @@ async def run(
76927692
return result
76937693

76947694

7695-
async def test_activity_pause_cancellation_details(client: Client):
7695+
async def test_activity_pause_cancellation_details(client: Client, env: WorkflowEnvironment):
7696+
if env.supports_time_skipping:
7697+
pytest.skip(
7698+
"Time-skipping server does not support pause API yet"
7699+
)
76967700
with concurrent.futures.ThreadPoolExecutor() as executor:
76977701
async with Worker(
76987702
client,
@@ -7769,7 +7773,11 @@ async def run(
77697773
return results
77707774

77717775

7772-
async def test_activity_pause_unpause(client: Client):
7776+
async def test_activity_pause_unpause(client: Client, env: WorkflowEnvironment):
7777+
if env.supports_time_skipping:
7778+
pytest.skip(
7779+
"Time-skipping server does not support pause API yet"
7780+
)
77737781
with concurrent.futures.ThreadPoolExecutor() as executor:
77747782
async with Worker(
77757783
client,

0 commit comments

Comments
 (0)