diff options
author | Alex Grönholm <alex.gronholm@nextday.fi> | 2022-09-12 22:48:45 +0300 |
---|---|---|
committer | Alex Grönholm <alex.gronholm@nextday.fi> | 2022-09-12 22:48:45 +0300 |
commit | 49344e6954559259beb336436a45698d62eed5b4 (patch) | |
tree | 8c0e42e95f9846b9bf1c854f1bd94e10de35f9e9 /src | |
parent | 9b72c6171741fc9492c0a468d40829c8118e61b0 (diff) | |
download | apscheduler-49344e6954559259beb336436a45698d62eed5b4.tar.gz |
Fixed schema parameter in SQLAlchemyJobStore not being used
Fixes #664.
Diffstat (limited to 'src')
-rw-r--r-- | src/apscheduler/datastores/sqlalchemy.py | 13 |
1 files changed, 7 insertions, 6 deletions
diff --git a/src/apscheduler/datastores/sqlalchemy.py b/src/apscheduler/datastores/sqlalchemy.py index 9c7c905..ebb076f 100644 --- a/src/apscheduler/datastores/sqlalchemy.py +++ b/src/apscheduler/datastores/sqlalchemy.py @@ -100,12 +100,13 @@ class _BaseSQLAlchemyDataStore: def __attrs_post_init__(self) -> None: # Generate the table definitions + prefix = f"{self.schema}." if self.schema else "" self._metadata = self.get_table_definitions() - self.t_metadata = self._metadata.tables["metadata"] - self.t_tasks = self._metadata.tables["tasks"] - self.t_schedules = self._metadata.tables["schedules"] - self.t_jobs = self._metadata.tables["jobs"] - self.t_job_results = self._metadata.tables["job_results"] + self.t_metadata = self._metadata.tables[prefix + "metadata"] + self.t_tasks = self._metadata.tables[prefix + "tasks"] + self.t_schedules = self._metadata.tables[prefix + "schedules"] + self.t_jobs = self._metadata.tables[prefix + "jobs"] + self.t_job_results = self._metadata.tables[prefix + "job_results"] # Find out if the dialect supports UPDATE...RETURNING update = self.t_jobs.update().returning(self.t_jobs.c.id) @@ -137,7 +138,7 @@ class _BaseSQLAlchemyDataStore: interval_type = EmulatedInterval tags_type = JSON - metadata = MetaData() + metadata = MetaData(schema=self.schema) Table("metadata", metadata, Column("schema_version", Integer, nullable=False)) Table( "tasks", |