diff --git a/.pre-commit-config.yaml b/.pre-commit-config.yaml index 387dcae..d3c7ff2 100644 --- a/.pre-commit-config.yaml +++ b/.pre-commit-config.yaml @@ -11,14 +11,14 @@ repos: - repo: https://github.com/astral-sh/uv-pre-commit # uv version. - rev: "0.9.4" + rev: "0.9.7" hooks: # Update the uv lockfile - id: uv-lock - repo: https://github.com/astral-sh/ruff-pre-commit # Ruff version. - rev: v0.14.1 + rev: v0.14.3 hooks: # Run the linter. - id: ruff @@ -31,3 +31,9 @@ repos: hooks: - id: flake8 args: ["--config=.flake8"] + + - repo: https://github.com/commitizen-tools/commitizen + rev: v4.9.1 + hooks: + - id: commitizen + stages: [commit-msg] diff --git a/CHANGELOG.md b/CHANGELOG.md index 28a40ea..a5e2bee 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -1,5 +1,15 @@ # Changelog +## 1.2.1 (2025-11-06) + +### Fix + +- **websocket**: handle web.ClientError during message sending to prevent unhandled exceptions + +### Refactor + +- **tests**: remove unused data_path assignment in TestWorkerInitCases + ## 1.2.0 (2025-11-05) ### Refactor diff --git a/pyproject.toml b/pyproject.toml index f78a626..a06ef35 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -1,6 +1,6 @@ [project] name = "funcnodes-worker" -version = "1.2.0" +version = "1.2.1" description = "Worker package for FuncNodes" readme = "README.md" authors = [{name = "Julian Kimmig", email = "julian.kimmig@linkdlab.de"}] diff --git a/src/funcnodes_worker/websocket.py b/src/funcnodes_worker/websocket.py index 8304da9..2dafd18 100644 --- a/src/funcnodes_worker/websocket.py +++ b/src/funcnodes_worker/websocket.py @@ -64,7 +64,8 @@ async def process_queue(self): await asyncio.wait_for(self.ws.send_bytes(msg), timeout=2) else: await asyncio.wait_for(self.ws.send_str(msg), timeout=2) - + except web.ClientError: + pass except Exception as exc: self.logger.exception("Error sending message", exc_info=exc) finally: diff --git a/tests/test_worker.py b/tests/test_worker.py index b85cc1d..a685461 100644 --- a/tests/test_worker.py +++ b/tests/test_worker.py @@ -47,7 +47,6 @@ class TestWorkerInitCases(TestCase): def setUp(self): fn_set_in_test() self.tempdir = tempfile.TemporaryDirectory() - # self.workerkwargs["data_path"] = self.tempdir.name self.workerkwargs["uuid"] = "testuuid" self.worker = None diff --git a/uv.lock b/uv.lock index f5ee3f7..bf9880c 100644 --- a/uv.lock +++ b/uv.lock @@ -464,7 +464,7 @@ wheels = [ [[package]] name = "funcnodes-worker" -version = "1.2.0" +version = "1.2.1" source = { editable = "." } dependencies = [ { name = "asynctoolkit" },