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
2 changes: 1 addition & 1 deletion README.md
Original file line number Diff line number Diff line change
Expand Up @@ -56,7 +56,7 @@ We know that your time is precious and, therefore, deeply value any effort to co
* [just](https://github.com/casey/just)
* [Rust toolchain](https://rustup.rs/)

Setup your virtual environment using the tool of your choice, e.g. VirtualEnv:
Set up your virtual environment using the tool of your choice, e.g. VirtualEnv:

```shell
python3 -m venv .venv
Expand Down
2 changes: 1 addition & 1 deletion python/restate/context.py
Original file line number Diff line number Diff line change
Expand Up @@ -120,7 +120,7 @@ class AttemptFinishedEvent(abc.ABC):
Represents an attempt finished event.

This event is used to signal that an attempt has finished (either successfully or with an error), and it is now
safe to cleanup any attempt related resources, such as pending ctx.run() 3rd party calls, or any other resources that
safe to clean up any attempt related resources, such as pending ctx.run() 3rd party calls, or any other resources that
are only valid for the duration of the attempt.

An attempt is considered finished when either the connection to the restate server is closed, the invocation is completed, or a transient
Expand Down
2 changes: 1 addition & 1 deletion python/restate/endpoint.py
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,7 @@ def __init__(self):
Create a new restate endpoint that serves as a container for all the services and objects
"""
self.services = {}
# we will let the user to override it later perhaps, but for now let us
# we will let the user override it later perhaps, but for now let us
# auto deduce it on discovery.
# None means that the user did not explicitly set it.
self.protocol = None
Expand Down
2 changes: 1 addition & 1 deletion python/restate/ext/openai/runner_wrapper.py
Original file line number Diff line number Diff line change
Expand Up @@ -86,7 +86,7 @@ async def call_llm() -> RestateModelResponse:
retry_interval_factor=self.llm_retry_opts.retry_interval_factor,
),
)
# collect function call IDs, to
# collect function call IDs, too
ids = get_function_call_ids(result.output)
self.state.turnstile = Turnstile(ids)

Expand Down
4 changes: 2 additions & 2 deletions python/restate/harness.py
Original file line number Diff line number Diff line change
Expand Up @@ -296,7 +296,7 @@ def create_restate_container(
:param restate_image: The image name for the restate-server container
(default is "restatedev/restate:latest").
:param always_replay: When True, this forces restate-server to always replay
on a suspension point. This is useful to hunt non deterministic bugs
on a suspension point. This is useful to hunt non-deterministic bugs
that might prevent your code to replay correctly (default is False).
:param disable_retries: When True, retries are disabled (default is False).
"""
Expand Down Expand Up @@ -356,7 +356,7 @@ async def create_test_harness(
:param restate_image: The image name for the restate-server container
(default is "restatedev/restate:latest").
:param always_replay: When True, this forces restate-server to always replay
on a suspension point. This is useful to hunt non deterministic bugs
on a suspension point. This is useful to hunt non-deterministic bugs
that might prevent your code to replay correctly (default is False).
:param disable_retries: When True, retries are disabled (default is False).
"""
Expand Down
2 changes: 1 addition & 1 deletion python/restate/server.py
Original file line number Diff line number Diff line change
Expand Up @@ -262,7 +262,7 @@ async def app(scope: Scope, receive: Receive, send: Send):
return
#
# At this point we have a valid handler.
# Let us setup restate's execution context for this invocation and handler.
# Let us set up restate's execution context for this invocation and handler.
#
receive_channel = ReceiveChannel(receive)
try:
Expand Down
2 changes: 1 addition & 1 deletion python/restate/vm.py
Original file line number Diff line number Diff line change
Expand Up @@ -223,7 +223,7 @@ def take_notification(self, handle: int) -> typing.Union[NotificationType, Excep
# success with an empty value
return None
if isinstance(result, bytes):
# success with a non empty value
# success with a non-empty value
return result
if isinstance(result, PyStateKeys):
# success with state keys
Expand Down