mirror of
https://github.com/datahub-project/datahub.git
synced 2025-11-10 16:32:26 +00:00
feat(ingest/snowflake): breaking change for match_fully_qualified_names (#13852)
This commit is contained in:
parent
582983ca27
commit
bb4d747e39
@ -30,6 +30,8 @@ This file documents any backwards-incompatible changes in DataHub and assists pe
|
|||||||
|
|
||||||
### Breaking Changes
|
### Breaking Changes
|
||||||
|
|
||||||
|
- #13852 `snowflake` connector has `match_fully_qualified_names` which has been present for backward compatibility. If you are using `schema_pattern` but have not set `match_fully_qualified_names: true` please change it to `match_fully_qualified_names: true` and update your `schema_pattern` to match against fully qualified schema names `<catalog_name>.<schema_name>`. We were printing warnings earlier for this. We are making this backward incompatible breaking change to make this consistent with all other sources.
|
||||||
|
|
||||||
### Known Issues
|
### Known Issues
|
||||||
|
|
||||||
### Potential Downtime
|
### Potential Downtime
|
||||||
|
|||||||
@ -4,6 +4,13 @@ source:
|
|||||||
# This option is recommended to be used to ingest all lineage on the first run.
|
# This option is recommended to be used to ingest all lineage on the first run.
|
||||||
ignore_start_time_lineage: true
|
ignore_start_time_lineage: true
|
||||||
|
|
||||||
|
# This has the default of `false` for backward compatibility but we are making a breaking change so add it here
|
||||||
|
# in case you wish to use schema_pattern
|
||||||
|
match_fully_qualified_names: true
|
||||||
|
|
||||||
|
# This flag tells the snowflake ingestion to use the more advanced query parsing. This will become the default eventually.
|
||||||
|
use_queries_v2: true
|
||||||
|
|
||||||
# Coordinates
|
# Coordinates
|
||||||
account_id: "abc48144"
|
account_id: "abc48144"
|
||||||
warehouse: "COMPUTE_WH"
|
warehouse: "COMPUTE_WH"
|
||||||
|
|||||||
@ -135,10 +135,12 @@ class SnowflakeFilterConfig(SQLFilterConfig):
|
|||||||
and match_fully_qualified_names is not None
|
and match_fully_qualified_names is not None
|
||||||
and not match_fully_qualified_names
|
and not match_fully_qualified_names
|
||||||
):
|
):
|
||||||
logger.warning(
|
raise ValueError(
|
||||||
"Please update `schema_pattern` to match against fully qualified schema name `<catalog_name>.<schema_name>` and set config `match_fully_qualified_names : True`."
|
"`match_fully_qualified_names: False` is no longer supported. "
|
||||||
"Current default `match_fully_qualified_names: False` is only to maintain backward compatibility. "
|
"Please set `match_fully_qualified_names: True` and update your `schema_pattern` "
|
||||||
"The config option `match_fully_qualified_names` will be deprecated in future and the default behavior will assume `match_fully_qualified_names: True`."
|
"to match against fully qualified schema names `<catalog_name>.<schema_name>`. "
|
||||||
|
"The config option `match_fully_qualified_names` will be removed in future and the default behavior will assume `match_fully_qualified_names: True`."
|
||||||
|
"match_fully_qualified_names False was there to maintain backward compatibility."
|
||||||
)
|
)
|
||||||
|
|
||||||
# Always exclude reporting metadata for INFORMATION_SCHEMA schema
|
# Always exclude reporting metadata for INFORMATION_SCHEMA schema
|
||||||
|
|||||||
@ -284,7 +284,8 @@ def test_snowflake_private_link_and_incremental_mcps(
|
|||||||
account_id="ABC12345.ap-south-1.privatelink",
|
account_id="ABC12345.ap-south-1.privatelink",
|
||||||
username="TST_USR",
|
username="TST_USR",
|
||||||
password="TST_PWD",
|
password="TST_PWD",
|
||||||
schema_pattern=AllowDenyPattern(allow=["test_schema"]),
|
schema_pattern=AllowDenyPattern(allow=["test_db.test_schema"]),
|
||||||
|
match_fully_qualified_names=True,
|
||||||
include_technical_schema=True,
|
include_technical_schema=True,
|
||||||
include_table_lineage=True,
|
include_table_lineage=True,
|
||||||
include_column_lineage=False,
|
include_column_lineage=False,
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user