feat(git-sync): sync jobs debouncing [merge-ee-first]

backend/Cargo.toml

@@ -49,7 +49,7 @@ incremental = true
 lto = "thin"
 
 [features]
-default = []
+default = ["enterprise", "private", "python", "license"]
 private = ["windmill-api/private", "windmill-autoscaling/private", "windmill-common/private", "windmill-git-sync/private", "windmill-indexer/private", "windmill-queue/private", "windmill-worker/private"]
 agent_worker_server = ["windmill-api/agent_worker_server"]
 enterprise = ["windmill-worker/enterprise", "windmill-queue/enterprise", "windmill-api/enterprise", "dep:windmill-autoscaling", "windmill-autoscaling/enterprise", "windmill-git-sync/enterprise", "windmill-common/prometheus", "windmill-common/enterprise"]

backend/ee-repo-ref.txt

@@ -1 +1 @@
-5c2a8854e7ff014063a69dd8f7829a935129c31e
+a46502cd9e494c67866ec9095a49bb1873448eb1

backend/windmill-common/src/jobs.rs

@@ -482,7 +482,7 @@ pub enum JobPayload {
     },
     DeploymentCallback {
         path: String,
-        // debouncing_settings: Option<DebouncingSettings>,
+        debouncing_settings: DebouncingSettings,
     },
     Identity,
     Noop,

backend/windmill-common/src/worker.rs

@@ -265,6 +265,7 @@ lazy_static::lazy_static! {
     .unwrap_or(false);
 
     pub static ref MIN_VERSION: Arc<RwLock<Version>> = Arc::new(RwLock::new(Version::new(0, 0, 0)));
+    pub static ref MIN_VERSION_SUPPORTS_SYNC_JOBS_DEBOUNCING: Arc<RwLock<bool>> = Arc::new(RwLock::new(false));
     pub static ref MIN_VERSION_SUPPORTS_DEBOUNCING_V2: Arc<RwLock<bool>> = Arc::new(RwLock::new(false));
     pub static ref MIN_VERSION_SUPPORTS_RUNNABLE_SETTINGS_V0: Arc<RwLock<bool>> = Arc::new(RwLock::new(false));
     /// Global flag indicating if all workers support workspace dependencies feature (>= 1.583.0)
@@ -1295,6 +1296,8 @@ pub async fn update_min_version(conn: &Connection) -> bool {
         tracing::info!("Minimal worker version: {min_version}");
     }
 
+    *MIN_VERSION_SUPPORTS_SYNC_JOBS_DEBOUNCING.write().await =
+        min_version >= Version::new(1, 999, 0); // todo
     *MIN_VERSION_SUPPORTS_DEBOUNCING_V2.write().await = min_version >= Version::new(1, 597, 0);
     *MIN_VERSION_SUPPORTS_RUNNABLE_SETTINGS_V0.write().await =
         min_version >= *crate::runnable_settings::MIN_VERSION_RUNNABLE_SETTINGS_V0;

backend/windmill-common/src/workspaces.rs

@@ -6,7 +6,7 @@ use serde::{Deserialize, Serialize};
 use strum::AsRefStr;
 
 use crate::{
-    error::{to_anyhow, Error, Result},
+    error::{self, to_anyhow, Error, Result},
     get_database_url,
     utils::get_custom_pg_instance_password,
     variables::{build_crypt, decrypt},
@@ -63,6 +63,31 @@ pub struct GitRepositorySettings {
     pub settings: Option<GitSyncSettings>,
 }
 
+impl GitRepositorySettings {
+    pub fn is_script_meets_min_version(&self, min_version: u32) -> error::Result<bool> {
+        // example: "hub/28102/sync-script-to-git-repo-windmill"
+        let current: u32 = self
+            .script_path
+            .split("/") // -> ["hub" "28102" "sync-script-to-git-repo-windmill"]
+            .skip(1) // emit "hub"
+            .next() // get numeric id
+            .ok_or(Error::InternalErr(format!(
+                "cannot get script version id from: {}",
+                &self.script_path
+            )))
+            .and_then(|s| {
+                s.parse().map_err(|e| {
+                    Error::InternalErr(format!(
+                        "cannot get script version id from: {}. e: {e}",
+                        &self.script_path
+                    ))
+                })
+            })?;
+
+        Ok(current >= min_version) // this works on assumption that all scripts in hub have sequential ids
+    }
+}
+
 #[derive(Serialize, Deserialize, Debug)]
 pub struct GitSyncSettings {
     pub include_path: Vec<String>,

backend/windmill-queue/src/jobs.rs

@@ -4833,14 +4833,15 @@ pub async fn push<'c, 'd>(
                 ..Default::default()
             }
         }
-        JobPayload::DeploymentCallback { path } => JobPayloadUntagged {
+        JobPayload::DeploymentCallback { path, debouncing_settings } => JobPayloadUntagged {
             runnable_path: Some(path.clone()),
             job_kind: JobKind::DeploymentCallback,
             concurrency_settings: ConcurrencySettings {
                 concurrency_key: Some(format!("{workspace_id}:git_sync")),
                 concurrent_limit: Some(1),
                 concurrency_time_window_s: Some(0),
             },
+            debouncing_settings,
             ..Default::default()
         },
         JobPayload::Identity => {