We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 1e93419 commit a5f274cCopy full SHA for a5f274c
nodestream/pipeline/channel.py
@@ -100,10 +100,6 @@ class StepOutput:
100
def __init__(self, channel: Channel) -> None:
101
self.channel = channel
102
103
- def register(self, name: str) -> None:
104
- """Register the name of the step that will produce to this channel."""
105
- self.channel.register_output(name)
106
-
107
async def done(self):
108
"""Mark the output channel as done.
109
0 commit comments