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
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]:
        assembly_ctx = AssemblyContext.from_extraction(extraction_ctx)
        return self.root.assemble(assembly_ctx)

    def assemble_result(self, extraction_ctx: ExtractionContext) -> GraphAssemblyResult:
        return GraphAssemblyResult(entities=self.assemble(extraction_ctx))

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)
Source code in graflo/architecture/pipeline/runtime/executor.py 
27
28
29
30
31
def assemble(
    self, extraction_ctx: ExtractionContext
) -> defaultdict[GraphEntity, list]:
    assembly_ctx = AssemblyContext.from_extraction(extraction_ctx)
    return self.root.assemble(assembly_ctx)
assemble_result(extraction_ctx)
Source code in graflo/architecture/pipeline/runtime/executor.py 
33
34
def assemble_result(self, extraction_ctx: ExtractionContext) -> GraphAssemblyResult:
    return GraphAssemblyResult(entities=self.assemble(extraction_ctx))
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)