release

Author: lsbardel

fluid/__init__.py

@@ -1,3 +1,3 @@
 """Reusable server side python modules"""
 
-__version__ = "1.4.0"
+__version__ = "1.4.1"

fluid/utils/worker.py

@@ -431,7 +431,7 @@ def add_workers(self, *workers: Worker) -> None:
     def num_workers(self) -> int:
         return len(self._workers)
 
-    def wrokers(self) -> Iterator[Worker]:
+    def workers(self) -> Iterator[Worker]:
         return iter(self._workers)
 
     def gracefully_stop(self) -> None:

pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "aio-fluid"
-version = "1.4.0"
+version = "1.4.1"
 description = "Tools for backend python services"
 authors = [
     { name = "Luca Sbardella", email = "luca@quantmind.com" }

tests/utils/test_worker.py

@@ -93,17 +93,18 @@ async def test_exeception3() -> None:
 
 
 async def test_workers() -> None:
-    workers = Workers(NiceWorker())
-    assert workers.num_workers == 1
+    workers = Workers(NiceWorker(), BadWorker(stopping_grace_period=2))
+    assert workers.num_workers == 2
     assert workers.has_started() is False
     await workers.startup()
     assert workers.has_started()
     status = await workers.status()
     assert status
     assert workers.is_running()
-    [nice] = list(workers.workers())
+    [nice, bad] = list(workers.workers())
     assert nice.is_running()
     nice.gracefully_stop()
     assert nice.is_stopping()
+    assert bad.is_running()
     await workers.wait_for_shutdown()
     assert workers.is_stopped()