pipeline.pipeline
Module¶
-
class
wpull.pipeline.pipeline.
Pipeline
(item_source: wpull.pipeline.pipeline.ItemSource, tasks: typing.Sequence, item_queue: typing.Union=None)[source]¶ Bases:
object
-
concurrency
¶
-
tasks
¶
-
-
class
wpull.pipeline.pipeline.
PipelineSeries
(pipelines: typing.Iterator)[source]¶ Bases:
object
-
concurrency
¶
-
concurrency_pipelines
¶
-
pipelines
¶
-