@@ -325,7 +325,7 @@ async def test_workflow_payload_conversion(
325325async def activity_with_heartbeat_details () -> TraceData :
326326 """Activity that checks heartbeat details are decoded with proper context."""
327327 info = activity .info ()
328-
328+
329329 # If we have heartbeat details, it means we're resuming from a previous attempt
330330 if info .heartbeat_details :
331331 # The heartbeat details should be a TraceData that was decoded with activity context
@@ -334,7 +334,7 @@ async def activity_with_heartbeat_details() -> TraceData:
334334 assert isinstance (heartbeat_data , TraceData )
335335 # Return the heartbeat data which should contain the decode trace
336336 return heartbeat_data
337-
337+
338338 # First attempt - heartbeat and then fail
339339 data = TraceData ()
340340 activity .heartbeat (data )
@@ -390,7 +390,7 @@ async def test_heartbeat_details_payload_conversion(client: Client):
390390 is_local = False ,
391391 )
392392 )
393-
393+
394394 # The result should contain the heartbeat data that was decoded with activity context
395395 # We expect to see the from_payload trace item for the heartbeat details
396396 # This test will FAIL until the bug is fixed
@@ -404,8 +404,10 @@ async def test_heartbeat_details_payload_conversion(client: Client):
404404 ):
405405 found_heartbeat_decode = True
406406 break
407-
408- assert found_heartbeat_decode , "Heartbeat details should be decoded with activity context"
407+
408+ assert (
409+ found_heartbeat_decode
410+ ), "Heartbeat details should be decoded with activity context"
409411
410412
411413# Async activity completion test
0 commit comments