diff --git a/README.md b/README.md index 8adf3b1..726c17c 100644 --- a/README.md +++ b/README.md @@ -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 diff --git a/python/restate/context.py b/python/restate/context.py index 2af7a6c..98f2239 100644 --- a/python/restate/context.py +++ b/python/restate/context.py @@ -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 diff --git a/python/restate/endpoint.py b/python/restate/endpoint.py index 2383101..f8c3a83 100644 --- a/python/restate/endpoint.py +++ b/python/restate/endpoint.py @@ -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 diff --git a/python/restate/ext/openai/runner_wrapper.py b/python/restate/ext/openai/runner_wrapper.py index d93f6db..68a039d 100644 --- a/python/restate/ext/openai/runner_wrapper.py +++ b/python/restate/ext/openai/runner_wrapper.py @@ -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) diff --git a/python/restate/harness.py b/python/restate/harness.py index 115fff6..28c568f 100644 --- a/python/restate/harness.py +++ b/python/restate/harness.py @@ -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). """ @@ -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). """ diff --git a/python/restate/server.py b/python/restate/server.py index 587d820..f6a514a 100644 --- a/python/restate/server.py +++ b/python/restate/server.py @@ -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: diff --git a/python/restate/vm.py b/python/restate/vm.py index 95951c8..f292d5c 100644 --- a/python/restate/vm.py +++ b/python/restate/vm.py @@ -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