Skip to content

graflo.architecture.pipeline.runtime.executor

Execution surface for actor extraction and assembly orchestration.

Attributes

Classes

ActorExecutor

Owns runtime extraction and assembly orchestration for an ActorWrapper.

Source code in graflo/architecture/pipeline/runtime/executor.py 
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
class ActorExecutor:
    """Owns runtime extraction and assembly orchestration for an ActorWrapper."""

    def __init__(self, root: ActorWrapper):
        self.root = root

    def extract(self, doc: dict) -> ExtractionContext:
        extraction_ctx = ExtractionContext()
        return self.root(extraction_ctx, doc=doc)

    def assemble(
        self, extraction_ctx: ExtractionContext
    ) -> defaultdict[GraphEntity, list]:
        """The assembled entities; :meth:`assemble_result` adds the attached rows."""
        return self.assemble_result(extraction_ctx).entities

    def assemble_result(self, extraction_ctx: ExtractionContext) -> GraphAssemblyResult:
        assembly_ctx = AssemblyContext.from_extraction(extraction_ctx)
        entities = self.root.assemble(assembly_ctx)
        return GraphAssemblyResult(
            entities=entities, attached=dict(assembly_ctx.acc_attached)
        )

Attributes

root = root instance-attribute

Methods:

__init__(root)
Source code in graflo/architecture/pipeline/runtime/executor.py 
20
21
def __init__(self, root: ActorWrapper):
    self.root = root
assemble(extraction_ctx)

The assembled entities; :meth:assemble_result adds the attached rows.

Source code in graflo/architecture/pipeline/runtime/executor.py 
27
28
29
30
31
def assemble(
    self, extraction_ctx: ExtractionContext
) -> defaultdict[GraphEntity, list]:
    """The assembled entities; :meth:`assemble_result` adds the attached rows."""
    return self.assemble_result(extraction_ctx).entities
assemble_result(extraction_ctx)
Source code in graflo/architecture/pipeline/runtime/executor.py 
33
34
35
36
37
38
def assemble_result(self, extraction_ctx: ExtractionContext) -> GraphAssemblyResult:
    assembly_ctx = AssemblyContext.from_extraction(extraction_ctx)
    entities = self.root.assemble(assembly_ctx)
    return GraphAssemblyResult(
        entities=entities, attached=dict(assembly_ctx.acc_attached)
    )
extract(doc)
Source code in graflo/architecture/pipeline/runtime/executor.py 
23
24
25
def extract(self, doc: dict) -> ExtractionContext:
    extraction_ctx = ExtractionContext()
    return self.root(extraction_ctx, doc=doc)