Skip to main content

make_process_input_task

cognee_lib

Function make_process_input_task 

Source 
pub fn make_process_input_task(
    storage: Arc<dyn StorageTrait>,
    hash_algorithm: HashAlgorithm,
    owner_id: Uuid,
    tenant_id: Option<Uuid>,
) -> TypedTask<DataInput, ProcessedInput>
Expand description

Build a TypedTask that streams a DataInput to storage, hashes its content, and returns a self-contained ProcessedInput.