format

Author: dlawin

data_diff/dbt.py

@@ -107,13 +107,7 @@ def dbt_diff(
 
         if diff_vars.primary_keys:
             if is_cloud:
-                diff_thread = run_as_daemon(
-                    _cloud_diff,
-                    diff_vars,
-                    datafold_host,
-                    url,
-                    api_key
-                )
+                diff_thread = run_as_daemon(_cloud_diff, diff_vars, datafold_host, url, api_key)
                 diff_threads.append(diff_thread)
             else:
                 _local_diff(diff_vars)
@@ -237,8 +231,7 @@ def _local_diff(diff_vars: DiffVars) -> None:
         )
 
 
-def _cloud_diff(diff_vars: DiffVars, datafold_host:str, url:str, api_key:str) -> None:
-
+def _cloud_diff(diff_vars: DiffVars, datafold_host: str, url: str, api_key: str) -> None:
     if diff_vars.datasource_id is None:
         raise ValueError(
             "Datasource ID not found, include it as a dbt variable in the dbt_project.yml. \nvars:\n data_diff:\n   datasource_id: 1234"
@@ -335,6 +328,7 @@ def _cloud_diff(diff_vars: DiffVars, datafold_host:str, url:str, api_key:str) ->
         if error:
             logger.error(error)
 
+
 def _setup_cloud_diff() -> tuple[str]:
     datafold_host = os.environ.get("DATAFOLD_HOST")
     if datafold_host is None:
@@ -353,7 +347,7 @@ def _setup_cloud_diff() -> tuple[str]:
         else:
             raise ValueError("Cannot diff because the API key is not provided")
 
-    return datafold_host,url,api_key
+    return datafold_host, url, api_key
 
 
 def _cloud_submit_diff(url, payload, headers) -> str: