Skip to content

Commit 73b670b

Browse files
committed
Skip error tests on time-skipping server
1 parent 657c188 commit 73b670b

File tree

1 file changed

+24
-4
lines changed

1 file changed

+24
-4
lines changed

tests/worker/test_workflow.py

Lines changed: 24 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -8644,7 +8644,12 @@ async def test_large_payload_workflow_payload_error_disabled(client: Client):
86448644
)
86458645

86468646

8647-
async def test_large_payload_workflow_result_error(client: Client):
8647+
async def test_large_payload_workflow_result_error(
8648+
client: Client, env: WorkflowEnvironment
8649+
):
8650+
if env.supports_time_skipping:
8651+
pytest.skip("Time-skipping server does not report payload limits.")
8652+
86488653
# Create worker runtime with forwarded logger
86498654
worker_logger = logging.getLogger(f"log-{uuid.uuid4()}")
86508655
worker_runtime = Runtime(
@@ -8745,7 +8750,12 @@ async def test_large_payload_workflow_result_warning(client: Client):
87458750
)
87468751

87478752

8748-
async def test_large_payload_activity_input_error(client: Client):
8753+
async def test_large_payload_activity_input_error(
8754+
client: Client, env: WorkflowEnvironment
8755+
):
8756+
if env.supports_time_skipping:
8757+
pytest.skip("Time-skipping server does not report payload limits.")
8758+
87498759
# Create worker runtime with forwarded logger
87508760
worker_logger = logging.getLogger(f"log-{uuid.uuid4()}")
87518761
worker_runtime = Runtime(
@@ -8844,7 +8854,12 @@ async def test_large_payload_activity_input_warning(client: Client):
88448854
)
88458855

88468856

8847-
async def test_large_payload_activity_exception_error(client: Client):
8857+
async def test_large_payload_activity_exception_error(
8858+
client: Client, env: WorkflowEnvironment
8859+
):
8860+
if env.supports_time_skipping:
8861+
pytest.skip("Time-skipping server does not report payload limits.")
8862+
88488863
# Create worker runtime with forwarded logger
88498864
worker_logger = logging.getLogger(f"log-{uuid.uuid4()}")
88508865
worker_runtime = Runtime(
@@ -8898,7 +8913,12 @@ def activity_logger_predicate(record: logging.LogRecord) -> bool:
88988913
assert activity_logger_capturer.find(activity_logger_predicate)
88998914

89008915

8901-
async def test_large_payload_activity_result_error(client: Client):
8916+
async def test_large_payload_activity_result_error(
8917+
client: Client, env: WorkflowEnvironment
8918+
):
8919+
if env.supports_time_skipping:
8920+
pytest.skip("Time-skipping server does not report payload limits.")
8921+
89028922
# Create worker runtime with forwarded logger
89038923
worker_logger = logging.getLogger(f"log-{uuid.uuid4()}")
89048924
worker_runtime = Runtime(

0 commit comments

Comments
 (0)