File tree Expand file tree Collapse file tree 1 file changed +1
-6
lines changed
src/aws_durable_execution_sdk_python_testing Expand file tree Collapse file tree 1 file changed +1
-6
lines changed Original file line number Diff line number Diff line change @@ -500,15 +500,13 @@ def checkpoint_execution(
500500 msg : str = f"Invalid checkpoint token: { checkpoint_token } "
501501 raise InvalidParameterValueException (msg )
502502
503- # Process operation updates using the checkpoint processor
504503 if updates :
505504 checkpoint_output = self ._checkpoint_processor .process_checkpoint (
506505 checkpoint_token = checkpoint_token ,
507506 updates = updates ,
508507 client_token = client_token ,
509508 )
510509
511- # Convert SDK CheckpointUpdatedExecutionState to testing library version
512510 new_execution_state = None
513511 if checkpoint_output .new_execution_state :
514512 new_execution_state = CheckpointUpdatedExecutionState (
@@ -521,11 +519,8 @@ def checkpoint_execution(
521519 new_execution_state = new_execution_state ,
522520 )
523521
524- # Generate new checkpoint token for case with no updates
525- new_checkpoint_token = execution .get_new_checkpoint_token ()
526-
527522 return CheckpointDurableExecutionResponse (
528- checkpoint_token = new_checkpoint_token ,
523+ checkpoint_token = execution . get_new_checkpoint_token () ,
529524 new_execution_state = None ,
530525 )
531526
You can’t perform that action at this time.
0 commit comments