From fac10845df36680da0b18f0cf22e585f2624c9d6 Mon Sep 17 00:00:00 2001 From: Ericson Fogo Soares Date: Wed, 7 Sep 2022 23:23:04 -0300 Subject: [PATCH] Missing job error from serde_json::Error --- core/src/job/mod.rs | 2 ++ core/src/location/indexer/indexer_job.rs | 3 +-- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/core/src/job/mod.rs b/core/src/job/mod.rs index 4bdb7d0b7..5eec57eb4 100644 --- a/core/src/job/mod.rs +++ b/core/src/job/mod.rs @@ -26,6 +26,8 @@ pub enum JobError { StateEncode(#[from] EncodeError), #[error("Job state decode error: {0}")] StateDecode(#[from] DecodeError), + #[error("Job metadata serialization error: {0}")] + MetadataSerialization(#[from] serde_json::Error), #[error("Tried to resume a job with unknown name: job ")] UnknownJobName(Uuid, String), #[error( diff --git a/core/src/location/indexer/indexer_job.rs b/core/src/location/indexer/indexer_job.rs index 933798964..3618e9d20 100644 --- a/core/src/location/indexer/indexer_job.rs +++ b/core/src/location/indexer/indexer_job.rs @@ -307,8 +307,7 @@ impl StatefulJob for IndexerJob { .expect("critical error: non-negative duration"), ); - // TODO: Serialize and return metadata here - Ok(None) + Ok(Some(serde_json::to_vec(state)?)) } }