Skip to content

Commit 6f1fb2d

Browse files
committed
fix(testing): preserve unscaled wait history
1 parent 8127b4b commit 6f1fb2d

2 files changed

Lines changed: 11 additions & 3 deletions

File tree

  • packages/aws-durable-execution-sdk-python-testing
    • src/aws_durable_execution_sdk_python_testing/checkpoint/processors
    • tests/checkpoint/processors

packages/aws-durable-execution-sdk-python-testing/src/aws_durable_execution_sdk_python_testing/checkpoint/processors/wait.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,7 @@ def process(
4545
scaled_wait_seconds = scale_delay(wait_seconds)
4646

4747
scheduled_end_timestamp = datetime.now(UTC) + timedelta(
48-
seconds=scaled_wait_seconds
48+
seconds=wait_seconds
4949
)
5050

5151
# Create WaitDetails with scheduled timestamp

packages/aws-durable-execution-sdk-python-testing/tests/checkpoint/processors/wait_test.py

Lines changed: 10 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
"""Tests for wait operation processor."""
22

3-
from datetime import UTC, datetime
3+
from datetime import UTC, datetime, timedelta
44
from unittest.mock import Mock
55

66
import pytest
@@ -86,9 +86,17 @@ def test_process_start_action_scales_wait_delay(monkeypatch):
8686
wait_options=WaitOptions(wait_seconds=30),
8787
)
8888

89-
processor.process(update, None, notifier, execution_arn)
89+
before_process = datetime.now(UTC)
90+
result = processor.process(update, None, notifier, execution_arn)
91+
after_process = datetime.now(UTC)
9092

9193
assert notifier.wait_timer_calls[0] == (execution_arn, "wait-123", 15)
94+
assert result.wait_details is not None
95+
assert (
96+
before_process + timedelta(seconds=30)
97+
<= result.wait_details.scheduled_end_timestamp
98+
<= after_process + timedelta(seconds=30)
99+
)
92100

93101

94102
def test_process_start_action_without_wait_options():

0 commit comments

Comments
 (0)