From 09d26e34f2a487e983c8816f0445b10a80a79ad0 Mon Sep 17 00:00:00 2001
From: Jagmeet Bali <jagmeet.bali@gmail.com>
Date: Tue, 17 Mar 2026 17:37:07 +0530
Subject: [PATCH 1/2] Cron v1

---
 Cargo.lock                  | 18 +++++++++++++++---
 lib/observo/private         |  2 +-
 lib/observo/scol/Cargo.toml |  1 +
 src/sources/scol/mod.rs     |  1 +
 4 files changed, 18 insertions(+), 4 deletions(-)

diff --git a/Cargo.lock b/Cargo.lock
index 008ccfe44..ee25bcbd3 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -2974,6 +2974,17 @@ dependencies = [
  "itertools 0.10.5",
 ]
 
+[[package]]
+name = "cron"
+version = "0.15.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "5877d3fbf742507b66bc2a1945106bd30dd8504019d596901ddd012a4dd01740"
+dependencies = [
+ "chrono",
+ "once_cell",
+ "winnow 0.6.26",
+]
+
 [[package]]
 name = "crossbeam-channel"
 version = "0.5.8"
@@ -10006,6 +10017,7 @@ dependencies = [
  "bytes 1.9.0",
  "chkpts",
  "chrono",
+ "cron",
  "dashmap 5.5.3",
  "futures 0.3.31",
  "futures-util",
@@ -11618,7 +11630,7 @@ dependencies = [
  "serde",
  "serde_spanned",
  "toml_datetime",
- "winnow 0.6.18",
+ "winnow 0.6.26",
 ]
 
 [[package]]
@@ -13759,9 +13771,9 @@ dependencies = [
 
 [[package]]
 name = "winnow"
-version = "0.6.18"
+version = "0.6.26"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "68a9bda4691f099d435ad181000724da8e5899daa10713c2d432552b9ccd3a6f"
+checksum = "1e90edd2ac1aa278a5c4599b1d89cf03074b610800f866d4026dc199d7929a28"
 dependencies = [
  "memchr",
 ]
diff --git a/lib/observo/private b/lib/observo/private
index 508509552..01b9ffb1b 160000
--- a/lib/observo/private
+++ b/lib/observo/private
@@ -1 +1 @@
-Subproject commit 508509552db486317addda31f361a7561b5336be
+Subproject commit 01b9ffb1b7779408f0bccb862fcae5868efe580a
diff --git a/lib/observo/scol/Cargo.toml b/lib/observo/scol/Cargo.toml
index 803b55254..cfcf9fc23 100644
--- a/lib/observo/scol/Cargo.toml
+++ b/lib/observo/scol/Cargo.toml
@@ -48,6 +48,7 @@ once_cell = { version = "1.21" }
 url.workspace = true
 rand.workspace = true
 chrono.workspace = true
+cron = "0.15"
 bstr = { version = "1.0", features = ["std"], default-features = false }
 hyper.workspace = true
 itertools.workspace = true
diff --git a/src/sources/scol/mod.rs b/src/sources/scol/mod.rs
index 1e12ef700..6aed36df3 100644
--- a/src/sources/scol/mod.rs
+++ b/src/sources/scol/mod.rs
@@ -19,6 +19,7 @@ use crate::config::{SourceConfig, SourceContext};
 #[typetag::serde(name = "scol")]
 impl SourceConfig for Config {
     async fn build(&self, cx: SourceContext) -> Result<Source> {
+        self.trigger.validate()?;
         let lns = cx.log_namespace(self.log_namespace);
         let chkptr = cx.checkpoint_accessor().await;
         let src = self

From ef4bcc82e1121ada8bf21f83799161cc838ec459 Mon Sep 17 00:00:00 2001
From: Jagmeet Bali <jagmeet.bali@gmail.com>
Date: Tue, 9 Jun 2026 11:44:11 +0530
Subject: [PATCH 2/2] Cron v1

---
 src/sources/scol/mod.rs | 1 -
 1 file changed, 1 deletion(-)

diff --git a/src/sources/scol/mod.rs b/src/sources/scol/mod.rs
index 6aed36df3..1e12ef700 100644
--- a/src/sources/scol/mod.rs
+++ b/src/sources/scol/mod.rs
@@ -19,7 +19,6 @@ use crate::config::{SourceConfig, SourceContext};
 #[typetag::serde(name = "scol")]
 impl SourceConfig for Config {
     async fn build(&self, cx: SourceContext) -> Result<Source> {
-        self.trigger.validate()?;
         let lns = cx.log_namespace(self.log_namespace);
         let chkptr = cx.checkpoint_accessor().await;
         let src = self