360 Secure SkillHub
360 安全技能中心

Queue Task

核心功能:为task-father任务文件夹提供持久化队列服务,支持可恢复、幂等的批量长时作业,通过状态文件跟踪进度,自带锁机制避免并发,可配置定时任务。典型场景:需长期运行、中断后可恢复的批量处理任务。支持聊天式初始化或终端配置,可通过命令查看状态、清理过期锁,依赖Python3与openclaw工具。

moodykong
moodykong
热度 83.07
最近更新 2026-05-17 12:32:58
分类:开发依赖:代码执行 / 读写文件 / 第三方 API应用场景:自动化脚本 / 任务管理 / DevOps

安装技能

复制下面的话术发给你的 Agent,它会通过 secure-skills 检索并安装该技能。

执行命令安装此 skill: npx secure-skills-cli add queue-task
Metadata
name
queue-task
description
Durable queue-task helper for resumable, idempotent batch jobs in task-father task folders.

queue-task

Use this skill for durable long-running queue jobs with resumable batches.

Layout (task-father only):

  • <WORKSPACE_DIR>/<TASKS_DIR>/<slug>/...

State files:

  • queue.jsonl
  • progress.json
  • done.jsonl
  • failed.jsonl
  • lock.json

Prerequisites

  • python3 --version
  • openclaw status
  • openclaw cron --help

Configuration (portable)

Skill-local config:

  • Example: config.env.example
  • Real machine config: config.env

Keys:

  • WORKSPACE_DIR
  • TASKS_DIR
  • BATCH_SIZE
  • LOCK_STALE_MINUTES
  • CRON_EXPR
  • CRON_TZ
  • DELIVERY_MODE
  • AGENT_ID

Initialization / Installation / Onboarding

Preferred (chat-first)

Provide:

  1. task slug
  2. batch size
  3. lock stale minutes
  4. schedule and timezone

Then initialize:

  • python3 scripts/queue_task.py init <slug>

Smoke test:

  • python3 scripts/queue_task.py status <slug>

Optional (terminal)

  • cp config.env.example config.env
  • Edit config.env
  • Run init/status commands above.

Commands

  • Init files:
    • python3 scripts/queue_task.py init <slug>
  • Status:
    • python3 scripts/queue_task.py status <slug>
  • Clear stale lock:
    • python3 scripts/queue_task.py clear-stale-lock <slug>
  • Print worker template:
    • python3 scripts/queue_task.py print-supervisor-template

Usage notes

  • Prefer append-only JSONL logs.
  • Process small batches.
  • Update progress.json after each item.
  • Keep idempotency keys task-defined.
  • Use lock file to avoid concurrent runs.