@@ -11,13 +11,13 @@ def startup_event_generator(
1111 app_or_path : Union [str , FastAPI ],
1212) -> Callable [[TaskiqState ], Awaitable [None ]]:
1313 """
14- Generate shutdown event.
14+ Generate startup event handler .
1515
1616 This function takes FastAPI application path
1717 and runs startup event on broker's startup.
1818
1919 :param broker: current broker.
20- :param app_path : fastapi application path.
20+ :param app_or_path : fastapi instance or application path.
2121 :returns: startup handler.
2222 """
2323
@@ -48,7 +48,7 @@ def shutdown_event_generator(
4848 broker : AsyncBroker ,
4949) -> Callable [[TaskiqState ], Awaitable [None ]]:
5050 """
51- Generate shutdown event.
51+ Generate shutdown event handler .
5252
5353 This function takes FastAPI application
5454 and runs shutdown event on broker's shutdown.
@@ -78,7 +78,7 @@ def init(broker: AsyncBroker, app_or_path: Union[str, FastAPI]) -> None:
7878 startup events will run.
7979
8080 :param broker: current broker to use.
81- :param app_path: path to fastapi application.
81+ :param app_or_path: fastapi instance or application path .
8282 """
8383 broker .add_event_handler (
8484 TaskiqEvents .WORKER_STARTUP ,
@@ -102,7 +102,7 @@ def populate_dependency_context(
102102 This function injects the Request and HTTPConnection
103103 into the broker's dependency context.
104104
105- It may be need to be called manually if you are using InMemoryBroker.
105+ It may be needed to be called manually if you are using InMemoryBroker.
106106
107107 :param broker: current broker to use.
108108 :param app: current application.
0 commit comments