Skip to content

Commit f3d402a

Browse files
committed
fix: revert change to address sonarqube attempted fix - need iterable copy of dictionary to loop through
1 parent 97fbf6e commit f3d402a

3 files changed

Lines changed: 3 additions & 3 deletions

File tree

‎src/dve/core_engine/backends/base/rules.py‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -865,5 +865,5 @@ def _remove_cached_artifact(self, entity_name: EntityName):
865865

866866
def clear_entity_cache(self):
867867
"""Helper method to remove all artifacts and cache trackers at end of processing."""
868-
for entity_name in self.entity_cache_tracker:
868+
for entity_name in list(self.entity_cache_tracker):
869869
self._remove_cached_artifact(entity_name)

‎src/dve/core_engine/backends/implementations/duckdb/rules.py‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -594,7 +594,7 @@ def cache_entity(self, entity_name: EntityName, entities: DuckDBEntities):
594594
removed as part of the function (in case the newer cache depends on the older one)."""
595595
_tmp_name = f"{entity_name}_{uuid4().hex}"
596596

597-
if entity := entities.get(entity_name): # pylint: disable=W0612
597+
if entity := entities.get(entity_name): # pylint: disable=W0612
598598
self.connection.sql(f"CREATE OR REPLACE TEMP TABLE {_tmp_name} AS SELECT * FROM entity")
599599
entities[entity_name] = self.connection.table(_tmp_name)
600600

‎src/dve/pipeline/pipeline.py‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -756,7 +756,7 @@ def apply_business_rules( # pylint: disable=R0914,R0915
756756
final_projection
757757
)
758758

759-
self.step_implementations.clear_entity_cache() # type: ignore
759+
self.step_implementations.clear_entity_cache() # type: ignore
760760

761761
fh.remove_prefix(
762762
fh.joinuri(

0 commit comments

Comments
 (0)