diff options
Diffstat (limited to 'src/apscheduler/datastores/sqlalchemy.py')
| -rw-r--r-- | src/apscheduler/datastores/sqlalchemy.py | 12 |
1 files changed, 3 insertions, 9 deletions
diff --git a/src/apscheduler/datastores/sqlalchemy.py b/src/apscheduler/datastores/sqlalchemy.py index 8ff90c4..cca223e 100644 --- a/src/apscheduler/datastores/sqlalchemy.py +++ b/src/apscheduler/datastores/sqlalchemy.py @@ -500,15 +500,9 @@ class SQLAlchemyDataStore(_BaseSQLAlchemyDataStore, DataStore): next_fire_times = { arg["p_id"]: arg["p_next_fire_time"] for arg in update_args } - if self._supports_update_returning: - update = update.returning(self.t_schedules.c.id) - updated_ids = [ - row[0] for row in conn.execute(update, update_args) - ] - else: - # TODO: actually check which rows were updated? - conn.execute(update, update_args) - updated_ids = list(next_fire_times) + # TODO: actually check which rows were updated? + conn.execute(update, update_args) + updated_ids = list(next_fire_times) for schedule_id in updated_ids: event = ScheduleUpdated( |