From 96a97be96072bde78020f326f9dc30e874a9b46a Mon Sep 17 00:00:00 2001 From: Noah Dove Date: Mon, 14 Nov 2022 20:12:49 -0800 Subject: [PATCH] Absorb renaming of AnVIL tables (#4617) --- src/azul/plugins/repository/tdr_anvil/__init__.py | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/src/azul/plugins/repository/tdr_anvil/__init__.py b/src/azul/plugins/repository/tdr_anvil/__init__.py index fc5c59109a..a35d68c510 100644 --- a/src/azul/plugins/repository/tdr_anvil/__init__.py +++ b/src/azul/plugins/repository/tdr_anvil/__init__.py @@ -228,6 +228,11 @@ def _bundle_entity(self, bundle_fqid: SourcedBundleFQID) -> KeyReference: bundle_uuid, bundle_entity.key, entity_type) return bundle_entity + def _full_table_name(self, source: TDRSourceSpec, table_name: str) -> str: + if not table_name.startswith('INFORMATION_SCHEMA'): + table_name = 'anvil_' + table_name + return super()._full_table_name(source, table_name) + def _consolidate_by_type(self, entities: Keys) -> MutableKeysByType: result = {entity_type: set() for entity_type in self.indexed_columns_by_entity_type} for e in entities: