1313
1414STANDALONE_ACTIVITY_MATCHING_TASKS_IMPLEMENTED = False
1515
16+ pytest .skip ("Standalone activity is not implemented in server" , allow_module_level = True )
17+
1618
1719@activity .defn
1820async def increment (input : int ) -> int :
1921 return input + 1
2022
2123
22- @pytest .mark .skip ("StartActivityExecution not implemented in server" )
2324async def test_start_activity_and_describe_activity (client : Client ):
2425 activity_id = str (uuid .uuid4 ())
2526 task_queue = str (uuid .uuid4 ())
@@ -40,7 +41,6 @@ async def test_start_activity_and_describe_activity(client: Client):
4041 assert desc .status == ActivityExecutionStatus .RUNNING
4142
4243
43- @pytest .mark .skip ("GetActivityExecutionResult not implemented in server" )
4444async def test_start_activity_and_get_result (client : Client ):
4545 activity_id = str (uuid .uuid4 ())
4646 task_queue = str (uuid .uuid4 ())
@@ -85,7 +85,6 @@ async def async_activity(input: ActivityInput) -> int:
8585 activity .raise_complete_async ()
8686
8787
88- @pytest .mark .skip ("StartActivityExecution not implemented in server" )
8988async def test_manual_completion (client : Client ):
9089 activity_id = str (uuid .uuid4 ())
9190 task_queue = str (uuid .uuid4 ())
@@ -123,9 +122,6 @@ async def test_manual_completion(client: Client):
123122 assert await activity_handle .result () == 7
124123
125124
126- @pytest .mark .skip (
127- "RespondActivityTaskCanceled not implemented in server for standalone activity"
128- )
129125async def test_manual_cancellation (client : Client ):
130126 activity_id = str (uuid .uuid4 ())
131127 task_queue = str (uuid .uuid4 ())
@@ -166,9 +162,6 @@ async def test_manual_cancellation(client: Client):
166162 assert str (err .value .cause ) == "Test cancellation"
167163
168164
169- @pytest .mark .skip (
170- "RespondActivityTaskFailed not implemented in server for standalone activity"
171- )
172165async def test_manual_fail (client : Client ):
173166 activity_id = str (uuid .uuid4 ())
174167 task_queue = str (uuid .uuid4 ())
@@ -228,9 +221,6 @@ async def activity_for_testing_heartbeat(input: ActivityInput) -> str:
228221 raise AssertionError (f"Unexpected attempt number: { info .attempt } " )
229222
230223
231- @pytest .mark .skip (
232- "RecordActivityTaskHeartbeat not implemented in server for standalone activity"
233- )
234224async def test_manual_heartbeat (client : Client ):
235225 activity_id = str (uuid .uuid4 ())
236226 task_queue = str (uuid .uuid4 ())
0 commit comments