From 45817e5542fbb58ed7c6bbaf9b3441f9bdaa3cb0 Mon Sep 17 00:00:00 2001
From: chakcy <947105045@qq.com>
Date: Thu, 6 Nov 2025 10:16:30 +0800
Subject: [PATCH] =?UTF-8?q?modify:=20=E5=B0=86=20QApplication=20=E5=AE=9E?=
 =?UTF-8?q?=E4=BE=8B=E5=88=9D=E5=A7=8B=E5=8C=96=E8=B0=83=E6=95=B4=E5=88=B0?=
 =?UTF-8?q?=E8=B0=83=E5=BA=A6=E5=99=A8=20start=20=E9=98=B6=E6=AE=B5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/queue_sqlite/scheduler/qt/__init__.py   | 4 ++--
 src/queue_sqlite_core/pyproject.toml        | 3 ---
 src/queue_sqlite_core/queue_sqlite_core.pyi | 2 ++
 3 files changed, 4 insertions(+), 5 deletions(-)

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): ...