toloka.streaming.pipeline.Pipeline.run | Source code
toloka.streaming.pipeline.Pipeline.run
async run(self)