Skip to content
Merged
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
4 changes: 3 additions & 1 deletion .gitignore
Original file line number Diff line number Diff line change
Expand Up @@ -24,4 +24,6 @@ __pycache__/

.attach_*

dist/
dist/

.idea
2 changes: 1 addition & 1 deletion CONTRIBUTING.md
Original file line number Diff line number Diff line change
Expand Up @@ -95,7 +95,7 @@ This will drop you into the Python debugger on the failed test.
### Writing tests
Place test files in the `tests/` directory, using file names that end with `_test`.

Mimic the package structure in the src/aws_durable_functions_sdk_python directory.
Mimic the package structure in the src/aws_durable_execution_sdk_python directory.
Name your module so that src/mypackage/mymodule.py has a dedicated unit test file
tests/mypackage/mymodule_test.py

Expand Down
2 changes: 1 addition & 1 deletion README.md
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
## Installation

```console
pip install aws-durable-functions-sdk-python
pip install aws-durable-execution-sdk-python
```

## Developers
Expand Down
28 changes: 14 additions & 14 deletions pyproject.toml
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@ requires = ["hatchling"]
build-backend = "hatchling.build"

[project]
name = "aws-durable-functions-sdk-python"
name = "aws-durable-execution-sdk-python"
dynamic = ["version"]
description = 'This the Python SDK for AWS Lambda Durable Functions.'
readme = "README.md"
Expand All @@ -25,18 +25,18 @@ dependencies = [
]

[project.urls]
Documentation = "https://github.com/aws/aws-durable-functions-sdk-python#readme"
Issues = "https://github.com/aws/aws-durable-functions-sdk-python/issues"
Source = "https://github.com/aws/aws-durable-functions-sdk-python"
Documentation = "https://github.com/aws/aws-durable-execution-sdk-python#readme"
Issues = "https://github.com/aws/aws-durable-execution-sdk-python/issues"
Source = "https://github.com/aws/aws-durable-execution-sdk-python"

[tool.hatch.build.targets.sdist]
packages = ["src/aws_durable_functions_sdk_python"]
packages = ["src/aws_durable_execution_sdk_python"]

[tool.hatch.build.targets.wheel]
packages = ["src/aws_durable_functions_sdk_python"]
packages = ["src/aws_durable_execution_sdk_python"]

[tool.hatch.version]
path = "src/aws_durable_functions_sdk_python/__about__.py"
path = "src/aws_durable_execution_sdk_python/__about__.py"

# [tool.hatch.envs.default]
# dependencies=["pytest"]
Expand All @@ -52,27 +52,27 @@ dependencies = [
]

[tool.hatch.envs.test.scripts]
cov="pytest --cov-report=term-missing --cov-config=pyproject.toml --cov=src/aws_durable_functions_sdk_python --cov=tests --cov-fail-under=98"
cov="pytest --cov-report=term-missing --cov-config=pyproject.toml --cov=src/aws_durable_execution_sdk_python --cov=tests --cov-fail-under=98"

[tool.hatch.envs.types]
extra-dependencies = [
"mypy>=1.0.0",
"pytest"
]
[tool.hatch.envs.types.scripts]
check = "mypy --install-types --non-interactive {args:src/aws_durable_functions_sdk_python tests}"
check = "mypy --install-types --non-interactive {args:src/aws_durable_execution_sdk_python tests}"

[tool.coverage.run]
source_pkgs = ["aws_durable_functions_sdk_python", "tests"]
source_pkgs = ["aws_durable_execution_sdk_python", "tests"]
branch = true
parallel = true
omit = [
"src/aws_durable_functions_sdk_python/__about__.py",
"src/aws_durable_execution_sdk_python/__about__.py",
]

[tool.coverage.paths]
aws_durable_functions_sdk_python = ["src/aws_durable_functions_sdk_python", "*/aws-durable-functions-sdk-python/src/aws_durable_functions_sdk_python"]
tests = ["tests", "*/aws-durable-functions-sdk-python/tests"]
aws_durable_execution_sdk_python = ["src/aws_durable_execution_sdk_python", "*/aws-durable-execution-sdk-python/src/aws_durable_execution_sdk_python"]
tests = ["tests", "*/aws-durable-execution-sdk-python/tests"]

[tool.coverage.report]
exclude_lines = [
Expand All @@ -88,4 +88,4 @@ line-length = 88
preview = false

[tool.ruff.lint.per-file-ignores]
"tests/**" = ["ARG001", "ARG002", "ARG005", "S101", "PLR2004", "SIM117", "TRY301"]
"tests/**" = ["ARG001", "ARG002", "ARG005", "S101", "PLR2004", "SIM117", "TRY301"]
Original file line number Diff line number Diff line change
Expand Up @@ -12,21 +12,21 @@
from enum import Enum
from typing import TYPE_CHECKING, Generic, Self, TypeVar

from aws_durable_functions_sdk_python.exceptions import (
from aws_durable_execution_sdk_python.exceptions import (
InvalidStateError,
SuspendExecution,
TimedSuspendExecution,
)
from aws_durable_functions_sdk_python.lambda_service import ErrorObject
from aws_durable_functions_sdk_python.types import BatchResult as BatchResultProtocol
from aws_durable_execution_sdk_python.lambda_service import ErrorObject
from aws_durable_execution_sdk_python.types import BatchResult as BatchResultProtocol

if TYPE_CHECKING:
from collections.abc import Callable

from aws_durable_functions_sdk_python.config import ChildConfig, CompletionConfig
from aws_durable_functions_sdk_python.lambda_service import OperationSubType
from aws_durable_functions_sdk_python.state import ExecutionState
from aws_durable_functions_sdk_python.types import DurableContext
from aws_durable_execution_sdk_python.config import ChildConfig, CompletionConfig
from aws_durable_execution_sdk_python.lambda_service import OperationSubType
from aws_durable_execution_sdk_python.state import ExecutionState
from aws_durable_execution_sdk_python.types import DurableContext


logger = logging.getLogger(__name__)
Expand Down Expand Up @@ -689,7 +689,7 @@ def _execute_item_in_child_context(
executable: Executable[CallableType],
) -> ResultType:
"""Execute a single item in a child context."""
from aws_durable_functions_sdk_python.config import ChildConfig
from aws_durable_execution_sdk_python.config import ChildConfig

def execute_in_child_context(child_context: DurableContext) -> ResultType:
return self.execute_item(child_context, executable)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
from enum import Enum
from typing import TYPE_CHECKING, Generic, TypeVar

from aws_durable_functions_sdk_python.retries import RetryDecision # noqa: TCH001
from aws_durable_execution_sdk_python.retries import RetryDecision # noqa: TCH001

R = TypeVar("R")
T = TypeVar("T")
Expand All @@ -16,8 +16,8 @@
from collections.abc import Callable
from concurrent.futures import Future

from aws_durable_functions_sdk_python.lambda_service import OperationSubType
from aws_durable_functions_sdk_python.serdes import SerDes
from aws_durable_execution_sdk_python.lambda_service import OperationSubType
from aws_durable_execution_sdk_python.serdes import SerDes


Numeric = int | float # deliberately leaving off complex
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@
import logging
from typing import TYPE_CHECKING, Any, Concatenate, Generic, ParamSpec, TypeVar

from aws_durable_functions_sdk_python.config import (
from aws_durable_execution_sdk_python.config import (
BatchedInput,
CallbackConfig,
ChildConfig,
Expand All @@ -13,48 +13,48 @@
WaitForCallbackConfig,
WaitForConditionConfig,
)
from aws_durable_functions_sdk_python.exceptions import (
from aws_durable_execution_sdk_python.exceptions import (
FatalError,
SuspendExecution,
ValidationError,
)
from aws_durable_functions_sdk_python.identifier import OperationIdentifier
from aws_durable_functions_sdk_python.lambda_context import (
from aws_durable_execution_sdk_python.identifier import OperationIdentifier
from aws_durable_execution_sdk_python.lambda_context import (
LambdaContext,
make_dict_from_obj,
)
from aws_durable_functions_sdk_python.lambda_service import OperationSubType
from aws_durable_functions_sdk_python.logger import Logger, LogInfo
from aws_durable_functions_sdk_python.operation.callback import (
from aws_durable_execution_sdk_python.lambda_service import OperationSubType
from aws_durable_execution_sdk_python.logger import Logger, LogInfo
from aws_durable_execution_sdk_python.operation.callback import (
create_callback_handler,
wait_for_callback_handler,
)
from aws_durable_functions_sdk_python.operation.child import child_handler
from aws_durable_functions_sdk_python.operation.map import map_handler
from aws_durable_functions_sdk_python.operation.parallel import parallel_handler
from aws_durable_functions_sdk_python.operation.step import step_handler
from aws_durable_functions_sdk_python.operation.wait import wait_handler
from aws_durable_functions_sdk_python.operation.wait_for_condition import (
from aws_durable_execution_sdk_python.operation.child import child_handler
from aws_durable_execution_sdk_python.operation.map import map_handler
from aws_durable_execution_sdk_python.operation.parallel import parallel_handler
from aws_durable_execution_sdk_python.operation.step import step_handler
from aws_durable_execution_sdk_python.operation.wait import wait_handler
from aws_durable_execution_sdk_python.operation.wait_for_condition import (
wait_for_condition_handler,
)
from aws_durable_functions_sdk_python.serdes import SerDes, deserialize
from aws_durable_functions_sdk_python.state import ExecutionState # noqa: TCH001
from aws_durable_functions_sdk_python.threading import OrderedCounter
from aws_durable_functions_sdk_python.types import (
from aws_durable_execution_sdk_python.serdes import SerDes, deserialize
from aws_durable_execution_sdk_python.state import ExecutionState # noqa: TCH001
from aws_durable_execution_sdk_python.threading import OrderedCounter
from aws_durable_execution_sdk_python.types import (
BatchResult,
LoggerInterface,
StepContext,
WaitForConditionCheckContext,
)
from aws_durable_functions_sdk_python.types import Callback as CallbackProtocol
from aws_durable_functions_sdk_python.types import (
from aws_durable_execution_sdk_python.types import Callback as CallbackProtocol
from aws_durable_execution_sdk_python.types import (
DurableContext as DurableContextProtocol,
)

if TYPE_CHECKING:
from collections.abc import Callable, Sequence

from aws_durable_functions_sdk_python.state import CheckpointedResult
from aws_durable_execution_sdk_python.state import CheckpointedResult

R = TypeVar("R")
T = TypeVar("T")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,14 +6,14 @@
from enum import Enum
from typing import TYPE_CHECKING, Any

from aws_durable_functions_sdk_python.context import DurableContext, ExecutionState
from aws_durable_functions_sdk_python.exceptions import (
from aws_durable_execution_sdk_python.context import DurableContext, ExecutionState
from aws_durable_execution_sdk_python.exceptions import (
CheckpointError,
DurableExecutionsError,
FatalError,
SuspendExecution,
)
from aws_durable_functions_sdk_python.lambda_service import (
from aws_durable_execution_sdk_python.lambda_service import (
DurableServiceClient,
ErrorObject,
LambdaClient,
Expand All @@ -25,7 +25,7 @@
if TYPE_CHECKING:
from collections.abc import Callable, MutableMapping

from aws_durable_functions_sdk_python.lambda_context import LambdaContext
from aws_durable_execution_sdk_python.lambda_context import LambdaContext

logger = logging.getLogger(__name__)

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -10,15 +10,15 @@

import boto3 # type: ignore

from aws_durable_functions_sdk_python.exceptions import (
from aws_durable_execution_sdk_python.exceptions import (
CallableRuntimeError,
CheckpointError,
)

if TYPE_CHECKING:
from collections.abc import MutableMapping

from aws_durable_functions_sdk_python.identifier import OperationIdentifier
from aws_durable_execution_sdk_python.identifier import OperationIdentifier

logger = logging.getLogger(__name__)

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,12 +5,12 @@
from dataclasses import dataclass
from typing import TYPE_CHECKING

from aws_durable_functions_sdk_python.types import LoggerInterface
from aws_durable_execution_sdk_python.types import LoggerInterface

if TYPE_CHECKING:
from collections.abc import Mapping, MutableMapping

from aws_durable_functions_sdk_python.identifier import OperationIdentifier
from aws_durable_execution_sdk_python.identifier import OperationIdentifier


@dataclass(frozen=True)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -4,25 +4,25 @@

from typing import TYPE_CHECKING, Any

from aws_durable_functions_sdk_python.exceptions import FatalError
from aws_durable_functions_sdk_python.lambda_service import (
from aws_durable_execution_sdk_python.exceptions import FatalError
from aws_durable_execution_sdk_python.lambda_service import (
CallbackOptions,
OperationUpdate,
)

if TYPE_CHECKING:
from collections.abc import Callable

from aws_durable_functions_sdk_python.config import (
from aws_durable_execution_sdk_python.config import (
CallbackConfig,
WaitForCallbackConfig,
)
from aws_durable_functions_sdk_python.identifier import OperationIdentifier
from aws_durable_functions_sdk_python.state import (
from aws_durable_execution_sdk_python.identifier import OperationIdentifier
from aws_durable_execution_sdk_python.state import (
CheckpointedResult,
ExecutionState,
)
from aws_durable_functions_sdk_python.types import Callback, DurableContext
from aws_durable_execution_sdk_python.types import Callback, DurableContext


def create_callback_handler(
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,20 +5,20 @@
import logging
from typing import TYPE_CHECKING, TypeVar

from aws_durable_functions_sdk_python.config import ChildConfig
from aws_durable_functions_sdk_python.exceptions import FatalError, SuspendExecution
from aws_durable_functions_sdk_python.lambda_service import (
from aws_durable_execution_sdk_python.config import ChildConfig
from aws_durable_execution_sdk_python.exceptions import FatalError, SuspendExecution
from aws_durable_execution_sdk_python.lambda_service import (
ErrorObject,
OperationSubType,
OperationUpdate,
)
from aws_durable_functions_sdk_python.serdes import deserialize, serialize
from aws_durable_execution_sdk_python.serdes import deserialize, serialize

if TYPE_CHECKING:
from collections.abc import Callable

from aws_durable_functions_sdk_python.identifier import OperationIdentifier
from aws_durable_functions_sdk_python.state import ExecutionState
from aws_durable_execution_sdk_python.identifier import OperationIdentifier
from aws_durable_execution_sdk_python.state import ExecutionState

logger = logging.getLogger(__name__)

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,18 +6,18 @@
from collections.abc import Callable, Sequence
from typing import TYPE_CHECKING, Generic, TypeVar

from aws_durable_functions_sdk_python.concurrency import (
from aws_durable_execution_sdk_python.concurrency import (
BatchResult,
ConcurrentExecutor,
Executable,
)
from aws_durable_functions_sdk_python.config import MapConfig
from aws_durable_functions_sdk_python.lambda_service import OperationSubType
from aws_durable_execution_sdk_python.config import MapConfig
from aws_durable_execution_sdk_python.lambda_service import OperationSubType

if TYPE_CHECKING:
from aws_durable_functions_sdk_python.config import ChildConfig
from aws_durable_functions_sdk_python.state import ExecutionState
from aws_durable_functions_sdk_python.types import DurableContext
from aws_durable_execution_sdk_python.config import ChildConfig
from aws_durable_execution_sdk_python.state import ExecutionState
from aws_durable_execution_sdk_python.types import DurableContext


logger = logging.getLogger(__name__)
Expand Down
Loading