Formatted all code to fit within Black's 88 column limit

2 files changed, 6 insertions, 4 deletions

diff --git a/src/apscheduler/datastores/async_sqlalchemy.py b/src/apscheduler/datastores/async_sqlalchemy.py
index 74742f8..0c165b8 100644
--- a/src/apscheduler/datastores/async_sqlalchemy.py
+++ b/src/apscheduler/datastores/async_sqlalchemy.py
@@ -120,7 +120,8 @@ class AsyncSQLAlchemyDataStore(_BaseSQLAlchemyDataStore, BaseAsyncDataStore):
                     elif version > 1:
                         raise RuntimeError(
                             f"Unexpected schema version ({version}); "
-                            f"only version 1 is supported by this version of APScheduler"
+                            f"only version 1 is supported by this version of "
+                            f"APScheduler"
                         )
 
     async def _deserialize_schedules(self, result: Result) -> list[Schedule]:
@@ -407,7 +408,8 @@ class AsyncSQLAlchemyDataStore(_BaseSQLAlchemyDataStore, BaseAsyncDataStore):
                             )
                             update_events.append(event)
 
-                    # Remove schedules that have no next fire time or failed to serialize
+                    # Remove schedules that have no next fire time or failed to
+                    # serialize
                     if finished_schedule_ids:
                         delete = self.t_schedules.delete().where(
                             self.t_schedules.c.id.in_(finished_schedule_ids)
diff --git a/src/apscheduler/datastores/memory.py b/src/apscheduler/datastores/memory.py
index fb29ad9..a9ff3cb 100644
--- a/src/apscheduler/datastores/memory.py
+++ b/src/apscheduler/datastores/memory.py
@@ -194,8 +194,8 @@ class MemoryDataStore(BaseDataStore):
                 break
             elif state.acquired_by is not None:
                 if state.acquired_by != scheduler_id and now <= state.acquired_until:
-                    # The schedule has been acquired by another scheduler and the timeout has not
-                    # expired yet
+                    # The schedule has been acquired by another scheduler and the
+                    # timeout has not expired yet
                     continue
 
             schedules.append(state.schedule)