diff --git a/dbt_server/services/dbt_service.py b/dbt_server/services/dbt_service.py index 62f145a..20144e4 100644 --- a/dbt_server/services/dbt_service.py +++ b/dbt_server/services/dbt_service.py @@ -76,19 +76,17 @@ class Args(BaseModel): profiles_dir = os.path.expanduser("~/.dbt") RuntimeArgs = namedtuple( - 'RuntimeArgs', 'project_dir profiles_dir single_threaded profile_name which' + 'RuntimeArgs', 'project_dir profiles_dir single_threaded which' ) # Construct a phony config config = UnsetProfileConfig.from_args(RuntimeArgs( - project_path, profiles_dir, True, "user", "deps" + project_path, profiles_dir, True, "deps" )) # Clear previously registered adapters-- # this fixes cacheing behavior on the dbt-server flags.set_from_args("", config) dbt.adapters.factory.reset_adapters() - # Load the relevant adapter - dbt.adapters.factory.register_adapter(config) # Set invocation id dbt.events.functions.set_invocation_id() task = DepsTask(Args(), config) diff --git a/dbt_server/views.py b/dbt_server/views.py index 2b6202d..c76d854 100644 --- a/dbt_server/views.py +++ b/dbt_server/views.py @@ -222,6 +222,7 @@ async def push_unparsed_manifest(args: PushProjectArgs): logger.info("Installing deps") path = filesystem_service.get_root_path(state_id) dbt_service.dbt_deps(path) + logger.info("Done installing deps") # Write messagepack repr to disk # Return a key that the client can use to operate on it?