Skip to main content

make_persist_data_task

Function make_persist_data_task 

Source
pub fn make_persist_data_task(
    database: Arc<dyn IngestDb>,
    dataset_name: String,
    owner_id: Uuid,
    tenant_id: Option<Uuid>,
) -> TypedTask<ProcessedInput, Data>
Expand description

Build a TypedTask that resolves or creates the dataset, deduplicates by content hash, persists a new Data record if needed, and returns it.