async fn filtered_ingest( state: Rc<TvixStoreIO>, co: GenCo, path: &Path, name: Option<String>, filter: Option<&Value>, ) -> Result<StorePath<String>, ErrorKind>