diff --git a/tests/hello/hello_update_test.py b/tests/hello/hello_update_test.py index 2a079387..5bff37e5 100644 --- a/tests/hello/hello_update_test.py +++ b/tests/hello/hello_update_test.py @@ -1,18 +1,12 @@ import uuid -import pytest from temporalio.client import Client, WorkflowExecutionStatus -from temporalio.testing import WorkflowEnvironment from temporalio.worker import Worker from hello.hello_update import GreetingWorkflow -async def test_update_workflow(client: Client, env: WorkflowEnvironment): - if env.supports_time_skipping: - pytest.skip( - "Time-skipping test server currently has issue with update: https://github.com/temporalio/sdk-java/issues/1903" - ) +async def test_update_workflow(client: Client): task_queue_name = str(uuid.uuid4()) async with Worker(client, task_queue=task_queue_name, workflows=[GreetingWorkflow]): handle = await client.start_workflow( diff --git a/tests/message_passing/introduction/test_introduction_sample.py b/tests/message_passing/introduction/test_introduction_sample.py index de981dc2..c20d8963 100644 --- a/tests/message_passing/introduction/test_introduction_sample.py +++ b/tests/message_passing/introduction/test_introduction_sample.py @@ -2,7 +2,6 @@ import pytest from temporalio.client import Client, WorkflowUpdateFailedError -from temporalio.testing import WorkflowEnvironment from temporalio.worker import Worker from message_passing.introduction.starter import TASK_QUEUE @@ -14,11 +13,7 @@ ) -async def test_queries(client: Client, env: WorkflowEnvironment): - if env.supports_time_skipping: - pytest.skip( - "Java test server: https://github.com/temporalio/sdk-java/issues/1903" - ) +async def test_queries(client: Client): async with Worker( client, task_queue=TASK_QUEUE, @@ -46,11 +41,7 @@ async def test_queries(client: Client, env: WorkflowEnvironment): ] -async def test_set_language(client: Client, env: WorkflowEnvironment): - if env.supports_time_skipping: - pytest.skip( - "Java test server: https://github.com/temporalio/sdk-java/issues/1903" - ) +async def test_set_language(client: Client): async with Worker( client, task_queue=TASK_QUEUE, @@ -69,11 +60,7 @@ async def test_set_language(client: Client, env: WorkflowEnvironment): assert await wf_handle.query(GreetingWorkflow.get_language) == Language.CHINESE -async def test_set_invalid_language(client: Client, env: WorkflowEnvironment): - if env.supports_time_skipping: - pytest.skip( - "Java test server: https://github.com/temporalio/sdk-java/issues/1903" - ) +async def test_set_invalid_language(client: Client): async with Worker( client, task_queue=TASK_QUEUE, @@ -92,17 +79,11 @@ async def test_set_invalid_language(client: Client, env: WorkflowEnvironment): ) -async def test_set_language_that_is_only_available_via_remote_service( - client: Client, env: WorkflowEnvironment -): +async def test_set_language_that_is_only_available_via_remote_service(client: Client): """ Similar to test_set_invalid_language, but this time Arabic is available since we use the remote service. """ - if env.supports_time_skipping: - pytest.skip( - "Java test server: https://github.com/temporalio/sdk-java/issues/1903" - ) async with Worker( client, task_queue=TASK_QUEUE, diff --git a/tests/message_passing/safe_message_handlers/workflow_test.py b/tests/message_passing/safe_message_handlers/workflow_test.py index 92345be7..76c43c51 100644 --- a/tests/message_passing/safe_message_handlers/workflow_test.py +++ b/tests/message_passing/safe_message_handlers/workflow_test.py @@ -20,11 +20,7 @@ ) -async def test_safe_message_handlers(client: Client, env: WorkflowEnvironment): - if env.supports_time_skipping: - pytest.skip( - "Java test server: https://github.com/temporalio/sdk-java/issues/1903" - ) +async def test_safe_message_handlers(client: Client): task_queue = f"tq-{uuid.uuid4()}" async with Worker( client, @@ -72,11 +68,7 @@ async def test_safe_message_handlers(client: Client, env: WorkflowEnvironment): assert result.num_currently_assigned_nodes == 0 -async def test_update_idempotency(client: Client, env: WorkflowEnvironment): - if env.supports_time_skipping: - pytest.skip( - "Java test server: https://github.com/temporalio/sdk-java/issues/1903" - ) +async def test_update_idempotency(client: Client): task_queue = f"tq-{uuid.uuid4()}" async with Worker( client, @@ -111,11 +103,7 @@ async def test_update_idempotency(client: Client, env: WorkflowEnvironment): assert result_1.nodes_assigned >= result_2.nodes_assigned -async def test_update_failure(client: Client, env: WorkflowEnvironment): - if env.supports_time_skipping: - pytest.skip( - "Java test server: https://github.com/temporalio/sdk-java/issues/1903" - ) +async def test_update_failure(client: Client): task_queue = f"tq-{uuid.uuid4()}" async with Worker( client,