Merge branch 'release/0.3.1'

Author: s3rius

pyproject.toml

@@ -3,7 +3,7 @@ name = "taskiq-aiohttp"
 description = "Taskiq integration with AioHTTP framework"
 authors = ["Taskiq team <taskiq@no-reply.com>"]
 maintainers = ["Taskiq team <taskiq@no-reply.com>"]
-version = "0.3.0"
+version = "0.3.1"
 readme = "README.md"
 license = "LICENSE"
 classifiers = [

taskiq_aiohttp/initializer.py

@@ -96,11 +96,14 @@ async def startup(state: TaskiqState) -> None:
 
         app = import_object(app_path)
 
-        if not isinstance(app, web.Application):
+        if inspect.iscoroutinefunction(app):
+            app = await app()
+        elif inspect.isfunction(app):
             app = app()
 
-        if inspect.iscoroutine(app):
-            app = await app
+        if isinstance(app, web.AppRunner):
+            app = app.app
+
         if not isinstance(app, web.Application):
             raise ValueError(f"{app_path} is not an AioHTTP application.")