Support configurable delimiter for seed files, default to comma (#3990)

.changes/unreleased/Features-20230317-144957.yaml

@@ -0,0 +1,6 @@
+kind: Features
+body: Added support to configure a delimiter for a seed file, defaults to comma
+time: 2023-03-17T14:49:57.564210866+01:00
+custom:
+  Author: ramonvermeulen
+  Issue: "3990"

core/dbt/clients/agate_helper.py

@@ -135,12 +135,12 @@ def as_matrix(table):
     return [r.values() for r in table.rows.values()]
 
 
-def from_csv(abspath, text_columns):
+def from_csv(abspath, text_columns, delimiter=","):
     type_tester = build_type_tester(text_columns=text_columns)
     with open(abspath, encoding="utf-8") as fp:
         if fp.read(1) != BOM:
             fp.seek(0)
-        return agate.Table.from_csv(fp, column_types=type_tester)
+        return agate.Table.from_csv(fp, column_types=type_tester, delimiter=delimiter)
 
 
 class _NullMarker:

core/dbt/context/providers.py

@@ -865,8 +865,9 @@ def load_agate_table(self) -> agate.Table:
         assert self.model.root_path
         path = os.path.join(self.model.root_path, self.model.original_file_path)
         column_types = self.model.config.column_types
+        delimiter = self.model.config.delimiter
         try:
-            table = agate_helper.from_csv(path, text_columns=column_types)
+            table = agate_helper.from_csv(path, text_columns=column_types, delimiter=delimiter)
         except ValueError as e:
             raise LoadAgateTableValueError(e, node=self.model)
         table.original_abspath = os.path.abspath(path)

core/dbt/contracts/graph/model_config.py

@@ -544,6 +544,7 @@ def field_mapping(cls):
 @dataclass
 class SeedConfig(NodeConfig):
     materialized: str = "seed"
+    delimiter: str = ","
     quote_columns: Optional[bool] = None
 
     @classmethod

tests/adapter/dbt/tests/adapter/simple_seed/fixtures.py

@@ -34,6 +34,10 @@
 models__downstream_from_seed_actual = """
 select * from {{ ref('seed_actual') }}
 
+"""
+models__downstream_from_seed_pipe_separated = """
+select * from {{ ref('seed_pipe_separated') }}
+
 """
 models__from_basic_seed = """
 select * from {{ this.schema }}.seed_expected

tests/adapter/dbt/tests/adapter/simple_seed/test_seed.py

@@ -18,6 +18,7 @@
 from dbt.tests.adapter.simple_seed.fixtures import (
     models__downstream_from_seed_actual,
     models__from_basic_seed,
+    models__downstream_from_seed_pipe_separated,
 )
 
 from dbt.tests.adapter.simple_seed.seeds import (
@@ -29,6 +30,7 @@
     seeds__wont_parse_csv,
     seed__unicode_csv,
     seed__with_dots_csv,
+    seeds__pipe_separated_csv,
 )
 
 
@@ -163,6 +165,91 @@ def test_simple_seed_with_drop_and_schema(self, project):
         check_relations_equal(project.adapter, [f"{custom_schema}.seed_actual", "seed_expected"])
 
 
+class SeedUniqueDelimiterTestBase(SeedConfigBase):
+    @pytest.fixture(scope="class")
+    def project_config_update(self):
+        return {
+            "seeds": {
+                "quote_columns": False,
+                "delimiter": "|"
+            },
+        }
+
+    @pytest.fixture(scope="class", autouse=True)
+    def setUp(self, project):
+        """Create table for ensuring seeds and models used in tests build correctly"""
+        project.run_sql(seeds__expected_sql)
+
+    @pytest.fixture(scope="class")
+    def seeds(self, test_data_dir):
+        return {"seed_pipe_separated.csv": seeds__pipe_separated_csv}
+
+    @pytest.fixture(scope="class")
+    def models(self):
+        return {
+            "models__downstream_from_seed_pipe_separated.sql": models__downstream_from_seed_pipe_separated,
+        }
+
+    def _build_relations_for_test(self, project):
+        """The testing environment needs seeds and models to interact with"""
+        seed_result = run_dbt(["seed"])
+        assert len(seed_result) == 1
+        check_relations_equal(project.adapter, ["seed_expected", "seed_pipe_separated"])
+
+        run_result = run_dbt()
+        assert len(run_result) == 1
+        check_relations_equal(
+            project.adapter, ["models__downstream_from_seed_pipe_separated", "seed_expected"]
+        )
+
+    def _check_relation_end_state(self, run_result, project, exists: bool):
+        assert len(run_result) == 1
+        check_relations_equal(project.adapter, ["seed_pipe_separated", "seed_expected"])
+        if exists:
+            check_table_does_exist(project.adapter, "models__downstream_from_seed_pipe_separated")
+        else:
+            check_table_does_not_exist(project.adapter, "models__downstream_from_seed_pipe_separated")
+
+
+class TestSeedWithUniqueDelimiter(SeedUniqueDelimiterTestBase):
+    def test_seed_with_unique_delimiter(self, project):
+        """Testing correct run of seeds with a unique delimiter (pipe in this case)"""
+        self._build_relations_for_test(project)
+        self._check_relation_end_state(run_result=run_dbt(["seed"]), project=project, exists=True)
+
+
+class TestSeedWithWrongDelimiter(SeedUniqueDelimiterTestBase):
+    @pytest.fixture(scope="class")
+    def project_config_update(self):
+        return {
+            "seeds": {
+                "quote_columns": False,
+                "delimiter": ";"
+            },
+        }
+
+    def test_seed_with_wrong_delimiter(self, project):
+        """Testing failure of running dbt seed with a wrongly configured delimiter"""
+        seed_result = run_dbt(["seed"], expect_pass=False)
+        assert "syntax error" in seed_result.results[0].message.lower()
+
+
+class TestSeedWithEmptyDelimiter(SeedUniqueDelimiterTestBase):
+    @pytest.fixture(scope="class")
+    def project_config_update(self):
+        return {
+            "seeds": {
+                "quote_columns": False,
+                "delimiter": ""
+            },
+        }
+
+    def test_seed_with_empty_delimiter(self, project):
+        """Testing failure of running dbt seed with an empty configured delimiter value"""
+        seed_result = run_dbt(["seed"], expect_pass=False)
+        assert "compilation error" in seed_result.results[0].message.lower()
+
+
 class TestSimpleSeedEnabledViaConfig(object):
     @pytest.fixture(scope="session")
     def seeds(self):

tests/functional/artifacts/expected_manifest.py

@@ -55,6 +55,7 @@ def get_rendered_seed_config(**updates):
         "pre-hook": [],
         "post-hook": [],
         "column_types": {},
+        "delimiter": ",",
         "quoting": {},
         "tags": [],
         "quote_columns": True,

tests/functional/list/test_list.py

@@ -392,6 +392,7 @@ def expect_seed_output(self):
                     "pre-hook": [],
                     "quoting": {},
                     "column_types": {},
+                    "delimiter": ",",
                     "persist_docs": {},
                     "quote_columns": False,
                     "full_refresh": None,

tests/unit/test_contracts_graph_parsed.py

@@ -520,6 +520,7 @@ def basic_parsed_seed_dict():
         "alias": "foo",
         "config": {
             "column_types": {},
+            "delimiter": ",",
             "enabled": True,
             "materialized": "seed",
             "persist_docs": {},
@@ -611,6 +612,7 @@ def complex_parsed_seed_dict():
         "alias": "foo",
         "config": {
             "column_types": {},
+            "delimiter": ",",
             "enabled": True,
             "materialized": "seed",
             "persist_docs": {"relation": True, "columns": True},
@@ -669,6 +671,7 @@ def complex_parsed_seed_object():
         alias="foo",
         config=SeedConfig(
             quote_columns=True,
+            delimiter=",",
             persist_docs={"relation": True, "columns": True},
         ),
         deferred=False,