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.