diff --git a/backend/tests/flow/test_workers.py b/backend/tests/flow/test_workers.py
index 043528e..02c57e1 100644
--- a/backend/tests/flow/test_workers.py
+++ b/backend/tests/flow/test_workers.py
@@ -38,7 +38,11 @@ def _sink_node(node_id: str, port: str, dtype: DType) -> tuple[Node, list[dict]]
     node._pipeline = type(
         "Recorder",
         (),
-        {"publish_emission": staticmethod(lambda _node, outputs: published.append(outputs))},
+        {
+            "publish_emission": staticmethod(
+                lambda _node, outputs: published.append(outputs)
+            )
+        },
     )()
     return node, published