Format the generator test's sink helper

2026-08-26 22:53:41 +02:00
parent 5e20fdec43
commit dabd6cde66
1 changed files with 5 additions and 1 deletions
@@ -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