From f63c8349f47fcd23c1504827774e697cf1cdd921 Mon Sep 17 00:00:00 2001 From: Ruben Fiszel Date: Sun, 19 May 2024 22:21:18 +0200 Subject: [PATCH] sleep handle f64 --- backend/windmill-worker/src/worker_flow.rs | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/backend/windmill-worker/src/worker_flow.rs b/backend/windmill-worker/src/worker_flow.rs index 0af575d704..e6393d097e 100644 --- a/backend/windmill-worker/src/worker_flow.rs +++ b/backend/windmill-worker/src/worker_flow.rs @@ -1743,13 +1743,16 @@ async fn push_next_flow_job }; match json_value.and_then(|x| serde_json::from_str::(x.get())) { Ok(serde_json::Value::Number(n)) => { - if !n.is_u64() { + if n.is_f64() { + n.as_f64() + .map(|x: f64| from_now(Duration::from_millis((x * 1000.0) as u64))) + } else if n.is_u64() { + n.as_u64().map(|x: u64| from_now(Duration::from_secs(x))) + } else { return Err(Error::ExecutionErr(format!( "Expected an integer, found: {n}" ))); } - - n.as_u64().map(|x| from_now(Duration::from_secs(x))) } Ok(x @ _) => Err(Error::ExecutionErr(format!( "Expected an integer, found: {x:?}"