diff --git a/src/queue_sqlite/scheduler/qt/__init__.py b/src/queue_sqlite/scheduler/qt/__init__.py index 9f2a2ff..cb853d9 100644 --- a/src/queue_sqlite/scheduler/qt/__init__.py +++ b/src/queue_sqlite/scheduler/qt/__init__.py @@ -32,8 +32,6 @@ class QtQueueScheduler(BaseScheduler): self, config: SchedulerConfig = SchedulerConfig(), ): - # 确保有 QApplication 实例(对于 GUI 应用) - self._ensure_qapplication() # 初始化队列操作 self.queue_operation = ShardedQueueOperation( @@ -137,6 +135,8 @@ class QtQueueScheduler(BaseScheduler): def start(self): """启动所有调度器组件""" + # 确保有 QApplication 实例(对于 GUI 应用) + self._ensure_qapplication() self.receive_scheduler.start() self.task_scheduler.start() self.cleanup_scheduler.start_cleanup() diff --git a/src/queue_sqlite_core/pyproject.toml b/src/queue_sqlite_core/pyproject.toml index d2457be..296becd 100644 --- a/src/queue_sqlite_core/pyproject.toml +++ b/src/queue_sqlite_core/pyproject.toml @@ -26,6 +26,3 @@ dev = [ "twine>=4.0.2", "maturin>=1.9.4", ] - -[[tool.uv.index]] -url = "https://pypi.tuna.tsinghua.edu.cn/simple" diff --git a/src/queue_sqlite_core/queue_sqlite_core.pyi b/src/queue_sqlite_core/queue_sqlite_core.pyi index 1a1ee37..90f9d0b 100644 --- a/src/queue_sqlite_core/queue_sqlite_core.pyi +++ b/src/queue_sqlite_core/queue_sqlite_core.pyi @@ -16,6 +16,8 @@ class QueueOperation: def remove_expired_messages(self, days: int) -> None: ... class ShardedQueueOperation: + @property + def shard_num(self) -> int: ... @property def db_dir(self) -> str: ... def __init__(self, shard_num: int, queue_name: str): ...