File tree Expand file tree Collapse file tree 1 file changed +0
-21
lines changed Expand file tree Collapse file tree 1 file changed +0
-21
lines changed Original file line number Diff line number Diff line change @@ -104,27 +104,6 @@ async def fetch_result(
104
104
raise NotImplementedError (
105
105
"Temporal Nexus operation handlers do not support fetching the operation result."
106
106
)
107
- # An implementation is provided for future reference:
108
- # TODO: honor `wait` param and Request-Timeout header
109
- # try:
110
- # nexus_handle = WorkflowHandle[OutputT].from_token(token)
111
- # except Exception as err:
112
- # raise HandlerError(
113
- # "Failed to decode operation token as workflow operation token. "
114
- # "Fetching result for non-workflow operations is not supported.",
115
- # type=HandlerErrorType.NOT_FOUND,
116
- # ) from err
117
- # ctx = _temporal_fetch_operation_context.get()
118
- # try:
119
- # client_handle = nexus_handle.to_workflow_handle(
120
- # ctx.client, result_type=self._output_type
121
- # )
122
- # except Exception as err:
123
- # raise HandlerError(
124
- # "Failed to construct workflow handle from workflow operation token",
125
- # type=HandlerErrorType.NOT_FOUND,
126
- # ) from err
127
- # return await client_handle.result()
128
107
129
108
130
109
async def _cancel_workflow (
You can’t perform that action at this time.
0 commit comments