File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -67,7 +67,7 @@ def on_exit(_: Receiver) -> None:
6767 receiver = receiver_cls (
6868 broker = broker ,
6969 executor = executor ,
70- run_starup = run_startup ,
70+ run_startup = run_startup ,
7171 validate_params = validate_params ,
7272 max_async_tasks = max_async_tasks ,
7373 max_prefetch = max_prefetch ,
Original file line number Diff line number Diff line change @@ -53,15 +53,15 @@ def __init__(
5353 max_async_tasks : "Optional[int]" = None ,
5454 max_prefetch : int = 0 ,
5555 propagate_exceptions : bool = True ,
56- run_starup : bool = True ,
56+ run_startup : bool = True ,
5757 ack_type : Optional [AcknowledgeType ] = None ,
5858 on_exit : Optional [Callable [["Receiver" ], None ]] = None ,
5959 max_tasks_to_execute : Optional [int ] = None ,
6060 wait_tasks_timeout : Optional [float ] = None ,
6161 ) -> None :
6262 self .broker = broker
6363 self .executor = executor
64- self .run_startup = run_starup
64+ self .run_startup = run_startup
6565 self .validate_params = validate_params
6666 self .task_signatures : Dict [str , inspect .Signature ] = {}
6767 self .task_hints : Dict [str , Dict [str , Any ]] = {}
You can’t perform that action at this time.
0 commit comments