From eba1169d5294fd92acb27b188c1d2e9b1ed765a3 Mon Sep 17 00:00:00 2001
From: Aljaz <aljaz@ceru.si>
Date: Mon, 2 Jun 2025 14:04:01 +0200
Subject: [PATCH] Add local scheduler service

---
 requirements.txt       |  1 +
 src/local/__init__.py  |  0
 src/local/scheduler.py | 17 +++++++++++++++++
 3 files changed, 18 insertions(+)
 create mode 100644 src/local/__init__.py
 create mode 100644 src/local/scheduler.py

diff --git a/requirements.txt b/requirements.txt
index c46cb06..8520887 100644
--- a/requirements.txt
+++ b/requirements.txt
@@ -10,3 +10,4 @@ tqdm
 prometheus-clien
 redis
 minio
+schedule==1.*
diff --git a/src/local/__init__.py b/src/local/__init__.py
new file mode 100644
index 0000000..e69de29
diff --git a/src/local/scheduler.py b/src/local/scheduler.py
new file mode 100644
index 0000000..bf3a3ec
--- /dev/null
+++ b/src/local/scheduler.py
@@ -0,0 +1,17 @@
+import schedule
+import time
+from src.infra.lambdas.RSSQueueFiller.lambda.lambda_function import handler
+
+
+def run_queue_filler():
+    """Invoke the queue filler lambda logic."""
+    handler(None, None)
+
+
+schedule.every(4).hours.do(run_queue_filler)
+
+
+if __name__ == "__main__":
+    while True:
+        schedule.run_pending()
+        time.sleep(1)