temporalio.testing._workflow._NonTsWorkflowEnvironment

class documentation

class _NonTsWorkflowEnvironment(_HasAServer): (source)

Constructors: _NonTsWorkflowEnvironment(client, server), _NonTsWorkflowEnvironment._create(**kwargs)

View In Hierarchy

Dev-server env with no time skipping.

Method __init__ Create a workflow environment from a client.
Async Class Method _create Undocumented

Inherited from _HasAServer:

Async Method shutdown Shut down this environment.
Async Class Method _bootstrap_dev_server Start a CLI dev server and connect a client. Shared by non-ts and V2.
Instance Variable _server Undocumented

Inherited from WorkflowEnvironment (via _HasAServer):

Class Method from_client Create a workflow environment from the given client.
Async Class Method start_local Start a full Temporal server locally, downloading if necessary.
Async Class Method start_time_skipping Start a V1 time skipping workflow environment.
Async Class Method start_time_skipping_v2 Start a local Temporal server with per-workflow time skipping enabled.
Async Method __aenter__ Noop for async with support.
Async Method __aexit__ For async with support to just call shutdown.
Method auto_time_skipping_disabled Disable V1's SDK-driven auto-unlock-on-result-await for the block.
Async Method connect_client Create another client connected to this environment.
Async Method create_nexus_endpoint Create a Nexus endpoint with the given name and task queue.
Async Method delete_nexus_endpoint Delete a Nexus endpoint.
Async Method fast_forward Fast-forward this workflow's virtual clock by duration, and wait for it to complete.
Async Method get_current_time Get the current time known to this environment.
Async Method get_time_skipping_info Fetch a workflow's TimeSkippingInfo via DescribeWorkflowExecution.
Async Method sleep Sleep in this environment.
Method with_time_skipping_disabled Suspend V2 time-skipping config stamping on newly-started workflows within the block.
Property client Client to this environment.
Property supports_time_skipping Whether this environment supports either V1 or V2 time skipping.
Property supports_time_skipping_v1 True if this environment uses the V1 Java time-skipping server (which has limited server features).
Property supports_time_skipping_v2 True if this environment uses the V2 time-skipping server.
Instance Variable _client Undocumented
def __init__(self, client: temporalio.client.Client, server: temporalio.bridge.testing.EphemeralServer): (source)
overrides temporalio.testing._workflow._HasAServer.__init__

Create a workflow environment from a client.

Most users would use a factory method instead.

async def _create(cls, **kwargs: Any) -> _NonTsWorkflowEnvironment: (source)

Undocumented