fixing for lint

Author: BSd3v

dash/_pages.py

@@ -396,9 +396,7 @@ def _page_meta_tags(app, request):
     image = start_page.get("image", "")
     if image:
         image = app.get_asset_url(image)
-    assets_image_url = (
-        "".join([request.url_root, image.lstrip("/")]) if image else None
-    )
+    assets_image_url = "".join([request.url_root, image.lstrip("/")]) if image else None
     supplied_image_url = start_page.get("image_url")
     image_url = supplied_image_url if supplied_image_url else assets_image_url
 

dash/dash.py

@@ -497,19 +497,25 @@ def __init__(  # pylint: disable=too-many-statements
 
         # We have 3 cases: server is either True (we create the server), False
         # (defer server creation) or a Flask app instance (we use their server)
-        if callable(server) and not (hasattr(server, 'route') and hasattr(server, 'run')):
+        if callable(server) and not (
+            hasattr(server, "route") and hasattr(server, "run")
+        ):
             # Server factory function
             self.server = server()
             if name is None:
                 caller_name = getattr(self.server, "name", caller_name)
-        elif hasattr(server, 'route') and hasattr(server, 'run'):
+        elif hasattr(server, "route") and hasattr(server, "run"):
             self.server = server
             if name is None:
                 caller_name = getattr(server, "name", caller_name)
         elif isinstance(server, bool):
-            self.server = self.server_factory.create_app(caller_name) if server else None
+            self.server = (
+                self.server_factory.create_app(caller_name) if server else None
+            )
         else:
-            raise ValueError("server must be a Flask app, a boolean, or a server factory function")
+            raise ValueError(
+                "server must be a Flask app, a boolean, or a server factory function"
+            )
 
         base_prefix, routes_prefix, requests_prefix = pathname_configs(
             url_base_pathname, routes_pathname_prefix, requests_pathname_prefix
@@ -707,6 +713,7 @@ def init_app(self, app: Optional[Any] = None, **kwargs) -> None:
         if config.compress:
             try:
                 from flask_compress import Compress
+
                 Compress(self.server)
                 _flask_compress_version = parse_version(
                     _get_distribution_version("flask_compress")
@@ -741,7 +748,11 @@ def _setup_routes(self):
         self.server_factory.setup_component_suites(self.server, self)
         self._add_url("_dash-layout", self.serve_layout)
         self._add_url("_dash-dependencies", self.dependencies)
-        self._add_url("_dash-update-component", self.server_factory.dispatch(self.server, self, self._use_async), ["POST"])
+        self._add_url(
+            "_dash-update-component",
+            self.server_factory.dispatch(self.server, self, self._use_async),
+            ["POST"],
+        )
         self._add_url("_reload-hash", self.serve_reload_hash)
         self._add_url("_favicon.ico", self.server_factory._serve_default_favicon)
         self.server_factory.setup_index(self.server, self)
@@ -759,7 +770,6 @@ def _setup_routes(self):
                 hook.data["methods"],
             )
 
-
     def setup_apis(self):
         """
         Register API endpoints for all callbacks defined using `dash.callback`.
@@ -1368,7 +1378,9 @@ def _initialize_context(self, body, adapter):
             {"prop_id": x, "value": g.input_values.get(x)}
             for x in body.get("changedPropIds", [])
         ]
-        g.dash_response = self.server_factory.make_response(mimetype="application/json", data=None)
+        g.dash_response = self.server_factory.make_response(
+            mimetype="application/json", data=None
+        )
         g.cookies = dict(adapter.get_cookies())
         g.headers = dict(adapter.get_headers())
         g.path = adapter.get_full_path()
@@ -2004,12 +2016,14 @@ def enable_dev_tools(
                     def _wrap_errors(error):
                         tb = _get_traceback(secret, error)
                         return tb, 500
+
                 elif hasattr(self.server, "exception_handler"):
                     # FastAPI
                     @self.server.exception_handler(Exception)
                     async def _wrap_errors(request, error):
                         tb = _get_traceback(secret, error)
                         from fastapi.responses import PlainTextResponse
+
                         return PlainTextResponse(tb, status_code=500)
 
         if debug and dev_tools.ui:
@@ -2325,15 +2339,16 @@ def verify_url_part(served_part, url_part, part_name):
                 server_url=jupyter_server_url,
             )
         else:
-            self.server_factory.run(self.server, host=host, port=port, debug=debug, **flask_run_options)
+            self.server_factory.run(
+                self.server, host=host, port=port, debug=debug, **flask_run_options
+            )
 
     def enable_pages(self) -> None:
         if not self.use_pages:
             return
         if self.pages_folder:
             _import_layouts_from_pages(self.config.pages_folder)
 
-
         def router():
             if self._got_first_request["pages"]:
                 return
@@ -2490,5 +2505,6 @@ def update(pathname_, search_, **states):
             )
 
         self.server_factory.before_request(self.server, router)
+
     def __call__(self, *args, **kwargs):
         return self.server_factory.__call__(self.server, *args, **kwargs)

dash/server_factories/__init__.py

@@ -3,8 +3,10 @@
 
 _request_adapter_var = contextvars.ContextVar("request_adapter")
 
+
 def set_request_adapter(adapter):
     _request_adapter_var.set(adapter)
 
+
 def get_request_adapter():
     return _request_adapter_var.get()

dash/server_factories/base_factory.py

@@ -1,5 +1,6 @@
 from abc import ABC, abstractmethod
 
+
 class BaseServerFactory(ABC):
     def __call__(self, server, *args, **kwargs):
         # Default: WSGI
@@ -10,7 +11,9 @@ def create_app(self, name="__main__", config=None):
         pass
 
     @abstractmethod
-    def register_assets_blueprint(self, app, blueprint_name, assets_url_path, assets_folder):
+    def register_assets_blueprint(
+        self, app, blueprint_name, assets_url_path, assets_folder
+    ):
         pass
 
     @abstractmethod
@@ -44,4 +47,3 @@ def jsonify(self, obj):
     @abstractmethod
     def get_request_adapter(self):
         pass
-

dash/server_factories/fastapi_factory.py

@@ -10,29 +10,32 @@
 from contextvars import copy_context
 import importlib.util
 
+
 class FastAPIServerFactory(BaseServerFactory):
     def __call__(self, server, *args, **kwargs):
         # ASGI: (scope, receive, send)
-        if (
-            len(args) == 3
-            and isinstance(args[0], dict)
-            and "type" in args[0]
-        ):
+        if len(args) == 3 and isinstance(args[0], dict) and "type" in args[0]:
             return server(*args, **kwargs)
         raise TypeError("FastAPI app must be called with (scope, receive, send)")
 
-
     def create_app(self, name="__main__", config=None):
         app = FastAPI()
         if config:
             for key, value in config.items():
                 setattr(app.state, key, value)
         return app
 
-    def register_assets_blueprint(self, app, blueprint_name, assets_url_path, assets_folder):
+    def register_assets_blueprint(
+        self, app, blueprint_name, assets_url_path, assets_folder
+    ):
         from fastapi.staticfiles import StaticFiles
+
         try:
-            app.mount(assets_url_path, StaticFiles(directory=assets_folder), name=blueprint_name)
+            app.mount(
+                assets_url_path,
+                StaticFiles(directory=assets_folder),
+                name=blueprint_name,
+            )
         except RuntimeError:
             # directory doesnt exist
             pass
@@ -43,7 +46,9 @@ async def _handle_error(request: Request, exc: PreventUpdate):
             return Response(status_code=204)
 
         @app.exception_handler(InvalidResourceError)
-        async def _invalid_resources_handler(request: Request, exc: InvalidResourceError):
+        async def _invalid_resources_handler(
+            request: Request, exc: InvalidResourceError
+        ):
             return Response(content=exc.args[0], status_code=404)
 
     def _html_response_wrapper(self, view_func):
@@ -60,6 +65,7 @@ async def index(request: Request):
             set_request_adapter(adapter)
             adapter.set_request(request)
             return Response(content=dash_app.render_index(), media_type="text/html")
+
         self.add_url_rule(app, "/", index, endpoint="index", methods=["GET"])
 
     def setup_catchall(self, app, dash_app):
@@ -73,17 +79,25 @@ async def catchall(path: str, request: Request):
                 adapter.set_request(request)
                 return Response(content=dash_app.render_index(), media_type="text/html")
 
-            self.add_url_rule(app, "/{path:path}", catchall, endpoint="catchall", methods=["GET"])
+            self.add_url_rule(
+                app, "/{path:path}", catchall, endpoint="catchall", methods=["GET"]
+            )
 
-        pass # catchall needs to be last to not override other routes
+        pass  # catchall needs to be last to not override other routes
 
     def add_url_rule(self, app, rule, view_func, endpoint=None, methods=None):
         if rule == "":
             rule = "/"
         if isinstance(view_func, str):
             # Wrap string or sync function to async FastAPI handler
             view_func = self._html_response_wrapper(view_func)
-        app.add_api_route(rule, view_func, methods=methods or ["GET"], name=endpoint, include_in_schema=False)
+        app.add_api_route(
+            rule,
+            view_func,
+            methods=methods or ["GET"],
+            name=endpoint,
+            include_in_schema=False,
+        )
 
     def before_request(self, app, func):
         # FastAPI does not have before_request, but we can use middleware
@@ -102,7 +116,13 @@ def run(self, app, host, port, debug, **kwargs):
             # Dynamically determine the module name from the file path
             file_path = frame.filename
             module_name = importlib.util.spec_from_file_location("app", file_path).name
-            uvicorn.run(f"{module_name}:app.server", host=host, port=port, reload=reload, **kwargs)
+            uvicorn.run(
+                f"{module_name}:app.server",
+                host=host,
+                port=port,
+                reload=reload,
+                **kwargs,
+            )
         else:
             uvicorn.run(app, host=host, port=port, reload=reload, **kwargs)
 
@@ -122,6 +142,7 @@ def get_request_adapter(self):
 
     def _make_before_middleware(self, func):
         pass
+
         async def middleware(request, call_next):
             if func is not None:
                 if inspect.iscoroutinefunction(func):
@@ -135,13 +156,17 @@ async def middleware(request, call_next):
 
     def _make_after_middleware(self, func):
         pass
+
         async def middleware(request, call_next):
             response = await call_next(request)
             await func()
             return response
+
         return middleware
 
-    def serve_component_suites(self, dash_app, package_name, fingerprinted_path, request):
+    def serve_component_suites(
+        self, dash_app, package_name, fingerprinted_path, request
+    ):
         import sys
         import mimetypes
         import pkgutil
@@ -162,12 +187,14 @@ def serve_component_suites(self, dash_app, package_name, fingerprinted_path, req
         )
         data = pkgutil.get_data(package_name, path_in_pkg)
         from starlette.responses import Response as StarletteResponse
+
         headers = {}
         if has_fingerprint:
             headers["Cache-Control"] = "public, max-age=31536000"
             return StarletteResponse(content=data, media_type=mimetype, headers=headers)
         else:
             import hashlib
+
             etag = hashlib.md5(data).hexdigest() if data else ""
             headers["ETag"] = etag
             if request.headers.get("if-none-match") == etag:
@@ -176,8 +203,11 @@ def serve_component_suites(self, dash_app, package_name, fingerprinted_path, req
 
     def setup_component_suites(self, app, dash_app):
         from fastapi import Request
+
         async def serve(request: Request, package_name: str, fingerprinted_path: str):
-            return self.serve_component_suites(dash_app, package_name, fingerprinted_path, request)
+            return self.serve_component_suites(
+                dash_app, package_name, fingerprinted_path, request
+            )
 
         self.add_url_rule(
             app,
@@ -206,10 +236,10 @@ async def _dispatch(request: Request):
 
     def _serve_default_favicon(self):
         return Response(
-            content=pkgutil.get_data("dash", "favicon.ico"),
-            media_type="image/x-icon"
+            content=pkgutil.get_data("dash", "favicon.ico"), media_type="image/x-icon"
         )
 
+
 class FastAPIRequestAdapter:
     def __init__(self):
         self._request = None
@@ -224,7 +254,9 @@ async def get_json(self):
         return await self._request.json()
 
     def is_json(self):
-        return self._request.headers.get("content-type", "").startswith("application/json")
+        return self._request.headers.get("content-type", "").startswith(
+            "application/json"
+        )
 
     def get_cookies(self, request=None):
         return self._request.cookies