From 9238d85ac8fb024d3192c6f13ae538fd08a84ea0 Mon Sep 17 00:00:00 2001 From: Olivier Agudo-Perez Date: Tue, 17 Dec 2024 14:26:15 +0100 Subject: [PATCH] add support for per_thread_output in external materialization --- dbt/adapters/duckdb/impl.py | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/dbt/adapters/duckdb/impl.py b/dbt/adapters/duckdb/impl.py index b62b5073..02c70031 100644 --- a/dbt/adapters/duckdb/impl.py +++ b/dbt/adapters/duckdb/impl.py @@ -170,10 +170,11 @@ def external_write_options(self, write_location: str, rendered_options: dict) -> @available def external_read_location(self, write_location: str, rendered_options: dict) -> str: - if rendered_options.get("partition_by"): + if rendered_options.get("partition_by") or rendered_options.get("per_thread_output"): globs = [write_location, "*"] - partition_by = str(rendered_options.get("partition_by")) - globs.extend(["*"] * len(partition_by.split(","))) + if rendered_options.get("partition_by"): + partition_by = str(rendered_options.get("partition_by")) + globs.extend(["*"] * len(partition_by.split(","))) return ".".join(["/".join(globs), str(rendered_options.get("format", "parquet"))]) return write_location