compass.pipeline.collection.steps.CollectionStep#

class CollectionStep[source]#

Bases: ABC

Strategy base class for fixed collection steps

Methods

collect(workflow)

Collect documents for one step

Attributes

Identifier for step (e.g. "known_local_docs").

abstract property STEP_NAME#: Identifier for step (e.g. “known_local_docs”)

abstractmethod async collect(workflow)[source]#: Collect documents for one step