From dc36901dde46e24398186412fcd06998d1037f20 Mon Sep 17 00:00:00 2001 From: Benjamin Dauvergne Date: Thu, 4 Feb 2021 10:35:24 +0100 Subject: [PATCH] feeder: store truncated temp schema's name (#50835) --- wcs_olap/feeder.py | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/wcs_olap/feeder.py b/wcs_olap/feeder.py index dd04de4..960dde2 100644 --- a/wcs_olap/feeder.py +++ b/wcs_olap/feeder.py @@ -96,11 +96,12 @@ class WcsOlapFeeder(object): if len(schema) > 63: raise ValueError('schema name length must < 64 characters: %r' % schema) self.schema = schema + self.schema_temp = truncate_pg_identifier(schema + '_temp') self.do_feed = do_feed self.ctx = Context() self.ctx.push({ 'schema': self.schema, - 'schema_temp': truncate_pg_identifier(schema + '_temp'), + 'schema_temp': self.schema_temp, 'role_table': 'role', 'channel_table': 'channel', 'category_table': 'category', @@ -335,8 +336,8 @@ class WcsOlapFeeder(object): def do_schema(self): self.ex('SET search_path = public') - self.logger.debug('dropping schema %s', self.schema + '_temp') - self.drop_tables_sequencially(self.schema + '_temp') + self.logger.debug('dropping schema %s', self.schema_temp) + self.drop_tables_sequencially(self.schema_temp) self.ex('DROP SCHEMA IF EXISTS {schema_temp} CASCADE') self.logger.debug('creating schema %s', self.schema) self.ex('CREATE SCHEMA {schema_temp}')