Skip to content
This repository was archived by the owner on May 17, 2024. It is now read-only.

Commit 802d0d3

Browse files
committed
refactor with black
1 parent 946eb48 commit 802d0d3

4 files changed

Lines changed: 4 additions & 3 deletions

File tree

data_diff/dbt.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -232,7 +232,7 @@ def _cloud_diff(diff_vars: DiffVars) -> None:
232232
webbrowser.open(f"{datafold_host}/login?next={datafold_host}/users/me")
233233
return
234234
else:
235-
raise ValueError('Cannot diff because the API key is not provided')
235+
raise ValueError("Cannot diff because the API key is not provided")
236236

237237
if diff_vars.datasource_id is None:
238238
raise ValueError(

data_diff/diff_tables.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -153,7 +153,6 @@ def get_stats_string(self, is_dbt: bool = False):
153153
string_output += f"\n{k}: {v}"
154154

155155
else:
156-
157156
string_output = ""
158157
string_output += f"{diff_stats.table1_count} rows in table A\n"
159158
string_output += f"{diff_stats.table2_count} rows in table B\n"

data_diff/joindiff_tables.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -201,7 +201,6 @@ def _diff_segments(
201201
if self.materialize_to_table
202202
else None,
203203
):
204-
205204
assert len(a_cols) == len(b_cols)
206205
logger.debug("Querying for different rows")
207206
diff = db.query(diff_rows, list)

data_diff/tracking.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -56,12 +56,15 @@ def set_entrypoint_name(s):
5656
global entrypoint_name
5757
entrypoint_name = s
5858

59+
5960
dbt_user_id = None
6061

62+
6163
def set_dbt_user_id(s):
6264
global dbt_user_id
6365
dbt_user_id = s
6466

67+
6568
def get_anonymous_id():
6669
global g_anonymous_id
6770
if g_anonymous_id is None:

0 commit comments

Comments
 (0)