fix request_adapter calls

Author: T4rk1n

dash/_callback.py

@@ -1,15 +1,9 @@
-from typing import Callable, Optional, Any, List, Tuple, Union
+from typing import Callable, Optional, Any, List, Tuple, Union, Dict
 from functools import wraps
 import collections
 import hashlib
 import inspect
 
-from functools import wraps
-
-from typing import Callable, Optional, Any, List, Tuple, Union, Dict
-
-import asyncio
-
 from .dependencies import (
     handle_callback_args,
     handle_grouped_callback_args,
@@ -363,7 +357,7 @@ def _initialize_context(args, kwargs, inputs_state_indices, has_output, insert_o
 
 def _get_callback_manager(
     kwargs: dict, background: dict
-) -> Union[BaseBackgroundCallbackManager, None]:
+) -> BaseBackgroundCallbackManager:
     """Set up the background callback and manage jobs."""
     callback_manager = background.get(
         "manager", kwargs.get("background_callback_manager", None)
@@ -379,7 +373,7 @@ def _get_callback_manager(
                 " and store results on redis.\n"
             )
 
-    adapter = backends.request_adapter()
+    adapter = backends.backend.request_adapter()
     old_job = adapter.args.getlist("oldJob") if hasattr(adapter.args, "getlist") else []
 
     if old_job:
@@ -439,7 +433,7 @@ def _setup_background_callback(
 
 def _progress_background_callback(response, callback_manager, background):
     progress_outputs = background.get("progress")
-    adapter = backends.request_adapter()
+    adapter = backends.backend.request_adapter()
     cache_key = adapter.args.get("cacheKey")
 
     if progress_outputs:
@@ -457,7 +451,7 @@ def _update_background_callback(
     """Set up the background callback and manage jobs."""
     callback_manager = _get_callback_manager(kwargs, background)
 
-    adapter = backends.request_adapter()
+    adapter = backends.backend.request_adapter()
     cache_key = adapter.args.get("cacheKey") if adapter else None
     job_id = adapter.args.get("job") if adapter else None
 
@@ -479,7 +473,7 @@ def _handle_rest_background_callback(
     multi,
     has_update=False,
 ):
-    adapter = backends.request_adapter()
+    adapter = backends.backend.request_adapter()
     cache_key = adapter.args.get("cacheKey") if adapter else None
     job_id = adapter.args.get("job") if adapter else None
     # Must get job_running after get_result since get_results terminates it.
@@ -697,7 +691,7 @@ def add_context(*args, **kwargs):
             jsonResponse: Optional[str] = None
             try:
                 if background is not None:
-                    adapter = backends.request_adapter()
+                    adapter = backends.backend.request_adapter()
                     if not (adapter and adapter.args.get("cacheKey")):
                         return _setup_background_callback(
                             kwargs,
@@ -769,7 +763,7 @@ async def async_add_context(*args, **kwargs):
 
             try:
                 if background is not None:
-                    adapter = backends.request_adapter()
+                    adapter = backends.backend.request_adapter()
                     if not (adapter and adapter.args.get("cacheKey")):
                         return _setup_background_callback(
                             kwargs,

dash/_validate.py

@@ -590,14 +590,14 @@ def _valid(out):
 def check_async(use_async):
     if use_async is None:
         try:
-            import asgiref  # pylint: disable=unused-import, import-outside-toplevel # noqa
+            import asgiref  # type: ignore[import-not-found]  # pylint: disable=unused-import, import-outside-toplevel # noqa
 
             use_async = True
         except ImportError:
             pass
     elif use_async:
         try:
-            import asgiref  # pylint: disable=unused-import, import-outside-toplevel # noqa
+            import asgiref  # type: ignore[import-not-found]  # pylint: disable=unused-import, import-outside-toplevel # noqa
         except ImportError as exc:
             raise Exception(
                 "You are trying to use dash[async] without having installed the requirements please install via: `pip install dash[async]`"

dash/backends/__init__.py

@@ -43,7 +43,7 @@ def _is_flask_instance(obj):
 def _is_fastapi_instance(obj):
     try:
         # pylint: disable=import-outside-toplevel
-        from fastapi import FastAPI
+        from fastapi import FastAPI  # type: ignore[import-not-found]
 
         return isinstance(obj, FastAPI)
     except ImportError:
@@ -53,7 +53,7 @@ def _is_fastapi_instance(obj):
 def _is_quart_instance(obj):
     try:
         # pylint: disable=import-outside-toplevel
-        from quart import Quart
+        from quart import Quart  # type: ignore[import-not-found]
 
         return isinstance(obj, Quart)
     except ImportError:

dash/dash.py

@@ -20,8 +20,6 @@
 
 import traceback
 
-from importlib_metadata import version as _get_distribution_version
-
 from dash import dcc
 from dash import html
 from dash import dash_table
@@ -53,7 +51,6 @@
     convert_to_AttributeDict,
     gen_salt,
     hooks_to_js_object,
-    parse_version,
     get_caller_name,
     get_root_path,
 )
@@ -1182,7 +1179,7 @@ def index(self, *_args, **_kwargs):
         renderer = self._generate_renderer()
         title = self.title
         # Refactored: direct access to global request adapter
-        request = backends.request_adapter()
+        request = backends.backend.request_adapter()
 
         if self.use_pages and self.config.include_pages_meta and request:
             metas = _page_meta_tags(self, request) + metas
@@ -1398,7 +1395,7 @@ def _inputs_to_vals(self, inputs):
     # pylint: disable=R0915
     def _initialize_context(self, body):
         """Initialize the global context for the request."""
-        adapter = backends.request_adapter()
+        adapter = backends.backend.request_adapter()
         g = AttributeDict({})
         g.inputs_list = body.get("inputs", [])
         g.states_list = body.get("state", [])
@@ -2445,6 +2442,7 @@ async def get_layouts():
                     ]
 
                 layouts = await get_layouts()
+                # pylint: disable=not-callable
                 layouts += [self.layout() if callable(self.layout) else self.layout]
                 self.validation_layout = html.Div(layouts)
                 if _ID_CONTENT not in self.validation_layout:
@@ -2512,6 +2510,7 @@ def update(pathname_, search_, **states):
             if not self.config.suppress_callback_exceptions:
                 layout = self.layout
                 if not isinstance(layout, list):
+                    # pylint: disable=not-callable
                     layout = [self.layout() if callable(self.layout) else self.layout]
                 self.validation_layout = html.Div(
                     [