TODOs

- fetch result
- error handling

Author: dandavison

temporalio/nexus/_operation_handlers.py

@@ -104,6 +104,7 @@ async def fetch_result(
             "Temporal Nexus operation handlers do not support fetching the operation result."
         )
         # An implementation is provided for future reference:
+        # TODO: honor `wait` param and Request-Timeout header
         try:
             nexus_handle = WorkflowHandle[OutputT].from_token(token)
         except Exception as err:

temporalio/worker/_nexus.py

@@ -341,6 +341,8 @@ async def _operation_error_to_proto(
         self,
         err: nexusrpc.OperationError,
     ) -> temporalio.api.nexus.v1.UnsuccessfulOperationError:
+        # TODO(nexus-prerelease): why are we accessing __cause__ here for OperationError
+        # and not for HandlerError?
         cause = err.__cause__
         if cause is None:
             cause = Exception(*err.args).with_traceback(err.__traceback__)