From 58a8691a5e48839c3ab1e023363973ede715d5a1 Mon Sep 17 00:00:00 2001 From: Minura Punchihewa Date: Fri, 4 Oct 2024 19:48:43 +0530 Subject: [PATCH] initialized the base table in the base table dataset --- .../databricks/_base_table_dataset.py | 14 +++++++++++++- 1 file changed, 13 insertions(+), 1 deletion(-) diff --git a/kedro-datasets/kedro_datasets/databricks/_base_table_dataset.py b/kedro-datasets/kedro_datasets/databricks/_base_table_dataset.py index 700e1cf53..cba1798a3 100644 --- a/kedro-datasets/kedro_datasets/databricks/_base_table_dataset.py +++ b/kedro-datasets/kedro_datasets/databricks/_base_table_dataset.py @@ -325,7 +325,19 @@ def _create_table( # noqa: PLR0913 Returns: ``BaseTable``: The new ``BaseTable`` instance. """ - raise NotImplementedError + return BaseTable( + table=table, + catalog=catalog, + database=database, + format=format, + write_mode=write_mode, + location=location, + dataframe_type=dataframe_type, + json_schema=json_schema, + partition_columns=partition_columns, + owner_group=owner_group, + primary_key=primary_key, + ) def _load(self) -> DataFrame | pd.DataFrame: """Loads the version of data in the format defined in the init