Reformat with black

Author: erezsh

data_diff/__main__.py

@@ -50,7 +50,7 @@
 @click.option("--max-age", default=None, help="Considers only rows younger than specified. See --min-age.")
 @click.option("-s", "--stats", is_flag=True, help="Print stats instead of a detailed diff")
 @click.option("-d", "--debug", is_flag=True, help="Print debug info")
-@click.option("--json", 'json_output', is_flag=True, help="Print JSONL output for machine readability")
+@click.option("--json", "json_output", is_flag=True, help="Print JSONL output for machine readability")
 @click.option("-v", "--verbose", is_flag=True, help="Print extra info")
 @click.option("-i", "--interactive", is_flag=True, help="Confirm queries, implies --debug")
 @click.option("--keep-column-case", is_flag=True, help="Don't use the schema to fix the case of given column names.")

data_diff/databases/base.py

@@ -34,9 +34,6 @@ def _inner():
     return dec
 
 
-
-
-
 class ConnectError(Exception):
     pass
 
@@ -57,7 +54,6 @@ def _query_conn(conn, sql_code: str) -> list:
         return c.fetchall()
 
 
-
 class Database(AbstractDatabase):
     """Base abstract class for databases.
 
@@ -139,7 +135,9 @@ def _parse_type(
 
             elif issubclass(cls, Decimal):
                 if numeric_scale is None:
-                    raise ValueError(f"{self.name}: Unexpected numeric_scale is NULL, for column {col_name} of type {type_repr}.")
+                    raise ValueError(
+                        f"{self.name}: Unexpected numeric_scale is NULL, for column {col_name} of type {type_repr}."
+                    )
                 return cls(precision=numeric_scale)
 
             assert issubclass(cls, Float)
@@ -235,4 +233,3 @@ def close(self):
 DEFAULT_NUMERIC_PRECISION = 24
 
 TIMESTAMP_PRECISION_POS = 20  # len("2022-06-03 12:24:35.") == 20
-

data_diff/databases/bigquery.py

@@ -2,6 +2,7 @@
 from .base import Database, import_helper, parse_table_name, ConnectError
 from .base import TIMESTAMP_PRECISION_POS
 
+
 @import_helper(text="Please install BigQuery and configure your google-cloud access.")
 def import_bigquery():
     from google.cloud import bigquery

data_diff/databases/connect.py

@@ -13,6 +13,7 @@
 from .redshift import Redshift
 from .presto import Presto
 
+
 @dataclass
 class MatchUriPath:
     database_cls: Type[Database]

data_diff/databases/database_types.py

@@ -152,7 +152,6 @@ def normalize_value_by_type(self, value: str, coltype: ColType) -> str:
             return self.normalize_number(value, coltype)
         return self.to_string(f"{value}")
 
-
     def _normalize_table_path(self, path: DbPath) -> DbPath:
         ...
 

data_diff/databases/mssql.py

@@ -23,4 +23,3 @@ def md5_to_int(self, s: str) -> str:
 
     def to_string(self, s: str):
         return f"CONVERT(varchar, {s})"
-

data_diff/databases/mysql.py

@@ -2,6 +2,7 @@
 from .base import ThreadedDatabase, import_helper, ConnectError
 from .base import MD5_HEXDIGITS, CHECKSUM_HEXDIGITS, TIMESTAMP_PRECISION_POS
 
+
 @import_helper("mysql")
 def import_mysql():
     import mysql.connector

data_diff/databases/oracle.py

@@ -4,6 +4,7 @@
 from .base import ThreadedDatabase, import_helper, ConnectError, QueryError
 from .base import DEFAULT_DATETIME_PRECISION, DEFAULT_NUMERIC_PRECISION
 
+
 @import_helper("oracle")
 def import_oracle():
     import cx_Oracle

data_diff/databases/postgresql.py

@@ -2,6 +2,7 @@
 from .base import ThreadedDatabase, import_helper, ConnectError
 from .base import MD5_HEXDIGITS, CHECKSUM_HEXDIGITS, _CHECKSUM_BITSIZE, TIMESTAMP_PRECISION_POS
 
+
 @import_helper("postgresql")
 def import_postgresql():
     import psycopg2
@@ -11,7 +12,6 @@ def import_postgresql():
     return psycopg2
 
 
-
 class PostgreSQL(ThreadedDatabase):
     DATETIME_TYPES = {
         "timestamp with time zone": TimestampTZ,

data_diff/databases/presto.py

@@ -2,7 +2,14 @@
 
 from .database_types import *
 from .base import Database, import_helper, _query_conn
-from .base import MD5_HEXDIGITS, CHECKSUM_HEXDIGITS, TIMESTAMP_PRECISION_POS, DEFAULT_DATETIME_PRECISION, DEFAULT_NUMERIC_PRECISION
+from .base import (
+    MD5_HEXDIGITS,
+    CHECKSUM_HEXDIGITS,
+    TIMESTAMP_PRECISION_POS,
+    DEFAULT_DATETIME_PRECISION,
+    DEFAULT_NUMERIC_PRECISION,
+)
+
 
 @import_helper("presto")
 def import_presto():