Test

.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]

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

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"}]

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:

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