Ensure future in sleep method (#34)

wbarnha · web-flow · commit 024112a47510 · 2022-11-30T09:58:43.000-05:00
diff --git a/mode/services.py b/mode/services.py
@@ -694,7 +694,7 @@ async def sleep(self, n: Seconds) -> None:
         """Sleep for ``n`` seconds, or until service stopped."""
         try:
             await asyncio.wait_for(
-                self._stopped.wait(),
+                asyncio.ensure_future(self._stopped.wait(), loop=self.loop),
                 timeout=want_seconds(n),
             )
         except asyncio.TimeoutError:

Original file line number	Diff line number	Diff line change
`@@ -694,7 +694,7 @@ async def sleep(self, n: Seconds) -> None:`
`694`	`694`	"""Sleep for ``n`` seconds, or until service stopped."""
`695`	`695`	`try:`
`696`	`696`	`await asyncio.wait_for(`
`697`		`- self._stopped.wait(),`
	`697`	`+ asyncio.ensure_future(self._stopped.wait(), loop=self.loop),`
`698`	`698`	`timeout=want_seconds(n),`
`699`	`699`	`)`
`700`	`700`	`except asyncio.TimeoutError:`