diff --git a/frontend/src/pages/DataCollection/Create/CreateTask.tsx b/frontend/src/pages/DataCollection/Create/CreateTask.tsx
index 06a6f4d8..937aa159 100644
--- a/frontend/src/pages/DataCollection/Create/CreateTask.tsx
+++ b/frontend/src/pages/DataCollection/Create/CreateTask.tsx
@@ -59,9 +59,9 @@ export default function CollectionTaskCreate() {
     },
   });
   const [scheduleExpression, setScheduleExpression] = useState({
-    type: "once",
+    type: "daily",
     time: "00:00",
-    cronExpression: "0 0 0 * * ?",
+    cronExpression: "0 0 * * *",
   });
 
   useEffect(() => {
@@ -166,6 +166,17 @@ export default function CollectionTaskCreate() {
     try {
       const values = await form.validateFields();
       const payload = { ...newTask, ...values };
+      if (payload.syncMode === SyncMode.SCHEDULED) {
+        if (!payload.scheduleExpression) {
+          payload.scheduleExpression = scheduleExpression.cronExpression;
+        }
+        if (!payload.scheduleExpression) {
+          message.error("请输入Cron表达式");
+          return;
+        }
+      } else {
+        delete payload.scheduleExpression;
+      }
       if (selectedTemplate?.templateContent) {
         payload.config = {
           ...(payload.config || {}),
diff --git a/frontend/src/pages/DataCollection/Create/SimpleCronScheduler.tsx b/frontend/src/pages/DataCollection/Create/SimpleCronScheduler.tsx
index 097474d6..51c58a48 100644
--- a/frontend/src/pages/DataCollection/Create/SimpleCronScheduler.tsx
+++ b/frontend/src/pages/DataCollection/Create/SimpleCronScheduler.tsx
@@ -1,24 +1,16 @@
-import React, { useState, useCallback } from "react";
+import React, { useState, useCallback, useEffect } from "react";
 import {
-  Card,
-  Radio,
   Select,
   Space,
-  Typography,
   TimePicker,
   Button,
-  Input,
   Form,
 } from "antd";
-import type { RadioChangeEvent } from "antd";
 import type { Dayjs } from "dayjs";
 import dayjs from "dayjs";
 
-const { Text } = Typography;
-const { Option } = Select;
-
 export interface SimpleCronConfig {
-  type: "once" | "daily" | "weekly" | "monthly";
+  type: "daily" | "weekly" | "monthly";
   time?: string; // HH:mm 格式
   weekDay?: number; // 0-6, 0 表示周日
   monthDay?: number; // 1-31
@@ -32,9 +24,9 @@ interface SimpleCronSchedulerProps {
 }
 
 const defaultConfig: SimpleCronConfig = {
-  type: "once",
+  type: "daily",
   time: "00:00",
-  cronExpression: "0 0 0 * * ?",
+  cronExpression: "0 0 * * *",
 };
 
 // 生成周几选项
@@ -71,26 +63,33 @@ const SimpleCronScheduler: React.FC<SimpleCronSchedulerProps> = ({
 }) => {
   const [config, setConfig] = useState<SimpleCronConfig>(value);
 
+  useEffect(() => {
+    setConfig(value || defaultConfig);
+  }, [value]);
+
   // 更新配置并生成 cron 表达式
   const updateConfig = useCallback(
     (updates: Partial<SimpleCronConfig>) => {
       const newConfig = { ...config, ...updates };
       const [hour, minute] = (newConfig.time || "00:00").split(":");
+      if (newConfig.type === "weekly" && (newConfig.weekDay === undefined || newConfig.weekDay === null)) {
+        newConfig.weekDay = 1;
+      }
+      if (newConfig.type === "monthly" && (newConfig.monthDay === undefined || newConfig.monthDay === null)) {
+        newConfig.monthDay = 1;
+      }
 
       // 根据不同类型生成 cron 表达式
       let cronExpression = "";
       switch (newConfig.type) {
-        case "once":
-          cronExpression = `0 ${minute} ${hour} * * ?`;
-          break;
         case "daily":
-          cronExpression = `0 ${minute} ${hour} * * ?`;
+          cronExpression = `${minute} ${hour} * * *`;
           break;
         case "weekly":
-          cronExpression = `0 ${minute} ${hour} ? * ${newConfig.weekDay}`;
+          cronExpression = `${minute} ${hour} * * ${newConfig.weekDay}`;
           break;
         case "monthly":
-          cronExpression = `0 ${minute} ${hour} ${newConfig.monthDay} * ?`;
+          cronExpression = `${minute} ${hour} ${newConfig.monthDay} * *`;
           break;
       }
 
@@ -106,9 +105,9 @@ const SimpleCronScheduler: React.FC<SimpleCronSchedulerProps> = ({
     const updates: Partial<SimpleCronConfig> = { type };
 
     // 设置默认值
-    if (type === "weekly" && !config.weekDay) {
+    if (type === "weekly" && (config.weekDay === undefined || config.weekDay === null)) {
       updates.weekDay = 1; // 默认周一
-    } else if (type === "monthly" && !config.monthDay) {
+    } else if (type === "monthly" && (config.monthDay === undefined || config.monthDay === null)) {
       updates.monthDay = 1; // 默认每月1号
     }
 
@@ -133,7 +132,6 @@ const SimpleCronScheduler: React.FC<SimpleCronSchedulerProps> = ({
       <div className="grid grid-cols-2 gap-4">
         <Form.Item label="执行周期" required>
           <Select value={config.type} onChange={handleTypeChange}>
-            <Select.Option value="once">仅执行一次</Select.Option>
             <Select.Option value="daily">每天执行</Select.Option>
             <Select.Option value="weekly">每周执行</Select.Option>
             <Select.Option value="monthly">每月执行</Select.Option>
diff --git a/frontend/src/pages/DataManagement/dataset.const.tsx b/frontend/src/pages/DataManagement/dataset.const.tsx
index 219ac353..d5b70901 100644
--- a/frontend/src/pages/DataManagement/dataset.const.tsx
+++ b/frontend/src/pages/DataManagement/dataset.const.tsx
@@ -211,9 +211,7 @@ export function mapDataset(dataset: AnyObject): Dataset {
     status: datasetStatusMap[dataset.status],
     statistics: [
       { label: "文件数", value: dataset.fileCount || 0 },
-      { label: "已标注", value: Math.floor(dataset.fileCount / 10) * 10},
       { label: "大小", value: formatBytes(dataset.totalSize || 0) },
-      { label: "关联归集任务", value: Math.floor(dataset.fileCount / 10)},
     ],
     lastModified: dataset.updatedAt,
   };
diff --git a/runtime/datamate-python/app/main.py b/runtime/datamate-python/app/main.py
index a49d77fc..fbc66fe8 100644
--- a/runtime/datamate-python/app/main.py
+++ b/runtime/datamate-python/app/main.py
@@ -20,6 +20,11 @@
 )
 from .module import router
 from .module.shared.schema import StandardResponse
+from .module.collection.scheduler import (
+    start_collection_scheduler,
+    shutdown_collection_scheduler,
+    load_scheduled_collection_tasks,
+)
 
 setup_logging()
 logger = get_logger(__name__)
@@ -56,9 +61,14 @@ def mask_db_url(url: str) -> Literal[b""] | str:
     # TODO Add actual connectivity check if needed
     logger.info(f"Label Studio: {settings.label_studio_base_url}")
 
+    # Collection scheduler
+    start_collection_scheduler()
+    await load_scheduled_collection_tasks()
+
     yield
 
     # @shutdown
+    shutdown_collection_scheduler()
     logger.info("DataMate Python Backend shutting down ...\n\n")
 
 # 创建FastAPI应用
diff --git a/runtime/datamate-python/app/module/collection/interface/collection.py b/runtime/datamate-python/app/module/collection/interface/collection.py
index e36e3614..d447f9c4 100644
--- a/runtime/datamate-python/app/module/collection/interface/collection.py
+++ b/runtime/datamate-python/app/module/collection/interface/collection.py
@@ -14,7 +14,8 @@
 from app.db.session import get_db
 from app.module.collection.client.datax_client import DataxClient
 from app.module.collection.schema.collection import CollectionTaskBase, CollectionTaskCreate, converter_to_response, \
-    convert_for_create
+    convert_for_create, SyncMode
+from app.module.collection.scheduler import schedule_collection_task, remove_collection_task
 from app.module.collection.service.collection import CollectionTaskService
 from app.module.shared.schema import StandardResponse, PaginatedData
 
@@ -61,6 +62,8 @@ async def create_task(
         task = await db.execute(select(CollectionTask).where(CollectionTask.id == task.id))
         task = task.scalar_one_or_none()
         await db.commit()
+        if task and task.sync_mode == SyncMode.SCHEDULED.value and task.schedule_expression:
+            schedule_collection_task(task.id, task.schedule_expression)
 
         return StandardResponse(
             code=200,
@@ -70,6 +73,9 @@ async def create_task(
     except HTTPException:
         await db.rollback()
         raise
+    except ValueError as e:
+        await db.rollback()
+        raise HTTPException(status_code=400, detail=str(e))
     except Exception as e:
         await db.rollback()
         logger.error(f"Failed to create collection task: {str(e)}", e)
@@ -153,6 +159,7 @@ async def delete_collection_tasks(
             TaskExecution.__table__.delete()
             .where(TaskExecution.task_id == task_id)
         )
+        remove_collection_task(task_id)
 
         target_path = f"/dataset/local/{task_id}"
         if os.path.exists(target_path):
diff --git a/runtime/datamate-python/app/module/collection/scheduler.py b/runtime/datamate-python/app/module/collection/scheduler.py
new file mode 100644
index 00000000..72e4b19c
--- /dev/null
+++ b/runtime/datamate-python/app/module/collection/scheduler.py
@@ -0,0 +1,94 @@
+from __future__ import annotations
+
+from typing import Optional
+
+from apscheduler.schedulers.asyncio import AsyncIOScheduler
+from apscheduler.triggers.cron import CronTrigger
+from sqlalchemy import select
+
+from app.core.logging import get_logger
+from app.db.models.data_collection import CollectionTask
+from app.db.session import AsyncSessionLocal
+from app.module.collection.schema.collection import SyncMode
+
+logger = get_logger(__name__)
+
+_scheduler: Optional[AsyncIOScheduler] = None
+
+
+def start_collection_scheduler() -> AsyncIOScheduler:
+    global _scheduler
+    if _scheduler is None:
+        _scheduler = AsyncIOScheduler()
+        _scheduler.start()
+        logger.info("Collection scheduler started")
+    return _scheduler
+
+
+def shutdown_collection_scheduler() -> None:
+    global _scheduler
+    if _scheduler is not None:
+        _scheduler.shutdown(wait=False)
+        _scheduler = None
+        logger.info("Collection scheduler stopped")
+
+
+def _get_scheduler() -> AsyncIOScheduler:
+    if _scheduler is None:
+        raise RuntimeError("Collection scheduler not initialized")
+    return _scheduler
+
+
+def schedule_collection_task(task_id: str, schedule_expression: str, dataset_id: Optional[str] = None) -> None:
+    scheduler = _get_scheduler()
+    trigger = CronTrigger.from_crontab(schedule_expression)
+    from app.module.collection.service.collection import CollectionTaskService
+
+    scheduler.add_job(
+        CollectionTaskService.run_async,
+        trigger=trigger,
+        args=[task_id, dataset_id],
+        id=f"collection:{task_id}",
+        replace_existing=True,
+        max_instances=1,
+        coalesce=True,
+        misfire_grace_time=60,
+    )
+    logger.info(f"Scheduled collection task {task_id} with cron {schedule_expression}")
+
+
+def remove_collection_task(task_id: str) -> None:
+    if _scheduler is None:
+        return
+    job_id = f"collection:{task_id}"
+    if _scheduler.get_job(job_id):
+        _scheduler.remove_job(job_id)
+        logger.info(f"Removed scheduled collection task {task_id}")
+
+
+def reschedule_collection_task(task_id: str, schedule_expression: str, dataset_id: Optional[str] = None) -> None:
+    remove_collection_task(task_id)
+    schedule_collection_task(task_id, schedule_expression, dataset_id)
+
+
+def validate_schedule_expression(schedule_expression: str) -> None:
+    CronTrigger.from_crontab(schedule_expression)
+
+
+async def load_scheduled_collection_tasks() -> None:
+    async with AsyncSessionLocal() as session:
+        result = await session.execute(
+            select(CollectionTask).where(
+                CollectionTask.sync_mode == SyncMode.SCHEDULED.value,
+                CollectionTask.schedule_expression.isnot(None),
+            )
+        )
+        tasks = result.scalars().all()
+
+    for task in tasks:
+        if not task.schedule_expression:
+            continue
+        try:
+            schedule_collection_task(task.id, task.schedule_expression)
+        except Exception as exc:
+            logger.error(f"Failed to schedule task {task.id}: {exc}")
diff --git a/runtime/datamate-python/app/module/collection/schema/collection.py b/runtime/datamate-python/app/module/collection/schema/collection.py
index be7faf76..387cc9e8 100644
--- a/runtime/datamate-python/app/module/collection/schema/collection.py
+++ b/runtime/datamate-python/app/module/collection/schema/collection.py
@@ -84,6 +84,7 @@ def converter_to_response(task: CollectionTask) -> CollectionTaskBase:
     )
 
 def convert_for_create(task: CollectionTaskCreate, task_id: str) -> CollectionTask:
+    schedule_expression = task.schedule_expression if task.sync_mode == SyncMode.SCHEDULED else None
     return CollectionTask(
         id=task_id,
         name=task.name,
@@ -92,7 +93,7 @@ def convert_for_create(task: CollectionTaskCreate, task_id: str) -> CollectionTa
         template_id=task.template_id,
         target_path=f"/dataset/local/{task_id}",
         config=json.dumps(task.config.dict()),
-        schedule_expression=task.schedule_expression,
+        schedule_expression=schedule_expression,
         status=TaskStatus.PENDING.name
     )
 
diff --git a/runtime/datamate-python/app/module/collection/service/collection.py b/runtime/datamate-python/app/module/collection/service/collection.py
index dc0a674d..46ca07d6 100644
--- a/runtime/datamate-python/app/module/collection/service/collection.py
+++ b/runtime/datamate-python/app/module/collection/service/collection.py
@@ -12,6 +12,7 @@
 from app.db.session import AsyncSessionLocal
 from app.module.collection.client.datax_client import DataxClient
 from app.module.collection.schema.collection import SyncMode, create_execute_record
+from app.module.collection.scheduler import validate_schedule_expression
 from app.module.dataset.service.service import Service
 from app.module.shared.schema import TaskStatus, NodeType, EdgeType
 from app.module.shared.common.lineage import LineageService
@@ -51,6 +52,10 @@ async def create_task(self, task: CollectionTask, dataset: Dataset) -> Collectio
             task.status = TaskStatus.RUNNING.name
             await self.db.commit()
             asyncio.create_task(CollectionTaskService.run_async(task.id, dataset.id if dataset else None))
+        elif task.sync_mode == SyncMode.SCHEDULED:
+            if not task.schedule_expression:
+                raise ValueError("schedule_expression is required for scheduled tasks")
+            validate_schedule_expression(task.schedule_expression)
         return task
 
     @staticmethod
diff --git a/runtime/datamate-python/deploy/docker-entrypoint.sh b/runtime/datamate-python/deploy/docker-entrypoint.sh
index 7cbca6ff..b560a003 100755
--- a/runtime/datamate-python/deploy/docker-entrypoint.sh
+++ b/runtime/datamate-python/deploy/docker-entrypoint.sh
@@ -7,7 +7,7 @@ fi
 
 # 启动应用
 echo "=========================================="
-echo "Starting Label Studio Adapter..."
+echo "Starting DataMate Backend Service..."
 echo "Host: ${HOST:-0.0.0.0}"
 echo "Port: ${PORT:-18000}"
 echo "Debug: ${DEBUG:-false}"
diff --git a/runtime/datamate-python/poetry.lock b/runtime/datamate-python/poetry.lock
index 1556f130..5c4db4a1 100644
--- a/runtime/datamate-python/poetry.lock
+++ b/runtime/datamate-python/poetry.lock
@@ -263,6 +263,34 @@ typing_extensions = {version = ">=4.5", markers = "python_version < \"3.13\""}
 [package.extras]
 trio = ["trio (>=0.31.0) ; python_version < \"3.10\"", "trio (>=0.32.0) ; python_version >= \"3.10\""]
 
+[[package]]
+name = "apscheduler"
+version = "3.11.2"
+description = "In-process task scheduler with Cron-like capabilities"
+optional = false
+python-versions = ">=3.8"
+groups = ["main"]
+files = [
+    {file = "apscheduler-3.11.2-py3-none-any.whl", hash = "sha256:ce005177f741409db4e4dd40a7431b76feb856b9dd69d57e0da49d6715bfd26d"},
+    {file = "apscheduler-3.11.2.tar.gz", hash = "sha256:2a9966b052ec805f020c8c4c3ae6e6a06e24b1bf19f2e11d91d8cca0473eef41"},
+]
+
+[package.dependencies]
+tzlocal = ">=3.0"
+
+[package.extras]
+doc = ["packaging", "sphinx", "sphinx-rtd-theme (>=1.3.0)"]
+etcd = ["etcd3", "protobuf (<=3.21.0)"]
+gevent = ["gevent"]
+mongodb = ["pymongo (>=3.0)"]
+redis = ["redis (>=3.0)"]
+rethinkdb = ["rethinkdb (>=2.4.0)"]
+sqlalchemy = ["sqlalchemy (>=1.4)"]
+test = ["APScheduler[etcd,mongodb,redis,rethinkdb,sqlalchemy,tornado,zookeeper]", "PySide6 ; platform_python_implementation == \"CPython\" and python_version < \"3.14\"", "anyio (>=4.5.2)", "gevent ; python_version < \"3.14\"", "pytest", "pytest-timeout", "pytz", "twisted ; python_version < \"3.14\""]
+tornado = ["tornado (>=4.3)"]
+twisted = ["twisted"]
+zookeeper = ["kazoo"]
+
 [[package]]
 name = "ascii-colors"
 version = "0.11.7"
@@ -4082,12 +4110,14 @@ optional = false
 python-versions = ">=3.7"
 groups = ["main"]
 files = [
+    {file = "sqlalchemy-2.0.45-cp310-cp310-macosx_11_0_arm64.whl", hash = "sha256:c64772786d9eee72d4d3784c28f0a636af5b0a29f3fe26ff11f55efe90c0bd85"},
     {file = "sqlalchemy-2.0.45-cp310-cp310-manylinux2014_aarch64.manylinux_2_17_aarch64.manylinux_2_28_aarch64.whl", hash = "sha256:7ae64ebf7657395824a19bca98ab10eb9a3ecb026bf09524014f1bb81cb598d4"},
     {file = "sqlalchemy-2.0.45-cp310-cp310-manylinux2014_x86_64.manylinux_2_17_x86_64.manylinux_2_28_x86_64.whl", hash = "sha256:0f02325709d1b1a1489f23a39b318e175a171497374149eae74d612634b234c0"},
     {file = "sqlalchemy-2.0.45-cp310-cp310-musllinux_1_2_aarch64.whl", hash = "sha256:d2c3684fca8a05f0ac1d9a21c1f4a266983a7ea9180efb80ffeb03861ecd01a0"},
     {file = "sqlalchemy-2.0.45-cp310-cp310-musllinux_1_2_x86_64.whl", hash = "sha256:040f6f0545b3b7da6b9317fc3e922c9a98fc7243b2a1b39f78390fc0942f7826"},
     {file = "sqlalchemy-2.0.45-cp310-cp310-win32.whl", hash = "sha256:830d434d609fe7bfa47c425c445a8b37929f140a7a44cdaf77f6d34df3a7296a"},
     {file = "sqlalchemy-2.0.45-cp310-cp310-win_amd64.whl", hash = "sha256:0209d9753671b0da74da2cfbb9ecf9c02f72a759e4b018b3ab35f244c91842c7"},
+    {file = "sqlalchemy-2.0.45-cp311-cp311-macosx_11_0_arm64.whl", hash = "sha256:2e90a344c644a4fa871eb01809c32096487928bd2038bf10f3e4515cb688cc56"},
     {file = "sqlalchemy-2.0.45-cp311-cp311-manylinux2014_aarch64.manylinux_2_17_aarch64.manylinux_2_28_aarch64.whl", hash = "sha256:b8c8b41b97fba5f62349aa285654230296829672fc9939cd7f35aab246d1c08b"},
     {file = "sqlalchemy-2.0.45-cp311-cp311-manylinux2014_x86_64.manylinux_2_17_x86_64.manylinux_2_28_x86_64.whl", hash = "sha256:12c694ed6468333a090d2f60950e4250b928f457e4962389553d6ba5fe9951ac"},
     {file = "sqlalchemy-2.0.45-cp311-cp311-musllinux_1_2_aarch64.whl", hash = "sha256:f7d27a1d977a1cfef38a0e2e1ca86f09c4212666ce34e6ae542f3ed0a33bc606"},
@@ -4116,12 +4146,14 @@ files = [
     {file = "sqlalchemy-2.0.45-cp314-cp314-win_amd64.whl", hash = "sha256:4748601c8ea959e37e03d13dcda4a44837afcd1b21338e637f7c935b8da06177"},
     {file = "sqlalchemy-2.0.45-cp314-cp314t-manylinux2014_x86_64.manylinux_2_17_x86_64.manylinux_2_28_x86_64.whl", hash = "sha256:cd337d3526ec5298f67d6a30bbbe4ed7e5e68862f0bf6dd21d289f8d37b7d60b"},
     {file = "sqlalchemy-2.0.45-cp314-cp314t-musllinux_1_2_x86_64.whl", hash = "sha256:9a62b446b7d86a3909abbcd1cd3cc550a832f99c2bc37c5b22e1925438b9367b"},
+    {file = "sqlalchemy-2.0.45-cp38-cp38-macosx_11_0_arm64.whl", hash = "sha256:5964f832431b7cdfaaa22a660b4c7eb1dfcd6ed41375f67fd3e3440fd95cb3cc"},
     {file = "sqlalchemy-2.0.45-cp38-cp38-manylinux2014_aarch64.manylinux_2_17_aarch64.manylinux_2_28_aarch64.whl", hash = "sha256:ee580ab50e748208754ae8980cec79ec205983d8cf8b3f7c39067f3d9f2c8e22"},
     {file = "sqlalchemy-2.0.45-cp38-cp38-manylinux2014_x86_64.manylinux_2_17_x86_64.manylinux_2_28_x86_64.whl", hash = "sha256:13e27397a7810163440c6bfed6b3fe46f1bfb2486eb540315a819abd2c004128"},
     {file = "sqlalchemy-2.0.45-cp38-cp38-musllinux_1_2_aarch64.whl", hash = "sha256:ed3635353e55d28e7f4a95c8eda98a5cdc0a0b40b528433fbd41a9ae88f55b3d"},
     {file = "sqlalchemy-2.0.45-cp38-cp38-musllinux_1_2_x86_64.whl", hash = "sha256:db6834900338fb13a9123307f0c2cbb1f890a8656fcd5e5448ae3ad5bbe8d312"},
     {file = "sqlalchemy-2.0.45-cp38-cp38-win32.whl", hash = "sha256:1d8b4a7a8c9b537509d56d5cd10ecdcfbb95912d72480c8861524efecc6a3fff"},
     {file = "sqlalchemy-2.0.45-cp38-cp38-win_amd64.whl", hash = "sha256:ebd300afd2b62679203435f596b2601adafe546cb7282d5a0cd3ed99e423720f"},
+    {file = "sqlalchemy-2.0.45-cp39-cp39-macosx_11_0_arm64.whl", hash = "sha256:d29b2b99d527dbc66dd87c3c3248a5dd789d974a507f4653c969999fc7c1191b"},
     {file = "sqlalchemy-2.0.45-cp39-cp39-manylinux2014_aarch64.manylinux_2_17_aarch64.manylinux_2_28_aarch64.whl", hash = "sha256:59a8b8bd9c6bedf81ad07c8bd5543eedca55fe9b8780b2b628d495ba55f8db1e"},
     {file = "sqlalchemy-2.0.45-cp39-cp39-manylinux2014_x86_64.manylinux_2_17_x86_64.manylinux_2_28_x86_64.whl", hash = "sha256:fd93c6f5d65f254ceabe97548c709e073d6da9883343adaa51bf1a913ce93f8e"},
     {file = "sqlalchemy-2.0.45-cp39-cp39-musllinux_1_2_aarch64.whl", hash = "sha256:6d0beadc2535157070c9c17ecf25ecec31e13c229a8f69196d7590bde8082bf1"},
@@ -4444,6 +4476,24 @@ files = [
     {file = "tzdata-2025.3.tar.gz", hash = "sha256:de39c2ca5dc7b0344f2eba86f49d614019d29f060fc4ebc8a417896a620b56a7"},
 ]
 
+[[package]]
+name = "tzlocal"
+version = "5.3.1"
+description = "tzinfo object for the local timezone"
+optional = false
+python-versions = ">=3.9"
+groups = ["main"]
+files = [
+    {file = "tzlocal-5.3.1-py3-none-any.whl", hash = "sha256:eb1a66c3ef5847adf7a834f1be0800581b683b5608e74f86ecbcef8ab91bb85d"},
+    {file = "tzlocal-5.3.1.tar.gz", hash = "sha256:cceffc7edecefea1f595541dbd6e990cb1ea3d19bf01b2809f362a03dd7921fd"},
+]
+
+[package.dependencies]
+tzdata = {version = "*", markers = "platform_system == \"Windows\""}
+
+[package.extras]
+devenv = ["check-manifest", "pytest (>=4.3)", "pytest-cov", "pytest-mock (>=3.3)", "zest.releaser"]
+
 [[package]]
 name = "unstructured"
 version = "0.18.27"
@@ -5429,4 +5479,4 @@ cffi = ["cffi (>=1.17,<2.0) ; platform_python_implementation != \"PyPy\" and pyt
 [metadata]
 lock-version = "2.1"
 python-versions = ">=3.12,<4.0.0"
-content-hash = "9ff6942c5f12288e198a6a9aff9e0fd6550403b9fe36b694192cf771334a8f70"
+content-hash = "3a84e7e5ec3874279a429a3b609f5d9c32794c8d0e422b2f93e1dbf3f24fc38e"
diff --git a/runtime/datamate-python/pyproject.toml b/runtime/datamate-python/pyproject.toml
index 14407902..c29a95a7 100644
--- a/runtime/datamate-python/pyproject.toml
+++ b/runtime/datamate-python/pyproject.toml
@@ -36,6 +36,7 @@ dependencies = [
     "asyncpg (>=0.31.0,<0.32.0)",
     "lightrag-hku (==1.4.9.8)",
     "pytest (>=9.0.2,<10.0.0)",
+    "apscheduler (>=3.11.2,<4.0.0)",
 ]