| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [Original HTTPS Page] |
Sorry, something went wrong.
…deployability. Signed-off-by: davem-bis <68955845+davem-bis@users.noreply.github.com>
Signed-off-by: davem-bis <68955845+davem-bis@users.noreply.github.com>
…ndirect-non-breaking-deployable-representative-mismatch
…ty instead of representativeness for determining whether dev or prod instance of each should be used. Signed-off-by: davem-bis <68955845+davem-bis@users.noreply.github.com>
Signed-off-by: davem-bis <68955845+davem-bis@users.noreply.github.com>
|
@davem-bis -- I think you'll also want to change from representative to deployable in the to_table_mapping function in sqlmesh/core/snapshot/definition.py file as well. That should create a clear prod/dev split. I'd also look into modifying the is_representative docstring in the DeployabilityIndex class. After this change, it will not be used for computing missing intervals. I think it will only be used for prod promotion and table creation stuff. Something like this: Unlike `is_deployable`, this variant also captures FORWARD_ONLY and INDIRECT_NON_BREAKING snapshots that are not deployable by their nature but are currently promoted in production. This is used when constructing a plan to determine prod promotion staging (e.g. which snapshots backfill before promote) and whether a physical table needs to be created. |
Sorry, something went wrong.
| Back | FazBrowse Home | New Git URL |
Description
Fixes #5793.
Changes the logic determining whether to use the prod or dev instance of intervals or physical model to rely solely on deployability. Previously this was inconsistently using either deployability and representativeness, leading to non-idempotent behaviour in non-prod environments.
Test Plan
sqlmesh init
sqlmesh plan
Add 'ABC' AS extra_column to incremental_model.sql
sqlmesh plan indirect_non_breaking
sqlmesh run
sqlmesh run indirect_non_breaking
sqlmesh fetchdf "UPDATE sqlmesh._intervals SET end_ts = end_ts - 86400000, start_ts = start_ts - 86400000, last_altered_ts = last_altered_ts - 86400000"
sqlmesh run indirect_non_breaking
sqlmesh run indirect_non_breaking
Checklist