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: 0 additions & 2 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -1514,8 +1514,6 @@ code](https://github.com/temporalio/samples-python/blob/main/context_propagation

### Nexus

⚠️ **Nexus support is currently at an experimental release stage. Backwards-incompatible changes are anticipated until a stable release is announced.** ⚠️

[Nexus](https://github.com/nexus-rpc/) is a synchronous RPC protocol. Arbitrary duration operations that can respond
asynchronously are modeled on top of a set of pre-defined synchronous RPCs.

Expand Down
3 changes: 0 additions & 3 deletions temporalio/nexus/__init__.py
Original file line number Diff line number Diff line change
@@ -1,8 +1,5 @@
"""Temporal Nexus support

.. warning::
Nexus APIs are experimental and unstable.

See https://github.com/temporalio/sdk-python/tree/main#nexus
"""

Expand Down
15 changes: 2 additions & 13 deletions temporalio/nexus/_operation_context.py
Original file line number Diff line number Diff line change
Expand Up @@ -76,9 +76,6 @@
class Info:
"""Information about the running Nexus operation.

.. warning::
This API is experimental and unstable.

Retrieved inside a Nexus operation handler via :py:func:`info`.
"""

Expand Down Expand Up @@ -277,11 +274,7 @@ def _add_outbound_links(


class WorkflowRunOperationContext(StartOperationContext):
"""Context received by a workflow run operation.

.. warning::
This API is experimental and unstable.
"""
"""Context received by a workflow run operation."""

def __init__(self, *args: Any, **kwargs: Any) -> None:
"""Initialize the workflow run operation context."""
Expand Down Expand Up @@ -541,11 +534,7 @@ async def start_workflow(

@dataclass(frozen=True)
class NexusCallback:
"""Nexus callback to attach to events such as workflow completion.

.. warning::
This API is experimental and unstable.
"""
"""Nexus callback to attach to events such as workflow completion."""

url: str
"""Callback URL."""
Expand Down
3 changes: 0 additions & 3 deletions temporalio/nexus/_token.py
Original file line number Diff line number Diff line change
Expand Up @@ -18,9 +18,6 @@
class WorkflowHandle(Generic[OutputT]):
"""A handle to a workflow that is backing a Nexus operation.

.. warning::
This API is experimental and unstable.

Do not instantiate this directly. Use
:py:func:`temporalio.nexus.WorkflowRunOperationContext.start_workflow` to create a
handle.
Expand Down
6 changes: 0 additions & 6 deletions temporalio/worker/_worker.py
Original file line number Diff line number Diff line change
Expand Up @@ -157,9 +157,6 @@ def __init__(
may be async functions or non-async functions.
nexus_service_handlers: Instances of Nexus service handler classes
decorated with :py:func:`@nexusrpc.handler.service_handler<nexusrpc.handler.service_handler>`.

.. warning::
This parameter is experimental and unstable.
workflows: Workflow classes decorated with
:py:func:`@workflow.defn<temporalio.workflow.defn>`.
activity_executor: Concurrent executor to use for non-async
Expand All @@ -182,9 +179,6 @@ def __init__(
nexus_task_executor: Executor to use for non-async
Nexus operations. This is required if any operation start methods
are non-``async def``.

.. warning::
This parameter is experimental and unstable.
workflow_runner: Runner for workflows.
unsandboxed_workflow_runner: Runner for workflows that opt-out of
sandboxing.
Expand Down
12 changes: 1 addition & 11 deletions temporalio/workflow.py
Original file line number Diff line number Diff line change
Expand Up @@ -4656,11 +4656,7 @@ async def execute_child_workflow(


class NexusOperationHandle(Generic[OutputT]):
"""Handle for interacting with a Nexus operation.

.. warning::
This API is experimental and unstable.
"""
"""Handle for interacting with a Nexus operation."""

# TODO(nexus-preview): should attempts to instantiate directly throw?

Expand Down Expand Up @@ -5444,9 +5440,6 @@ class NexusOperationCancellationType(IntEnum):
class NexusClient(ABC, Generic[ServiceT]):
"""A client for invoking Nexus operations.

.. warning::
This API is experimental and unstable.

Example::

nexus_client = workflow.create_nexus_client(
Expand Down Expand Up @@ -5858,9 +5851,6 @@ def create_nexus_client(
) -> NexusClient[ServiceT]:
"""Create a Nexus client.

.. warning::
This API is experimental and unstable.

Args:
service: The Nexus service.
endpoint: The Nexus endpoint.
Expand Down
Loading