Skip to content

Commit 533ec5f

Browse files
Update processing job resolver
1 parent 5de56c5 commit 533ec5f

File tree

3 files changed

+3
-260
lines changed

3 files changed

+3
-260
lines changed

dp.gql

Lines changed: 0 additions & 256 deletions
This file was deleted.

processed_data/src/graphql/entities.rs

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -267,11 +267,10 @@ pub struct DataCollection {
267267
}
268268

269269
/// Datasets subgraph extension
270-
#[derive(Clone, Debug, PartialEq, SimpleObject)]
270+
#[derive(Debug, Clone, SimpleObject)]
271271
#[graphql(name = "ProcessJob", unresolvable = "processingJobId")]
272272
pub struct ProcessJob {
273273
#[graphql(flatten, external)]
274274
pub processing_job: ProcessingJob,
275-
#[graphql(flatten, external)]
276-
pub parameters: ProcessingJobParameter,
275+
pub parameters: Option<ProcessingJobParameter>,
277276
}

processed_data/src/graphql/mod.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -242,7 +242,7 @@ impl Loader<u32> for ProcessingJobDataLoader {
242242
.into_iter()
243243
.map(|(job, parameter)| ProcessJob {
244244
processing_job: ProcessingJob::from(job),
245-
parameters: ProcessingJobParameter::from(parameter.unwrap()),
245+
parameters: parameter.map(ProcessingJobParameter::from),
246246
})
247247
.collect::<Vec<_>>();
248248

0 commit comments

Comments
 (0)