Merge pull request #47 from simonsobs/dev

Require `nextline>=0.7.12`

ci/latest/requirements.txt

@@ -1,6 +1,7 @@
 # The exact requirements of the latest versions of the dependencies. This file
 # is used in a GitHub Actions workflow to test the compatibility with the
 # latest versions of the dependencies. This file is monitored by Dependabot.
+nextline==0.7.12
 nextline-graphql==0.7.9
 transitions==0.9.1
 httpx==0.27.0

ci/minimum/requirements.txt

@@ -2,6 +2,7 @@
 # This file is used in a GitHub Actions workflow to test the compatibility.
 # This file needs to be manually updated to be consistent with
 # `pyproject.toml`.
+nextline==0.7.12
 nextline-graphql==0.7.8
 transitions==0.9.0
 httpx==0.23.0

pyproject.toml

@@ -22,6 +22,7 @@ classifiers = [
   "Programming Language :: Python :: 3.12",
 ]
 dependencies = [
+  "nextline>=0.7.12",
   "nextline-graphql>=0.7.8",
   "transitions>=0.9",
   "httpx>=0.23",

src/nextline_schedule/auto/auto_mode.py

@@ -62,7 +62,7 @@ async def __aenter__(self) -> 'AutoMode':
 
     async def __aexit__(self, exc_type, exc_value, traceback) -> None:
         await self._machine.__aexit__(exc_type, exc_value, traceback)
-        await self._pubsub_mode.close()
+        await self._pubsub_mode.aclose()
 
     async def on_state_changed(self, state: str) -> None:
         if state == 'off':

src/nextline_schedule/auto/state_machine/machine.py

@@ -83,7 +83,7 @@ async def _collect_tasks(self) -> None:
 
     async def close(self) -> None:
         await self._collect_tasks()
-        await self._pubsub_state.close()
+        await self._pubsub_state.aclose()
 
     async def __aenter__(self) -> 'AutoModeStateMachine':
         await self.start()

src/nextline_schedule/queue/queue.py

@@ -78,7 +78,7 @@ async def move_one_backward(self, id: int) -> bool:
         return True
 
     async def aclose(self) -> None:
-        await self._pubsub.close()
+        await self._pubsub.aclose()
 
     async def __aenter__(self) -> 'Queue':
         await self._pubsub.publish(list(self._queue.items))