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 for cancel and terminate calls if present to ensure the cancel and terminate happen for 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 |
Run ID used for signal , query , and update calls if present to ensure the signal/query/update happen on 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 |
async def result(self, *, follow_runs:
bool
= True, rpc_metadata: Mapping[ str, str]
= {}, rpc_timeout: Optional[ timedelta]
= 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, the first result is used. |
rpcMapping[ | Headers used on the RPC call. Keys here override client-level RPC metadata keys. |
rpcOptional[ | 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. |