Struct CognifyResult 

pub struct CognifyResult {
    pub chunks: Vec<DocumentChunk>,
    pub entities: Vec<GraphNodePair>,
    pub edges: Vec<GraphEdgePair>,
    pub summaries: Vec<TextSummary>,
    pub edge_types: Vec<EdgeType>,
    pub embeddings: Vec<Embedding>,
    pub indexed_fields: IndexedFieldsStats,
    pub documents_for_dlt: Vec<Document>,
    pub already_completed: bool,
    pub prior_pipeline_run_id: Option<Uuid>,
}

Result of the cognify pipeline.

Fields

chunks: Vec<DocumentChunk>

Text chunks extracted from documents

entities: Vec<GraphNodePair>

Entities (nodes) with their types, deduplicated

edges: Vec<GraphEdgePair>

Edges (relationships) between entities, deduplicated

summaries: Vec<TextSummary>

Text summaries generated from chunks

edge_types: Vec<EdgeType>

Edge types aggregated from relationship names

embeddings: Vec<Embedding>

Embeddings for chunks, entities, and summaries

indexed_fields: IndexedFieldsStats

Statistics about indexed fields

documents_for_dlt: Vec<Document>

Documents needed by the post-pipeline crate::tasks::extract_dlt_fk_edges teardown step. Populated by the final task in crate::tasks::build_cognify_pipeline; empty in the temporal branch (which does not run DLT FK extraction). The matching chunk list reuses the existing Self::chunks field.

Not serialised — internal teardown carrier, not part of the public result shape.

already_completed: bool

true when this result was synthesised by the check_pipeline_run_qualification short-circuit (latest pipeline_runs row was COMPLETED). All other fields are empty.

CLI prints “already complete” when set; HTTP-server returns 200 OK with status = "PipelineRunAlreadyCompleted". See doc 08-08 §4.3 and locked decision 13.

prior_pipeline_run_id: Option<Uuid>

The pipeline_run_id of the prior completed run that triggered the short-circuit. None on normal (non-short-circuit) results.

Implementations

impl CognifyResult

pub fn empty() -> CognifyResult

Create an empty result (no data to process).

pub fn already_completed(pipeline_run_id: Uuid) -> CognifyResult

Create a short-circuit “already completed” result tagged with the prior pipeline_run_id. All payload vectors are empty — callers that need the prior run’s outputs should query the graph / vector store directly (matches Python parity). See doc 08-08 §4.3.

Trait Implementations

impl Clone for CognifyResult

fn clone(&self) -> CognifyResult

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for CognifyResult

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.