From f2f8663eafb90cb9241fb71f44262eb9a3636945 Mon Sep 17 00:00:00 2001 From: Kyle Wigley Date: Thu, 17 Mar 2022 22:10:06 -0400 Subject: [PATCH 1/2] quick debug log --- dbt_server/views.py | 1 + 1 file changed, 1 insertion(+) 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? From d68a7e5a3291c842d88b82f7e467d16b6b49a246 Mon Sep 17 00:00:00 2001 From: Kyle Wigley Date: Thu, 17 Mar 2022 22:58:23 -0400 Subject: [PATCH 2/2] this works with the development version of dbt-core --- dbt_server/services/dbt_service.py | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) 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)