Skip to content

Commit

Permalink
fix linting.
Browse files Browse the repository at this point in the history
fix sort_key_position for non sort_key column
  • Loading branch information
lvitti committed Aug 9, 2024
1 parent c499f92 commit e4e8d52
Show file tree
Hide file tree
Showing 3 changed files with 9 additions and 4 deletions.
4 changes: 2 additions & 2 deletions dbt/adapters/redshift/relation_configs/materialized_view.py
Original file line number Diff line number Diff line change
Expand Up @@ -206,8 +206,8 @@ def parse_relation_results(cls, relation_results: RelationResults) -> Dict:
{"dist": RedshiftDistConfig.parse_relation_results(materialized_view)}
)

if columns:= relation_results.get("columns"):
sort_columns = [row for row in columns.rows if row.get("sort_key_position") > 0]
if columns := relation_results.get("columns"):
sort_columns = [row for row in columns.rows if row.get("sort_key_position", 0) > 0]
if sort_columns:
config_dict.update(
{"sort": RedshiftSortConfig.parse_relation_results(sort_columns)}
Expand Down
4 changes: 2 additions & 2 deletions dbt/adapters/redshift/relation_configs/sort.py
Original file line number Diff line number Diff line change
Expand Up @@ -137,7 +137,6 @@ def parse_relation_config(cls, relation_config: RelationConfig) -> Dict[str, Any

return config_dict


@classmethod
def parse_relation_results(cls, relation_results_entry: "agate.MappedSequence") -> dict:
"""
Expand All @@ -161,14 +160,15 @@ def parse_relation_results(cls, relation_results_entry: "agate.MappedSequence")
Returns: a standard dictionary describing this `RedshiftSortConfig` instance
"""
sort_config = []

sorted_columns = sorted(relation_results_entry, key=lambda x: x["sort_key_position"])
for column in sorted_columns:
if column.get("sort_key_position"):
sort_config.append(column.get("column"))

return {"sortkey": sort_config}


@dataclass(frozen=True, eq=True, unsafe_hash=True)
class RedshiftSortConfigChange(RelationConfigChange, RelationConfigValidationMixin):
context: RedshiftSortConfig
Expand Down
5 changes: 5 additions & 0 deletions tests/unit/test_materialized_view.py
Original file line number Diff line number Diff line change
Expand Up @@ -81,6 +81,11 @@ def test_redshift_materialized_view_parse_relation_results_handles_multiples_sor
"is_dist_key": True,
"sort_key_position": 2,
},
{
"column": "my_column5",
"is_dist_key": False,
"sort_key_position": 0,
},
],
)

Expand Down

0 comments on commit e4e8d52

Please sign in to comment.