File tree Expand file tree Collapse file tree 2 files changed +1
-7
lines changed Expand file tree Collapse file tree 2 files changed +1
-7
lines changed Original file line number Diff line number Diff line change @@ -120,7 +120,7 @@ async def _start(
120120 )
121121
122122 _start .__doc__ = start .__doc__
123- return WorkflowRunOperationHandler (_start , input_type , output_type )
123+ return WorkflowRunOperationHandler (_start )
124124
125125 method_name = get_callable_name (start )
126126 nexusrpc .set_operation_definition (
Original file line number Diff line number Diff line change 44 Any ,
55 Awaitable ,
66 Callable ,
7- Optional ,
8- Type ,
97)
108
119from nexusrpc import (
@@ -50,8 +48,6 @@ def __init__(
5048 [StartOperationContext , InputT ],
5149 Awaitable [WorkflowHandle [OutputT ]],
5250 ],
53- input_type : Optional [Type [InputT ]],
54- output_type : Optional [Type [OutputT ]],
5551 ) -> None :
5652 """Initialize the workflow run operation handler."""
5753 if not is_async_callable (start ):
@@ -64,8 +60,6 @@ def __init__(
6460 if start .__doc__ :
6561 if start_func := getattr (self .start , "__func__" , None ):
6662 start_func .__doc__ = start .__doc__
67- self ._input_type = input_type
68- self ._output_type = output_type
6963
7064 async def start (
7165 self , ctx : StartOperationContext , input : InputT
You can’t perform that action at this time.
0 commit comments