@@ -347,7 +347,7 @@ def set_connection(self):
347347 "role" : credentials .get ("role" ),
348348 "schema" : credentials .get ("schema" ),
349349 }
350- self .threads = rendered_credentials .get ("threads" )
350+ self .threads = credentials .get ("threads" )
351351 self .requires_upper = True
352352 elif conn_type == "bigquery" :
353353 method = credentials .get ("method" )
@@ -360,7 +360,7 @@ def set_connection(self):
360360 "project" : credentials .get ("project" ),
361361 "dataset" : credentials .get ("dataset" ),
362362 }
363- self .threads = rendered_credentials .get ("threads" )
363+ self .threads = credentials .get ("threads" )
364364 elif conn_type == "duckdb" :
365365 conn_info = {
366366 "driver" : conn_type ,
@@ -377,7 +377,7 @@ def set_connection(self):
377377 "port" : credentials .get ("port" ),
378378 "dbname" : credentials .get ("dbname" ),
379379 }
380- self .threads = rendered_credentials .get ("threads" )
380+ self .threads = credentials .get ("threads" )
381381 elif conn_type == "databricks" :
382382 conn_info = {
383383 "driver" : conn_type ,
@@ -387,7 +387,7 @@ def set_connection(self):
387387 "schema" : credentials .get ("schema" ),
388388 "access_token" : credentials .get ("token" ),
389389 }
390- self .threads = rendered_credentials .get ("threads" )
390+ self .threads = credentials .get ("threads" )
391391 elif conn_type == "postgres" :
392392 conn_info = {
393393 "driver" : "postgresql" ,
@@ -397,7 +397,7 @@ def set_connection(self):
397397 "port" : credentials .get ("port" ),
398398 "dbname" : credentials .get ("dbname" ) or credentials .get ("database" ),
399399 }
400- self .threads = rendered_credentials .get ("threads" )
400+ self .threads = credentials .get ("threads" )
401401 else :
402402 raise NotImplementedError (f"Provider { conn_type } is not yet supported for dbt diffs" )
403403
0 commit comments