Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion .github/workflows/ci.yml
Original file line number Diff line number Diff line change
Expand Up @@ -42,7 +42,7 @@ jobs:
python-version: ${{ matrix.python-version }}
- name: Install Hatch
run: |
python -m pip install hatch==1.15.0
python -m pip install hatch==1.16.5
- name: static analysis
run: hatch fmt --check
- name: type checking
Expand Down
4 changes: 2 additions & 2 deletions .github/workflows/integration-tests.yml
Original file line number Diff line number Diff line change
Expand Up @@ -42,7 +42,7 @@ jobs:
python-version: ${{ matrix.python-version }}

- name: Install Hatch
run: python -m pip install hatch==1.15.0
run: python -m pip install hatch==1.16.5

- name: Setup and run Testing SDK
working-directory: testing-sdk
Expand Down Expand Up @@ -102,7 +102,7 @@ jobs:
env:
AWS_DURABLE_SDK_URL: file://${{ github.workspace }}/language-sdk
run: |
pip install hatch==1.15.0
pip install hatch==1.16.5
python -m pip install -e .

- name: Get integration examples
Expand Down
39 changes: 39 additions & 0 deletions .github/workflows/notify_slack.yml
Original file line number Diff line number Diff line change
@@ -0,0 +1,39 @@
name: Slack Notifications

on:
issues:
types: [opened, reopened, edited]
pull_request_target:
types: [opened, reopened, synchronize]

permissions: {}

jobs:
notify:
runs-on: ubuntu-latest
steps:
- name: Send issue notification to Slack
if: github.event_name == 'issues'
uses: slackapi/slack-github-action@v2.1.1
with:
webhook: ${{ secrets.SLACK_WEBHOOK_URL_ISSUE }}
webhook-type: incoming-webhook
payload: |
{
"action": "${{ github.event.action }}",
"issue_url": "${{ github.event.issue.html_url }}",
"package_name": "${{ github.repository }}"
}

- name: Send pull request notification to Slack
if: github.event_name == 'pull_request_target'
uses: slackapi/slack-github-action@v2.1.1
with:
webhook: ${{ secrets.SLACK_WEBHOOK_URL_PR }}
webhook-type: incoming-webhook
payload: |
{
"action": "${{ github.event.action }}",
"pr_url": "${{ github.event.pull_request.html_url }}",
"package_name": "${{ github.repository }}"
}
2 changes: 1 addition & 1 deletion .github/workflows/pypi-publish.yml
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@ jobs:
python-version: "3.11"
- name: Install Hatch
run: |
python -m pip install --upgrade hatch==1.15.0
python -m pip install --upgrade hatch==1.16.5
- name: Build release distributions
run: |
# NOTE: put your own distribution build steps here.
Expand Down
2 changes: 1 addition & 1 deletion .github/workflows/sync-package.yml
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@ jobs:
python-version: ${{ matrix.python-version }}
- name: Install Hatch
run: |
python -m pip install --upgrade hatch==1.15.0
python -m pip install --upgrade hatch==1.16.5
- name: Build distribution
run: hatch build
- name: configure aws credentials
Expand Down
2 changes: 1 addition & 1 deletion src/aws_durable_execution_sdk_python/context.py
Original file line number Diff line number Diff line change
Expand Up @@ -42,7 +42,7 @@
SerDes,
deserialize,
)
from aws_durable_execution_sdk_python.state import ExecutionState # noqa: TCH001
from aws_durable_execution_sdk_python.state import ExecutionState # noqa: TC001
from aws_durable_execution_sdk_python.threading import OrderedCounter
from aws_durable_execution_sdk_python.types import Callback as CallbackProtocol
from aws_durable_execution_sdk_python.types import (
Expand Down
6 changes: 3 additions & 3 deletions src/aws_durable_execution_sdk_python/lambda_service.py
Original file line number Diff line number Diff line change
Expand Up @@ -1079,12 +1079,12 @@ def checkpoint(
self.client.checkpoint_durable_execution(
DurableExecutionArn=durable_execution_arn,
CheckpointToken=checkpoint_token,
Updates=cast(Any, [o.to_dict() for o in updates]),
Updates=cast("Any", [o.to_dict() for o in updates]),
**optional_params, # type: ignore[arg-type]
)
)

return CheckpointOutput.from_dict(cast(MutableMapping[str, Any], result))
return CheckpointOutput.from_dict(cast("MutableMapping[str, Any]", result))
except Exception as e:
checkpoint_error = CheckpointError.from_exception(e)
logger.exception(
Expand All @@ -1108,7 +1108,7 @@ def get_execution_state(
MaxItems=max_items,
)
)
return StateOutput.from_dict(cast(MutableMapping[str, Any], result))
return StateOutput.from_dict(cast("MutableMapping[str, Any]", result))
except Exception as e:
error = GetExecutionStateError.from_exception(e)
logger.exception(
Expand Down
2 changes: 1 addition & 1 deletion tests/operation/child_test.py
Original file line number Diff line number Diff line change
Expand Up @@ -502,7 +502,7 @@ def my_summary(result: str) -> str:
return "summary"

child_config: ChildConfig = ChildConfig[str](
summary_generator=cast(SummaryGenerator, my_summary)
summary_generator=cast("SummaryGenerator", my_summary)
)

actual_result = child_handler(
Expand Down
2 changes: 1 addition & 1 deletion tests/serdes_test.py
Original file line number Diff line number Diff line change
Expand Up @@ -798,7 +798,7 @@ def test_envelope_type_preservation_after_roundtrip():
result = _roundtrip_envelope(original)

# Verify types are preserved
assert type(result["none"]) is type(None)
assert result["none"] is None
assert type(result["bool"]) is bool
assert type(result["int"]) is int
assert type(result["float"]) is float
Expand Down
Loading