rebuild and retest

Author: JohnMount

build/lib/data_algebra/BigQuery.py

@@ -208,9 +208,7 @@ def example_handle():
     assert _have_bigquery
     credential_file = "/Users/johnmount/big_query/big_query_jm.json"
     # assert os.path.isfile(credential_file)
-    os.environ[
-        "GOOGLE_APPLICATION_CREDENTIALS"
-    ] = credential_file
+    os.environ["GOOGLE_APPLICATION_CREDENTIALS"] = credential_file
     # os.environ["GOOGLE_APPLICATION_CREDENTIALS"]  # trigger key error if not present
     try:
         data_catalog = "data-algebra-test"

build/lib/data_algebra/PostgreSQL.py

@@ -20,7 +20,7 @@
 
 class PostgreSQLModel(data_algebra.db_model.DBModel):
     """A model of how SQL should be generated for PostgreSQL.
-       Assuming we are using a sqlalhemy engine as our connection
+       Assuming we are using a sqlalchemy engine as our connection
     """
 
     def __init__(self):

build/lib/data_algebra/SQLite.py

@@ -58,9 +58,9 @@ def __init__(self):
             identifier_quote='"',
             string_quote="'",
             sql_formatters=SQLite_formatters,
-            on_joiner='AND',
-            union_all_term_start='',
-            union_all_term_end='',
+            on_joiner="AND",
+            union_all_term_start="",
+            union_all_term_end="",
         )
 
     def prepare_connection(self, conn):

build/lib/data_algebra/SparkSQL.py

@@ -70,9 +70,9 @@ def __init__(self, *, spark_context, spark_session):
         self.spark_session = spark_session
 
     def close(self):
-        if self.spark_conext is not None:
-            self.spark_conext.stop()  # probably only for local demos
-            self.spark_conext = None
+        if self.spark_context is not None:
+            self.spark_context.stop()  # probably only for local demos
+            self.spark_context = None
         if self.spark_session is not None:
             self.spark_session = None
 

build/lib/data_algebra/data_model.py

@@ -86,7 +86,7 @@ def _type_safe_is_in(a, b):
         type_a = data_algebra.util.guess_carried_scalar_type(a)
         type_b = {data_algebra.util.map_type_to_canonical(type(v)) for v in b}
         if len(type_b) > 1:
-            raise TypeError(f'multiple types in set: {type_b}')
+            raise TypeError(f"multiple types in set: {type_b}")
         type_b = list(type_b)[0]
         if not data_algebra.util.compatible_types([type_a, type_b]):
             raise TypeError(f"can't check for an {type_a} in a set of {type_b}'s")