Add missing channel creation

2026-09-22 01:25:06 +02:00 · 2023-11-04 17:58:19 +00:00
parent 6704b6d205
commit 2cf92cdad7
1 changed files with 5 additions and 0 deletions
@@ -27,9 +27,14 @@ def validate_chains_channels(
            channels[chan] = LastValue(Any)

    if isinstance(input, str):
+        if input not in channels:
+            channels[input] = LastValue(Any)
        if input not in subscribed_channels:
            raise ValueError(f"Input channel {input} is not subscribed to by any chain")
    else:
+        for chan in input:
+            if chan not in channels:
+                channels[chan] = LastValue(Any)
        if all(chan not in subscribed_channels for chan in input):
            raise ValueError(
                f"None of the input channels {input} are subscribed to by any chain"