Skip to content

Commit 18b5d33

Browse files
Use PyPi dependency for durable functions integration tests (aws#8643)
* Reapply "chore: use pypi dependency for durable executions python SDK (aws#8608)" (aws#8633) This reverts commit d0effc7. * chore: update durable execution emulator binaries * fix: update wait for callback example --------- Co-authored-by: Roger Zhang <ruojiazh@amazon.com>
1 parent 60329e7 commit 18b5d33

6 files changed

Lines changed: 6 additions & 12 deletions

File tree

29.4 KB
Binary file not shown.
28.9 KB
Binary file not shown.

tests/integration/durable_integ_base.py

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -37,15 +37,6 @@ def parameterized_test_name(func, num, params):
3737
@classmethod
3838
def build_durable_functions(cls):
3939
"""Run sam build for durable functions."""
40-
# Set environment variable for SDK .whl file location
41-
whl_path = Path(
42-
cls.test_data_path,
43-
"durable",
44-
"functions",
45-
"aws_durable_execution_sdk_python-1.0.0-py3-none-any.whl",
46-
)
47-
os.environ["DURABLE_SDK_WHL"] = str(whl_path.absolute())
48-
4940
cls.build_dir = Path(cls.test_data_path, "durable", ".aws-sam", "build")
5041
cls.built_template_path = cls.build_dir / "template.yaml"
5142

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
${DURABLE_SDK_WHL}
1+
aws-durable-execution-sdk-python

tests/integration/testdata/durable/functions/wait_for_callback/wait_for_callback.py

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2,15 +2,18 @@
22
from typing import Any
33

44
from aws_durable_execution_sdk_python.config import WaitForCallbackConfig
5-
from aws_durable_execution_sdk_python.context import DurableContext
5+
from aws_durable_execution_sdk_python.context import (
6+
DurableContext,
7+
WaitForCallbackContext,
8+
)
69
from aws_durable_execution_sdk_python.execution import durable_execution
710
from aws_durable_execution_sdk_python.config import Duration
811

912
logger = logging.getLogger()
1013
logger.setLevel(logging.INFO)
1114

1215

13-
def external_system_call(callback_id: str) -> None:
16+
def external_system_call(callback_id: str, _context: WaitForCallbackContext) -> None:
1417
"""Simulate calling an external system with callback ID."""
1518
# In real usage, this would make an API call to an external system
1619
# passing the callback_id for the system to call back when done

0 commit comments

Comments
 (0)