Whitespace

Author: hoijnet

terminusdb_client/schema/schema.py

@@ -86,7 +86,11 @@ def _check_cycling(class_obj: "TerminusClass"):
         mro_names = [obj.__name__ for obj in class_obj.__mro__]
         for prop_type in class_obj._annotations.values():
             # Handle both string annotations and type objects
-            type_name = prop_type if isinstance(prop_type, str) else getattr(prop_type, '__name__', str(prop_type))
+            type_name = (
+                prop_type
+                if isinstance(prop_type, str)
+                else getattr(prop_type, "__name__", str(prop_type))
+            )
             if type_name in mro_names:
                 raise RecursionError(f"Embbding {prop_type} cause recursions.")
 

terminusdb_client/scripts/scripts.py

@@ -19,7 +19,9 @@
 from ..woqlschema.woql_schema import WOQLSchema
 
 
-def _df_to_schema(class_name, df, np, embedded=None, id_col=None, na_mode=None, keys=None):
+def _df_to_schema(
+    class_name, df, np, embedded=None, id_col=None, na_mode=None, keys=None
+):
     """Convert a pandas DataFrame to a TerminusDB schema class definition.
 
     Args:
@@ -41,9 +43,7 @@ def _df_to_schema(class_name, df, np, embedded=None, id_col=None, na_mode=None,
 
     class_dict = {"@type": "Class", "@id": class_name}
     np_to_builtin = {
-        v: getattr(builtins, k)
-        for k, v in np.sctypeDict.items()
-        if k in vars(builtins)
+        v: getattr(builtins, k) for k, v in np.sctypeDict.items() if k in vars(builtins)
     }
     np_to_builtin[np.datetime64] = dt.datetime
 
@@ -512,7 +512,15 @@ def importcsv(
                 converted_col = col.lower().replace(" ", "_").replace(".", "_")
                 df.rename(columns={col: converted_col}, inplace=True)
             if not has_schema:
-                class_dict = _df_to_schema(class_name, df, np, embedded=embedded, id_col=id_, na_mode=na, keys=keys)
+                class_dict = _df_to_schema(
+                    class_name,
+                    df,
+                    np,
+                    embedded=embedded,
+                    id_col=id_,
+                    na_mode=na,
+                    keys=keys,
+                )
                 if message is None:
                     schema_msg = f"Schema object insert/ update with {csv_file} by Python client."
                 else:

terminusdb_client/woqldataframe/woqlDataframe.py

@@ -75,7 +75,9 @@ def _embed_obj(df, maxdep, pd, keepid, all_existing_class, class_obj, client):
     ):
         return finish_df
     else:
-        return _embed_obj(finish_df, maxdep - 1, pd, keepid, all_existing_class, class_obj, client)
+        return _embed_obj(
+            finish_df, maxdep - 1, pd, keepid, all_existing_class, class_obj, client
+        )
 
 
 def result_to_df(all_records, keepid=False, max_embed_dep=0, client=None):
@@ -111,5 +113,7 @@ def result_to_df(all_records, keepid=False, max_embed_dep=0, client=None):
             raise InterfaceError(
                 f"{class_obj} not found in database ({client.db}) schema.'"
             )
-        df = _embed_obj(df, max_embed_dep, pd, keepid, all_existing_class, class_obj, client)
+        df = _embed_obj(
+            df, max_embed_dep, pd, keepid, all_existing_class, class_obj, client
+        )
     return df