File tree Expand file tree Collapse file tree 2 files changed +3
-3
lines changed Expand file tree Collapse file tree 2 files changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -67,7 +67,7 @@ def on_exit(_: Receiver) -> None:
67
67
receiver = receiver_cls (
68
68
broker = broker ,
69
69
executor = executor ,
70
- run_starup = run_startup ,
70
+ run_startup = run_startup ,
71
71
validate_params = validate_params ,
72
72
max_async_tasks = max_async_tasks ,
73
73
max_prefetch = max_prefetch ,
Original file line number Diff line number Diff line change @@ -53,15 +53,15 @@ def __init__(
53
53
max_async_tasks : "Optional[int]" = None ,
54
54
max_prefetch : int = 0 ,
55
55
propagate_exceptions : bool = True ,
56
- run_starup : bool = True ,
56
+ run_startup : bool = True ,
57
57
ack_type : Optional [AcknowledgeType ] = None ,
58
58
on_exit : Optional [Callable [["Receiver" ], None ]] = None ,
59
59
max_tasks_to_execute : Optional [int ] = None ,
60
60
wait_tasks_timeout : Optional [float ] = None ,
61
61
) -> None :
62
62
self .broker = broker
63
63
self .executor = executor
64
- self .run_startup = run_starup
64
+ self .run_startup = run_startup
65
65
self .validate_params = validate_params
66
66
self .task_signatures : Dict [str , inspect .Signature ] = {}
67
67
self .task_hints : Dict [str , Dict [str , Any ]] = {}
You can’t perform that action at this time.
0 commit comments