Run black.

Signed-off-by: Thomas Neidhart <thomas.neidhart@gmail.com>

Author: netomi

src/python_inspector/api.py

@@ -287,7 +287,7 @@ def resolve_dependencies(
         analyze_setup_py_insecurely=analyze_setup_py_insecurely,
         ignore_errors=ignore_errors,
         verbose=verbose,
-        printer=printer
+        printer=printer,
     )
 
     async def gather_pypi_data():
@@ -331,7 +331,7 @@ def resolve(
     analyze_setup_py_insecurely: bool = False,
     ignore_errors: bool = False,
     verbose: bool = False,
-    printer=print
+    printer=print,
 ):
     """
     Resolve dependencies given a ``direct_dependencies`` list of
@@ -359,7 +359,7 @@ def resolve(
         analyze_setup_py_insecurely=analyze_setup_py_insecurely,
         ignore_errors=ignore_errors,
         verbose=verbose,
-        printer=printer
+        printer=printer,
     )
 
     return resolved_dependencies, packages
@@ -375,7 +375,7 @@ def get_resolved_dependencies(
     analyze_setup_py_insecurely: bool = False,
     ignore_errors: bool = False,
     verbose: bool = False,
-    printer=print
+    printer=print,
 ) -> Tuple[List[Dict], List[str]]:
     """
     Return resolved dependencies of a ``requirements`` list of Requirement for
@@ -406,7 +406,9 @@ async def get_version_data(name: str):
         if verbose:
             printer(f"versions:")
 
-        return await asyncio.gather(*[get_version_data(requirement.name) for requirement in requirements])
+        return await asyncio.gather(
+            *[get_version_data(requirement.name) for requirement in requirements]
+        )
 
     asyncio.run(gather_version_data())
 
@@ -428,7 +430,9 @@ async def get_dependencies(requirement: Requirement):
         if verbose:
             printer(f"dependencies:")
 
-        return await asyncio.gather(*[get_dependencies(requirement) for requirement in requirements])
+        return await asyncio.gather(
+            *[get_dependencies(requirement) for requirement in requirements]
+        )
 
     asyncio.run(gather_dependencies())
 

src/python_inspector/dependencies.py

@@ -25,7 +25,9 @@
 TRACE = False
 
 
-def get_dependencies_from_requirements(requirements_file="requirements.txt") -> Iterable[DependentPackage]:
+def get_dependencies_from_requirements(
+    requirements_file="requirements.txt",
+) -> Iterable[DependentPackage]:
     """
     Yield DependentPackage for each requirement in a `requirement` file.
     """

src/python_inspector/package_data.py

@@ -45,6 +45,7 @@ async def get_pypi_data_from_purl(
     api_url = f"{base_path}/{name}/{version}/json"
 
     from python_inspector.utils import get_response_async
+
     response = await get_response_async(api_url)
     if not response:
         return None
@@ -56,7 +57,9 @@ async def get_pypi_data_from_purl(
     bug_tracking_url = get_pypi_bugtracker_url(project_urls)
     python_version = get_python_version_from_env_tag(python_version=environment.python_version)
     valid_distribution_urls = []
-    sdist_url = await get_sdist_download_url(purl=parsed_purl, repos=repos, python_version=python_version)
+    sdist_url = await get_sdist_download_url(
+        purl=parsed_purl, repos=repos, python_version=python_version
+    )
     if sdist_url:
         valid_distribution_urls.append(sdist_url)
 
@@ -65,16 +68,15 @@ async def get_pypi_data_from_purl(
     # if prefer_source is True then only source distribution is used
     # in case of no source distribution available then wheel is used
     if not valid_distribution_urls or not prefer_source:
-        wheel_urls = \
-            [
-                item
-                for item in await get_wheel_download_urls(
-                    purl=parsed_purl,
-                    repos=repos,
-                    environment=environment,
-                    python_version=python_version,
-                )
-            ]
+        wheel_urls = [
+            item
+            for item in await get_wheel_download_urls(
+                purl=parsed_purl,
+                repos=repos,
+                environment=environment,
+                python_version=python_version,
+            )
+        ]
         wheel_url = choose_single_wheel(wheel_urls)
         if wheel_url:
             valid_distribution_urls.insert(0, wheel_url)

src/python_inspector/resolution.py

@@ -472,7 +472,9 @@ async def fill_requirements_for_package(
             return dependencies
 
         if self.repos and self.environment:
-            dependencies.extend(await self._get_requirements_for_package_from_pypi_simple(candidate))
+            dependencies.extend(
+                await self._get_requirements_for_package_from_pypi_simple(candidate)
+            )
         else:
             dependencies.extend(await self._get_requirements_for_package_from_pypi_json_api(purl))
 

src/python_inspector/utils_pypi.py

@@ -1575,20 +1575,24 @@ async def get_package_version(
         """
         if not version:
             versions = list(
-                (await self._get_package_versions_map(
-                    name=name,
-                    verbose=verbose,
-                    echo_func=echo_func,
-                )).values()
+                (
+                    await self._get_package_versions_map(
+                        name=name,
+                        verbose=verbose,
+                        echo_func=echo_func,
+                    )
+                ).values()
             )
             # return the latest version
             return versions and versions[-1]
         else:
-            return (await self._get_package_versions_map(
-                name=name,
-                verbose=verbose,
-                echo_func=echo_func,
-            )).get(version)
+            return (
+                await self._get_package_versions_map(
+                    name=name,
+                    verbose=verbose,
+                    echo_func=echo_func,
+                )
+            ).get(version)
 
     async def fetch_links(
         self,
@@ -1795,9 +1799,7 @@ async def get_remote_file_content(
         auth = (credentials.get("login"), credentials.get("password"))
 
     async with aiohttp.ClientSession() as session:
-        async with session.get(url, allow_redirects=True,
-                               headers=headers,
-                               auth=auth) as response:
+        async with session.get(url, allow_redirects=True, headers=headers, auth=auth) as response:
             status = response.status
             if status != requests.codes.ok:  # NOQA
                 if status == 429 and _delay < 20: