@@ -611,7 +611,12 @@ async def some_activity(param1: SomeClass2, param2: str) -> str:
611
611
assert activity_param1 == SomeClass2 (foo = "str1" , bar = SomeClass1 (foo = 123 ))
612
612
613
613
614
- async def test_activity_heartbeat_details (client : Client , worker : ExternalWorker ):
614
+ async def test_activity_heartbeat_details (
615
+ client : Client , worker : ExternalWorker , env : WorkflowEnvironment
616
+ ):
617
+ if env .supports_time_skipping :
618
+ pytest .skip ("https://github.com/temporalio/sdk-java/issues/2459" )
619
+
615
620
@activity .defn
616
621
async def some_activity () -> str :
617
622
info = activity .info ()
@@ -698,8 +703,11 @@ def picklable_heartbeat_details_activity() -> str:
698
703
699
704
700
705
async def test_sync_activity_thread_heartbeat_details (
701
- client : Client , worker : ExternalWorker
706
+ client : Client , worker : ExternalWorker , env : WorkflowEnvironment
702
707
):
708
+ if env .supports_time_skipping :
709
+ pytest .skip ("https://github.com/temporalio/sdk-java/issues/2459" )
710
+
703
711
with concurrent .futures .ThreadPoolExecutor (
704
712
max_workers = default_max_concurrent_activities
705
713
) as executor :
@@ -714,8 +722,11 @@ async def test_sync_activity_thread_heartbeat_details(
714
722
715
723
716
724
async def test_sync_activity_process_heartbeat_details (
717
- client : Client , worker : ExternalWorker
725
+ client : Client , worker : ExternalWorker , env : WorkflowEnvironment
718
726
):
727
+ if env .supports_time_skipping :
728
+ pytest .skip ("https://github.com/temporalio/sdk-java/issues/2459" )
729
+
719
730
with concurrent .futures .ProcessPoolExecutor () as executor :
720
731
result = await _execute_workflow_with_activity (
721
732
client ,
@@ -1066,8 +1077,11 @@ async def test_activity_async_success(
1066
1077
1067
1078
@pytest .mark .parametrize ("use_task_token" , [True , False ])
1068
1079
async def test_activity_async_heartbeat_and_fail (
1069
- client : Client , worker : ExternalWorker , use_task_token : bool
1080
+ client : Client , worker : ExternalWorker , env : WorkflowEnvironment
1070
1081
):
1082
+ if env .supports_time_skipping :
1083
+ pytest .skip ("https://github.com/temporalio/sdk-java/issues/2459" )
1084
+
1071
1085
wrapper = AsyncActivityWrapper ()
1072
1086
# Start task w/ max attempts 2, wait for info, send heartbeat, fail
1073
1087
task = asyncio .create_task (
0 commit comments