Skip to content

Commit 017c174

Browse files
author
tibut
committed
fixes an error, which appear when creating a pipeline without input, fixes a bug with importing
1 parent 077da20 commit 017c174

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

bitflow/script_parser.py

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -7,9 +7,9 @@
77
from bitflow.source import FileSource, ListenSource, DownloadSource
88
from bitflow.sinksteps import FileSink, ListenSink, TerminalOut, TCPSink
99
from bitflow.pipeline import Pipeline
10+
from bitflow.fork import *
1011
from bitflow.processingstep import *
1112
from bitflow.steps.plotprocessingsteps import *
12-
from bitflow.fork import *
1313
from bitflow.helper import *
1414
from bitflow.marshaller import CsvMarshaller
1515

@@ -344,8 +344,9 @@ def parse_pipelines(pipelines_ctx):
344344
for pipeline_ctx in pipelines_ctx.pipeline():
345345
pipeline,inputs = build_pipeline(pipeline_ctx)
346346
pipeline.start()
347-
for i in inputs:
348-
i.start()
347+
if inputs:
348+
for i in inputs:
349+
i.start()
349350
pipes_and_inputs.append((pipeline,inputs))
350351
return pipes_and_inputs
351352

0 commit comments

Comments
 (0)