remove anyhow dependency

oac1771 · Dec 8, 2024 · 667b3ea · 667b3ea
1 parent dffb647
commit 667b3ea
Show file tree

Hide file tree

Showing 5 changed files with 7 additions and 11 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/crates/clis/requester/src/error.rs b/crates/clis/requester/src/error.rs
@@ -35,7 +35,4 @@ pub enum Error {
 
     #[error("")]
     NetworkHandlerStopped,
-
-    #[error(transparent)]
-    Unknown(#[from] anyhow::Error),
 }
diff --git a/crates/clis/worker/src/error.rs b/crates/clis/worker/src/error.rs
@@ -32,7 +32,4 @@ pub enum Error {
 
     #[error("")]
     WorkerStoppedUnexpectedly,
-
-    #[error(transparent)]
-    Unknown(#[from] anyhow::Error),
 }
diff --git a/crates/utils/Cargo.toml b/crates/utils/Cargo.toml
@@ -27,7 +27,6 @@ wasmtime = { workspace = true }
 pallet-contracts = { workspace = true, default-features = false }
 sp-runtime = { workspace = true, default-features = false }
 sp-weights = { workspace = true, default-features = false }
-anyhow = { workspace = true}
 
 catalog = { workspace = true }
 async-stream = "0.3.6"

diff --git a/crates/utils/src/services/job/job_runner.rs b/crates/utils/src/services/job/job_runner.rs
@@ -53,9 +53,10 @@ impl WasmJobRunner {
         params: Vec<Val>,
         mut results: Vec<Val>,
         store: Store<()>,
-    ) -> Result<JoinHandle<anyhow::Result<RawResults>>, Error> {
-        let job_handle: JoinHandle<anyhow::Result<RawResults>> = tokio::spawn(async move {
-            func.call(store, &params, &mut results)?;
+    ) -> Result<JoinHandle<Result<RawResults, Error>>, Error> {
+        let job_handle: JoinHandle<Result<RawResults, Error>> = tokio::spawn(async move {
+            func.call(store, &params, &mut results)
+                .map_err(|e| Error::JobError { err: e.to_string() })?;
             let result = results
                 .iter()
                 .map(|v| match v {
@@ -223,6 +224,9 @@ pub enum Error {
         source: codec::Error,
     },
 
+    #[error("{err}")]
+    JobError { err: String },
+
     #[error("")]
     FuncTypeNotFound,