diff --git a/sqlalchemy_timescaledb/dialect.py b/sqlalchemy_timescaledb/dialect.py index 6274f55..8113063 100644 --- a/sqlalchemy_timescaledb/dialect.py +++ b/sqlalchemy_timescaledb/dialect.py @@ -23,7 +23,7 @@ def post_create_table(self, table): table, 'after_create', self.ddl_hypertable( - table.name, hypertable + table.schema, table.name, hypertable ).execute_if( dialect='timescaledb' ) @@ -32,7 +32,7 @@ def post_create_table(self, table): return super().post_create_table(table) @staticmethod - def ddl_hypertable(table_name, hypertable): + def ddl_hypertable(schema_name, table_name, hypertable): time_column_name = hypertable['time_column_name'] chunk_time_interval = hypertable.get('chunk_time_interval', '7 days') @@ -45,7 +45,7 @@ def ddl_hypertable(table_name, hypertable): return DDL( f""" SELECT create_hypertable( - '{table_name}', + '"{schema_name}"."{table_name}"', '{time_column_name}', chunk_time_interval => {chunk_time_interval}, if_not_exists => TRUE