Skip to content

Releases: liuhuo23/taskmq

Release list

v0.1.1

Choose a tag to compare

@github-actions github-actions released this 27 Sep 13:24

Full Changelog: v0.1.0...v0.1.1

v0.1.0

Choose a tag to compare

@github-actions github-actions released this 26 Sep 18:56

首个生产版本:Phase 1–2 的能力落地。

核心

  • 投递语义:at-least-once(成功才 ack)+ 可见性租约 + DLQ / 重放;优先级插队(跨档严格优先、档内平级加权轮询、未开始预留让位)
  • transport:memory://(进程内)、sqlite://(单机 / 共享盘)、redis://(含 ?cluster=1 的 Redis Cluster)、postgresql://(FOR UPDATE SKIP LOCKED)、amqp://(state= 状态侧车)
  • 工作流 / 调度:原生 DAG 工作流(失败语义、崩溃补偿推进)、beat 定时 + 租约选主、插件机制(自注册后端)、OTel 事件适配
  • Redis:零依赖 RESP2 客户端;Lua 原子取件,EVAL 被禁自动回退 WATCH/MULTI/EXEC;Cluster 下按队列 hash tag 分槽 + CLUSTER SLOTS / MOVED / ASK 路由
  • 质量闸门:一致性套件 16 场景覆盖内建后端,Redis 在 Lua / 无 Lua / Cluster 三种模式下各跑一遍

安装

uv sync          # 开发(含 dev 依赖)
pip install .    # 运行

Python ≥ 3.10。

验证

GitHub Actions:ruff + mypy + pyright + 全量 pytest(真跑 Redis、Redis Cluster、PostgreSQL、RabbitMQ 服务)。

设计与决策见 docs/design.md。