Skip to content

Commit

Permalink
set catalog integration
Browse files Browse the repository at this point in the history
  • Loading branch information
MichelleArk committed Dec 13, 2024
1 parent e4a2d64 commit 926d4c5
Showing 1 changed file with 4 additions and 1 deletion.
5 changes: 4 additions & 1 deletion core/dbt/cli/requires.py
Original file line number Diff line number Diff line change
Expand Up @@ -324,7 +324,7 @@ def wrapper(*args, **kwargs):
req_strs = ["flags", "profile"]
reqs = [ctx.obj.get(req_str) for req_str in req_strs]
if None in reqs:
raise DbtProjectError("profile and flags required for runtime_config")
raise DbtProjectError("profile and flags required to load catalogs")

Check warning on line 327 in core/dbt/cli/requires.py

View check run for this annotation

Codecov / codecov/patch

core/dbt/cli/requires.py#L327

Added line #L327 was not covered by tests

flags = ctx.obj["flags"]
profile = ctx.obj["profile"]
Expand Down Expand Up @@ -382,3 +382,6 @@ def setup_manifest(ctx: Context, write: bool = True, write_perf_info: bool = Fal
adapter.set_macro_resolver(ctx.obj["manifest"])
query_header_context = generate_query_header_context(adapter.config, ctx.obj["manifest"]) # type: ignore[attr-defined]
adapter.connections.set_query_header(query_header_context)
catalogs = ctx.obj["catalogs"].catalogs if "catalogs" in ctx.obj else []
for catalog in catalogs:
adapter.set_catalog_integration(catalog.name, catalog.active_write_integration)

Check warning on line 387 in core/dbt/cli/requires.py

View check run for this annotation

Codecov / codecov/patch

core/dbt/cli/requires.py#L387

Added line #L387 was not covered by tests

0 comments on commit 926d4c5

Please sign in to comment.