fix: fix formatting + deploy-examples

Author: hsilan

.github/workflows/deploy-examples.yml

@@ -101,7 +101,6 @@ jobs:
         echo "QUALIFIED_FUNCTION_NAME=$QUALIFIED_FUNCTION_NAME" >> $GITHUB_OUTPUT
 
     - name: Run Integration Tests - ${{ matrix.example.name }}
-      working-directory: ./packages/aws-durable-execution-sdk-python
       env:
         AWS_REGION: ${{ env.AWS_REGION }}
         LAMBDA_ENDPOINT: "https://lambda.us-west-2.amazonaws.com"
@@ -118,7 +117,7 @@ jobs:
         TEST_NAME="test_$(echo "${{ matrix.example.name }}" | tr '[:upper:]' '[:lower:]' | tr ' ' '_')"
         echo "Test name: ${TEST_NAME}"
         
-        # Run integration tests
+        # Run integration tests from repo root
         hatch run test:examples-integration
 
         # Wait for function to be ready

packages/aws-durable-execution-sdk-python/tests/operation/map_test.py

@@ -1000,7 +1000,11 @@ def test_map_handler_serializes_batch_result():
             child_checkpoint.is_replay_children.return_value = False
 
             def get_checkpoint(op_id):
-                return child_checkpoint if op_id.startswith("child-") else parent_checkpoint
+                return (
+                    child_checkpoint
+                    if op_id.startswith("child-")
+                    else parent_checkpoint
+                )
 
             mock_state = Mock()
             mock_state.durable_execution_arn = "arn:test"
@@ -1054,7 +1058,11 @@ def test_map_default_serdes_serializes_batch_result():
             child_checkpoint.is_replay_children.return_value = False
 
             def get_checkpoint(op_id):
-                return child_checkpoint if op_id.startswith("child-") else parent_checkpoint
+                return (
+                    child_checkpoint
+                    if op_id.startswith("child-")
+                    else parent_checkpoint
+                )
 
             mock_state = Mock()
             mock_state.durable_execution_arn = "arn:test"
@@ -1096,7 +1104,9 @@ def test_map_custom_serdes_serializes_batch_result():
     custom_serdes = CustomStrSerDes()
 
     try:
-        with patch("aws_durable_execution_sdk_python.serdes.serialize") as mock_serialize:
+        with patch(
+            "aws_durable_execution_sdk_python.serdes.serialize"
+        ) as mock_serialize:
             mock_serialize.return_value = '"serialized"'
             importlib.reload(child)
 
@@ -1113,7 +1123,11 @@ def test_map_custom_serdes_serializes_batch_result():
             child_checkpoint.is_replay_children.return_value = False
 
             def get_checkpoint(op_id):
-                return child_checkpoint if op_id.startswith("child-") else parent_checkpoint
+                return (
+                    child_checkpoint
+                    if op_id.startswith("child-")
+                    else parent_checkpoint
+                )
 
             mock_state = Mock()
             mock_state.durable_execution_arn = "arn:test"

packages/aws-durable-execution-sdk-python/tests/operation/parallel_test.py

@@ -976,7 +976,11 @@ def test_parallel_handler_serializes_batch_result():
             child_checkpoint.is_replay_children.return_value = False
 
             def get_checkpoint(op_id):
-                return child_checkpoint if op_id.startswith("child-") else parent_checkpoint
+                return (
+                    child_checkpoint
+                    if op_id.startswith("child-")
+                    else parent_checkpoint
+                )
 
             mock_state = Mock()
             mock_state.durable_execution_arn = "arn:test"
@@ -1030,7 +1034,11 @@ def test_parallel_default_serdes_serializes_batch_result():
             child_checkpoint.is_replay_children.return_value = False
 
             def get_checkpoint(op_id):
-                return child_checkpoint if op_id.startswith("child-") else parent_checkpoint
+                return (
+                    child_checkpoint
+                    if op_id.startswith("child-")
+                    else parent_checkpoint
+                )
 
             mock_state = Mock()
             mock_state.durable_execution_arn = "arn:test"
@@ -1072,7 +1080,9 @@ def test_parallel_custom_serdes_serializes_batch_result():
     custom_serdes = CustomStrSerDes()
 
     try:
-        with patch("aws_durable_execution_sdk_python.serdes.serialize") as mock_serialize:
+        with patch(
+            "aws_durable_execution_sdk_python.serdes.serialize"
+        ) as mock_serialize:
             mock_serialize.return_value = '"serialized"'
             importlib.reload(child)
 
@@ -1089,7 +1099,11 @@ def test_parallel_custom_serdes_serializes_batch_result():
             child_checkpoint.is_replay_children.return_value = False
 
             def get_checkpoint(op_id):
-                return child_checkpoint if op_id.startswith("child-") else parent_checkpoint
+                return (
+                    child_checkpoint
+                    if op_id.startswith("child-")
+                    else parent_checkpoint
+                )
 
             mock_state = Mock()
             mock_state.durable_execution_arn = "arn:test"

pyproject.toml

@@ -19,6 +19,7 @@ dependencies = [
 [tool.hatch.envs.test.scripts]
 all = "pytest {args}"
 cov = "pytest --cov-report=term-missing --cov {args}"
+examples-integration = "pytest --runner-mode=cloud -m example packages/examples/test/ -v {args}"
 
 [tool.pytest.ini_options]
 addopts = "--import-mode=importlib"