Reformatted files using black and isort

Author: mdesmet

setup.py

@@ -16,7 +16,7 @@
 import re
 import textwrap
 
-from setuptools import setup, find_packages
+from setuptools import find_packages, setup
 
 _version_re = re.compile(r"__version__\s+=\s+(.*)")
 
@@ -75,7 +75,7 @@
         "Programming Language :: Python :: Implementation :: PyPy",
         "Topic :: Database :: Front-Ends",
     ],
-    python_requires='>=3.7',
+    python_requires=">=3.7",
     install_requires=["pytz", "requests"],
     extras_require={
         "all": all_require,

tests/integration/conftest.py

@@ -18,11 +18,11 @@
 from uuid import uuid4
 
 import click
-import trino.logging
 import pytest
-from trino.client import TrinoQuery, TrinoRequest, ClientSession
-from trino.constants import DEFAULT_PORT
 
+import trino.logging
+from trino.client import ClientSession, TrinoQuery, TrinoRequest
+from trino.constants import DEFAULT_PORT
 
 logger = trino.logging.get_logger(__name__)
 
@@ -64,13 +64,7 @@ def start_trino(image_tag=None):
 
 
 def wait_for_trino_workers(host, port, timeout=180):
-    request = TrinoRequest(
-        host=host,
-        port=port,
-        client_session=ClientSession(
-            user="test_fixture"
-        )
-    )
+    request = TrinoRequest(host=host, port=port, client_session=ClientSession(user="test_fixture"))
     sql = "SELECT state FROM system.runtime.nodes"
     t0 = time.time()
     while True:
@@ -116,9 +110,7 @@ def start_trino_and_wait(image_tag=None):
     if host:
         port = os.environ.get("TRINO_RUNNING_PORT", DEFAULT_PORT)
     else:
-        container_id, proc, host, port = start_local_trino_server(
-            image_tag
-        )
+        container_id, proc, host, port = start_local_trino_server(image_tag)
 
     print("trino.server.hostname {}".format(host))
     print("trino.server.port {}".format(port))
@@ -135,9 +127,7 @@ def stop_trino(container_id, proc):
 
 def find_images(name):
     assert name
-    output = subprocess.check_output(
-        ["docker", "images", "--format", "{{.Repository}}:{{.Tag}}", name]
-    )
+    output = subprocess.check_output(["docker", "images", "--format", "{{.Repository}}:{{.Tag}}", name])
     return [line.decode() for line in output.splitlines()]
 
 
@@ -167,9 +157,7 @@ def cli():
     pass
 
 
-@click.option(
-    "--cache/--no-cache", default=True, help="enable/disable Docker build cache"
-)
+@click.option("--cache/--no-cache", default=True, help="enable/disable Docker build cache")
 @click.command()
 def trino_server():
     container_id, _, _, _ = start_trino_and_wait()
@@ -198,19 +186,14 @@ def trino_cli(container_id=None):
 
 @cli.command("list")
 def list_():
-    subprocess.check_call(
-        ["docker", "ps", "--filter", "name=trino-python-client-tests-"]
-    )
+    subprocess.check_call(["docker", "ps", "--filter", "name=trino-python-client-tests-"])
 
 
 @cli.command()
 def clean():
     cmd = (
-        "docker ps "
-        "--filter name=trino-python-client-tests- "
-        "--format={{.Names}} | "
-        "xargs -n 1 docker kill"  # NOQA deliberate additional indent
-    )
+        "docker ps " "--filter name=trino-python-client-tests- " "--format={{.Names}} | " "xargs -n 1 docker kill"
+    )  # NOQA deliberate additional indent
     subprocess.check_output(cmd, shell=True)