From 36d3e1674329ee498f97f2b534c391b52bb2246e Mon Sep 17 00:00:00 2001 From: JulianKimmig Date: Wed, 5 Nov 2025 07:48:46 +0100 Subject: [PATCH 1/4] refactor(tests): remove unused data_path assignment in TestWorkerInitCases --- tests/test_worker.py | 1 - 1 file changed, 1 deletion(-) 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 From f8d167025213192ac3717a579a1a3e74025293f2 Mon Sep 17 00:00:00 2001 From: JulianKimmig Date: Thu, 6 Nov 2025 11:07:01 +0100 Subject: [PATCH 2/4] chore(config): update pre-commit hooks and add Commitizen for commit message management --- .pre-commit-config.yaml | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) 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] From 8f9254a50f40ac81813b86a92f48df67dce37d45 Mon Sep 17 00:00:00 2001 From: JulianKimmig Date: Thu, 6 Nov 2025 11:08:07 +0100 Subject: [PATCH 3/4] fix(websocket): handle web.ClientError during message sending to prevent unhandled exceptions --- src/funcnodes_worker/websocket.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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: From 3ea1b18dcbdabb4171615a6acce3cbcddc6ebc38 Mon Sep 17 00:00:00 2001 From: Julian Kimmig Date: Thu, 6 Nov 2025 11:10:00 +0100 Subject: [PATCH 4/4] =?UTF-8?q?bump:=20version=201.2.0=20=E2=86=92=201.2.1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- CHANGELOG.md | 10 ++++++++++ pyproject.toml | 2 +- uv.lock | 2 +- 3 files changed, 12 insertions(+), 2 deletions(-) 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/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" },