@@ -65,9 +65,9 @@ def dbt_diff(
65
65
elif is_cloud :
66
66
rich .print (
67
67
"[red]"
68
- + "." .join (diff_vars .dev_path )
69
- + " <> "
70
68
+ "." .join (diff_vars .prod_path )
69
+ + " <> "
70
+ + "." .join (diff_vars .dev_path )
71
71
+ "[/] \n "
72
72
+ "Skipped due to missing primary-key tag\n "
73
73
)
@@ -77,9 +77,9 @@ def dbt_diff(
77
77
elif not is_cloud :
78
78
rich .print (
79
79
"[red]"
80
- + "." .join (diff_vars .dev_path )
81
- + " <> "
82
80
+ "." .join (diff_vars .prod_path )
81
+ + " <> "
82
+ + "." .join (diff_vars .dev_path )
83
83
+ "[/] \n "
84
84
+ "Skipped due to missing primary-key tag or multi-column primary-key (unsupported for non --cloud diffs)\n "
85
85
)
@@ -129,9 +129,9 @@ def _local_diff(diff_vars: DiffVars) -> None:
129
129
logging .info (ex )
130
130
rich .print (
131
131
"[red]"
132
- + dev_qualified_string
133
- + " <> "
134
132
+ prod_qualified_string
133
+ + " <> "
134
+ + dev_qualified_string
135
135
+ "[/] \n "
136
136
+ column_diffs_str
137
137
+ "[green]New model or no access to prod table.[/] \n "
@@ -156,9 +156,9 @@ def _local_diff(diff_vars: DiffVars) -> None:
156
156
if list (diff ):
157
157
rich .print (
158
158
"[red]"
159
- + dev_qualified_string
160
- + " <> "
161
159
+ prod_qualified_string
160
+ + " <> "
161
+ + dev_qualified_string
162
162
+ "[/] \n "
163
163
+ column_diffs_str
164
164
+ diff .get_stats_string (is_dbt = True )
@@ -167,9 +167,9 @@ def _local_diff(diff_vars: DiffVars) -> None:
167
167
else :
168
168
rich .print (
169
169
"[red]"
170
- + dev_qualified_string
171
- + " <> "
172
170
+ prod_qualified_string
171
+ + " <> "
172
+ + dev_qualified_string
173
173
+ "[/] \n "
174
174
+ column_diffs_str
175
175
+ "[green]No row differences[/] \n "
@@ -191,8 +191,8 @@ def _cloud_diff(diff_vars: DiffVars) -> None:
191
191
payload = {
192
192
"data_source1_id" : diff_vars .datasource_id ,
193
193
"data_source2_id" : diff_vars .datasource_id ,
194
- "table1" : diff_vars .dev_path ,
195
- "table2" : diff_vars .prod_path ,
194
+ "table1" : diff_vars .prod_path ,
195
+ "table2" : diff_vars .dev_path ,
196
196
"pk_columns" : diff_vars .primary_keys ,
197
197
}
198
198
@@ -216,9 +216,9 @@ def _cloud_diff(diff_vars: DiffVars) -> None:
216
216
diff_url = f"https://app.datafold.com/datadiffs/{ diff_id } /overview"
217
217
rich .print (
218
218
"[red]"
219
- + "." .join (diff_vars .dev_path )
220
- + " <> "
221
219
+ "." .join (diff_vars .prod_path )
220
+ + " <> "
221
+ + "." .join (diff_vars .dev_path )
222
222
+ "[/] \n Diff in progress: \n "
223
223
+ diff_url
224
224
+ "\n "
0 commit comments