Add APScheduler for cron job management

- Introduced APScheduler as a dependency in `pyproject.toml` to facilitate scheduled tasks.
- Implemented a cron job in `main.py` that triggers the `trigger_cron` function every minute.
- Created a new `trigger_cron.py` file to define the task executed by the scheduler.

This enhancement allows for periodic execution of tasks, improving the application's scheduling capabilities.

Author: NiveditJain

state-manager/app/main.py

@@ -33,10 +33,17 @@
 
 # importing database health check function
 from .utils.check_database_health import check_database_health
+
+#scheduler
+from apscheduler.schedulers.asyncio import AsyncIOScheduler
+from apscheduler.triggers.cron import CronTrigger
+from .tasks.trigger_cron import trigger_cron
 
 # Define models list
 DOCUMENT_MODELS = [State, GraphTemplate, RegisteredNode, Store, Run, DatabaseTriggers]
 
+scheduler = AsyncIOScheduler()
+
 @asynccontextmanager
 async def lifespan(app: FastAPI):
     # begaining of the server
@@ -60,11 +67,20 @@ async def lifespan(app: FastAPI):
     # perform database health check
     await check_database_health(DOCUMENT_MODELS)
 
+    scheduler.add_job(
+        trigger_cron,
+        CronTrigger.from_crontab("* * * * *"),
+        replace_existing=True,
+        id="every_minute_task"
+    )
+    scheduler.start()
+
     # main logic of the server
     yield
 
     # end of the server
     await client.close()
+    scheduler.shutdown()
     logger.info("server stopped")
 
 

state-manager/app/tasks/trigger_cron.py

@@ -0,0 +1,4 @@
+from datetime import datetime
+
+async def trigger_cron():
+    print(f"From trigger_cron: {datetime.now()}")

state-manager/pyproject.toml

@@ -9,6 +9,7 @@ description = "Add your description here"
 readme = "README.md"
 requires-python = ">=3.12"
 dependencies = [
+    "apscheduler>=3.11.0",
     "beanie>=2.0.0",
     "croniter>=6.0.0",
     "cryptography>=45.0.5",