chakcy_code_repository/queue_sqlite
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

modify: 修改支持版本

Browse Source
This commit is contained in:
chakcy 2025-10-19 21:23:55 +08:00
parent 0c8c6ffbc2
commit c6bcb64c61
4 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
.python-version
View File

@ -1 +1 @@
3.10 3.11

2
pyproject.toml
View File

@ -18,7 +18,7 @@ dependencies = [
description = "A high-performance, SQLite-based distributed task queue system with Rust-backed core operations. Supports task mounting, message listening, priority handling, retry mechanisms, and automatic cleanup of expired messages. Ideal for building reliable, scalable background task processing systems." description = "A high-performance, SQLite-based distributed task queue system with Rust-backed core operations. Supports task mounting, message listening, priority handling, retry mechanisms, and automatic cleanup of expired messages. Ideal for building reliable, scalable background task processing systems."
name = "queue-sqlite" name = "queue-sqlite"
readme = "README.md" readme = "README.md"
requires-python = ">=3.7" requires-python = ">=3.11"
version = "0.2.0" version = "0.2.0"
[project.optional-dependencies] [project.optional-dependencies]

2
tests/test_async_scheduler.py
View File

@ -27,7 +27,7 @@ class TestAsyncScheduler:
cls.callback_counter += 1 cls.callback_counter += 1
# if cls.callback_counter % 100 == 0: # 每100个任务打印一次 # if cls.callback_counter % 100 == 0: # 每100个任务打印一次
# print(f"callback: {cls.callback_counter}") # print(f"callback: {cls.callback_counter}")
print(f"callback: {message_item}") # print(f"callback: {message_item}")
# print(f"callback: {message_item.id}") # print(f"callback: {message_item.id}")
# print(f"callback: {message_item.expire_time}") # print(f"callback: {message_item.expire_time}")
# print(f"callback: {message_item.tags}") # print(f"callback: {message_item.tags}")

2
tests/test_stress.py
View File

@ -27,7 +27,7 @@ class TestStress:
cls.callback_counter += 1 cls.callback_counter += 1
# if cls.callback_counter % 100 == 0: # 每100个任务打印一次 # if cls.callback_counter % 100 == 0: # 每100个任务打印一次
# print(f"callback: {cls.callback_counter}") # print(f"callback: {cls.callback_counter}")
print(message_item.id) # print(message_item.id)
# print(f"callback: {message_item}") # print(f"callback: {message_item}")
# print(f"callback: {message_item.id}") # print(f"callback: {message_item.id}")
# print(f"callback: {message_item.expire_time}") # print(f"callback: {message_item.expire_time}")