class documentation
class _TimeSkippingWorkflowHandle(temporalio.client.WorkflowHandle): (source)
Constructor: _TimeSkippingWorkflowHandle(client, id, run_id, result_run_id, ...)
Undocumented
Async Method | result |
Wait for result of the workflow. |
Class Variable | env |
Undocumented |
Inherited from WorkflowHandle
:
Method | __init__ |
Create workflow handle. |
Async Method | cancel |
Cancel the workflow. |
Async Method | describe |
Get workflow details. |
Async Method | execute |
Send an update request to the workflow and wait for it to complete. |
Async Method | fetch |
Get workflow history. |
Method | fetch |
Get workflow history events as an async iterator. |
Method | get |
Get a handle for an update. The handle can be used to wait on the update result. |
Method | get |
Get a typed handle for an update. The handle can be used to wait on the update result. |
Async Method | query |
Query the workflow. |
Async Method | signal |
Send a signal to the workflow. |
Async Method | start |
Send an update request to the workflow and return a handle to it. |
Async Method | terminate |
Terminate the workflow. |
Property | first |
Run ID used to ensure requested operations apply to a workflow ID started with this run ID. |
Property | id |
ID for the workflow. |
Property | result |
Run ID used for result calls if present to ensure result is for a workflow starting from this run. |
Property | run |
If present, run ID used to ensure that requested operations apply to this exact run. |
Method | _fetch |
Undocumented |
Async Method | _start |
Undocumented |
Instance Variable | __temporal |
Undocumented |
Instance Variable | _client |
Undocumented |
Instance Variable | _first |
Undocumented |
Instance Variable | _id |
Undocumented |
Instance Variable | _result |
Undocumented |
Instance Variable | _result |
Undocumented |
Instance Variable | _run |
Undocumented |
Instance Variable | _start |
Undocumented |
async def result(self, *, follow_runs:
bool
= True, rpc_metadata: Mapping[ str, str]
= {}, rpc_timeout: timedelta | None
= None) -> Any
:
(source)
¶
overrides
temporalio.client.WorkflowHandle.result
Wait for result of the workflow.
This will use result_run_id
if present to base the result on.
To use another run ID, a new handle must be created via
Client.get_workflow_handle
.
Parameters | |
followbool | If true (default), workflow runs will be continually fetched, until the most recent one is found. If false, return the result from the first run targeted by the request if that run ends in a result, otherwise raise an exception. |
rpcMapping[ | Headers used on the RPC call. Keys here override client-level RPC metadata keys. |
rpctimedelta | None | Optional RPC deadline to set for each RPC call. Note, this is the timeout for each history RPC call not this overall function. |
Returns | |
Any | Result of the workflow after being converted by the data converter. |
Raises | |
WorkflowFailureError | Workflow failed, was cancelled, was
terminated, or timed out. Use the
WorkflowFailureError.cause to see the underlying
reason. |
Exception | Other possible failures during result fetching. |