reformat rebuild

Author: JohnMount

README.md

@@ -15,7 +15,7 @@ can perform data engineering in [`Pandas`](https://pandas.pydata.org) and genera
 Install `data_algebra` with either of:
 
   * `pip install data_algebra`
-  * `pip install https://github.com/WinVector/data_algebra/raw/master/dist/data_algebra-0.1.8.tar.gz`
+  * `pip install https://github.com/WinVector/data_algebra/raw/master/dist/data_algebra-0.1.9.tar.gz`
 
 # Announcement
 

build/lib/data_algebra/SparkSQL.py

@@ -12,7 +12,7 @@ class SparkSQLModel(data_algebra.db_model.DBModel):
     def __init__(self):
         data_algebra.db_model.DBModel.__init__(
             self,
-            identifier_quote='`',
+            identifier_quote="`",
             string_quote='"',
             sql_formatters=SparkSQL_formatters,
         )

build/lib/data_algebra/__init__.py

@@ -57,7 +57,7 @@
 
 
 __docformat__ = "restructuredtext"
-__version__ = "0.1.8"
+__version__ = "0.1.9"
 
 __doc__ = """
 `data_algebra`<https://github.com/WinVector/data_algebra> is a piped data wrangling system

build/lib/data_algebra/cdata.py

@@ -29,8 +29,9 @@ def table_is_keyed_by_columns(table, column_names):
 
 
 class RecordSpecification:
-    def __init__(self, control_table, *,
-                 record_keys=None, control_table_keys=None, strict=False):
+    def __init__(
+        self, control_table, *, record_keys=None, control_table_keys=None, strict=False
+    ):
         control_table = data_algebra.data_types.convert_to_pandas_dataframe(
             control_table, "control_table"
         )
@@ -50,14 +51,18 @@ def __init__(self, control_table, *,
         self.control_table_keys = [k for k in control_table_keys]
         unknown = set(self.control_table_keys) - set(control_table.columns)
         if len(unknown) > 0:
-            raise ValueError("control table keys that are not in the control table: " + str(unknown))
+            raise ValueError(
+                "control table keys that are not in the control table: " + str(unknown)
+            )
         confused = set(record_keys).intersection(control_table_keys)
         if len(confused) > 0:
             raise ValueError(
                 "columns common to record_keys and control_table_keys: " + str(confused)
             )
         if strict:
-            if not table_is_keyed_by_columns(self.control_table, self.control_table_keys):
+            if not table_is_keyed_by_columns(
+                self.control_table, self.control_table_keys
+            ):
                 raise ValueError("control table wasn't keyed by control table keys")
         self.block_columns = self.record_keys + [c for c in self.control_table.columns]
         cvs = []

build/lib/data_algebra/cdata_impl.py

@@ -34,9 +34,13 @@ def __init__(self, *, blocks_in=None, blocks_out=None, strict=False):
                 raise ValueError("unknown outgoing content_keys" + str(unknown))
             if strict:
                 if set(blocks_in.record_keys) != set(blocks_out.record_keys):
-                    raise ValueError("record keys must match when using both blocks in and blocks out")
+                    raise ValueError(
+                        "record keys must match when using both blocks in and blocks out"
+                    )
                 if set(blocks_in.content_keys) != set(blocks_out.content_keys):
-                    raise ValueError("content keys must match when using both blocks in and blocks out")
+                    raise ValueError(
+                        "content keys must match when using both blocks in and blocks out"
+                    )
         self.blocks_in = blocks_in
         self.blocks_out = blocks_out
         if self.blocks_in is not None:
@@ -113,7 +117,9 @@ def transform(
                 raise KeyError("missing required columns: " + str(missing_cols))
             if check_blocks_out_keying:
                 # table should be keyed by record_keys
-                if not data_algebra.cdata.table_is_keyed_by_columns(X, self.blocks_out.record_keys):
+                if not data_algebra.cdata.table_is_keyed_by_columns(
+                    X, self.blocks_out.record_keys
+                ):
                     raise ValueError("table is not keyed by blocks_out.record_keys")
             # convert to block records
             with sqlite3.connect(":memory:") as conn:
@@ -159,24 +165,30 @@ def compose(self, other):
                     blocks_out=data_algebra.cdata.RecordSpecification(
                         control_table=rso,
                         record_keys=rk,
-                        control_table_keys=s2.blocks_out.control_table_keys))
+                        control_table_keys=s2.blocks_out.control_table_keys,
+                    )
+                )
         else:
             if out.shape[0] < 2:
                 return RecordMap(
                     blocks_in=data_algebra.cdata.RecordSpecification(
                         control_table=rsi,
                         record_keys=rk,
-                        control_table_keys=s1.blocks_in.control_table_keys))
+                        control_table_keys=s1.blocks_in.control_table_keys,
+                    )
+                )
             else:
                 return RecordMap(
                     blocks_in=data_algebra.cdata.RecordSpecification(
                         control_table=rsi,
                         record_keys=rk,
-                        control_table_keys=s1.blocks_in.control_table_keys),
+                        control_table_keys=s1.blocks_in.control_table_keys,
+                    ),
                     blocks_out=data_algebra.cdata.RecordSpecification(
                         control_table=rso,
                         record_keys=rk,
-                        control_table_keys=s2.blocks_out.control_table_keys)
+                        control_table_keys=s2.blocks_out.control_table_keys,
+                    ),
                 )
 
     def __rrshift__(self, other):  # override other >> self

build/lib/data_algebra/dask_model.py

@@ -1,4 +1,3 @@
-
 import data_algebra
 import data_algebra.data_ops
 import data_algebra.pandas_model