fix migration

backend/Cargo.lock

@@ -7356,6 +7356,7 @@ version = "1.172.1"
 dependencies = [
  "anyhow",
  "async-recursion",
+ "bigdecimal",
  "chrono",
  "chrono-tz",
  "cron",

backend/Cargo.toml

@@ -157,6 +157,7 @@ sqlx = { version = "^0", features = [
     "runtime-tokio-rustls",
     "bigdecimal"
 ] }
+bigdecimal = "^0"
 dotenv = "^0"
 ulid = { version = "^1", features = ["uuid"] }
 futures = "^0"

backend/windmill-queue/Cargo.toml

@@ -37,3 +37,4 @@ tokio.workspace = true
 futures-core.workspace = true
 itertools.workspace = true
 async-recursion.workspace = true
+bigdecimal.workspace = true

backend/windmill-queue/src/jobs.rs

@@ -8,16 +8,16 @@
 
 use std::{collections::HashMap, sync::atomic::AtomicBool, vec};
 
-#[cfg(feature = "benchmark")]
-use std::time::Instant;
-
 use anyhow::Context;
 use async_recursion::async_recursion;
+use bigdecimal::ToPrimitive;
 use chrono::{DateTime, Duration, Utc};
 use reqwest::Client;
 use rsmq_async::RsmqConnection;
 use serde_json::json;
 use sqlx::{Pool, Postgres, Transaction};
+#[cfg(feature = "benchmark")]
+use std::time::Instant;
 use tracing::{instrument, Instrument};
 use ulid::Ulid;
 use uuid::Uuid;
@@ -236,6 +236,8 @@ pub async fn add_completed_job<R: rsmq_async::RsmqConnection + Clone + Send>(
             .await
             .ok()
             .flatten()
+            .map(|x| x.to_i64())
+            .flatten()
         } else {
             tracing::warn!("Could not parse flow status");
             None