Поток задач

Поток задач — это основа оркестрации потоков, которая находится над фоновыми задачами. Он управляет долговечными многошаговыми потоками с собственным состоянием, отслеживанием ревизий и семантикой синхронизации, тогда как отдельные задачи остаются единицей отсоединенной работы.

Когда использовать поток задач

Используйте поток задач, когда работа охватывает несколько последовательных или ветвящихся шагов и вам нужно долговечное отслеживание прогресса при перезапусках Gateway. Для одиночных фоновых операций достаточно обычной задачи.

Надежный шаблон запланированного рабочего процесса

Для повторяющихся рабочих процессов, таких как сводки рыночной аналитики, рассматривайте расписание, оркестрацию и проверки надежности как отдельные уровни:

1. Используйте запланированные задачи для времени запуска.
2. Используйте постоянный сеанс cron, когда рабочий процесс должен опираться на предыдущий контекст.
3. Используйте Lobster для детерминированных шагов, шлюзов утверждения и токенов возобновления.
4. Используйте поток задач, чтобы отслеживать многошаговый запуск между дочерними задачами, ожиданиями, повторными попытками и перезапусками Gateway.

Пример формы cron:

openclaw cron add \  --name "Market intelligence brief" \  --cron "0 7 * * 1-5" \  --tz "America/New_York" \  --session session:market-intel \  --message "Run the market-intel Lobster workflow. Verify source freshness before summarizing." \  --announce \  --channel slack \  --to "channel:C1234567890"

Используйте session:<id> вместо isolated, когда повторяющемуся рабочему процессу нужна намеренная история, сводки предыдущих запусков или постоянный контекст. Используйте isolated, когда каждый запуск должен начинаться с чистого состояния, а все необходимое состояние явно задано в рабочем процессе.

Внутри рабочего процесса поместите проверки надежности перед шагом сводки LLM:

name: market-intel-briefsteps:  - id: preflight    command: market-intel check --json  - id: collect    command: market-intel collect --json    stdin: $preflight.json  - id: summarize    command: market-intel summarize --json    stdin: $collect.json  - id: approve    command: market-intel deliver --preview    stdin: $summarize.json    approval: required  - id: deliver    command: market-intel deliver --execute    stdin: $summarize.json    condition: $approve.approved

Рекомендуемые предполетные проверки:

• Доступность браузера и выбор профиля, например openclaw для управляемого состояния или user, когда требуется сеанс Chrome с выполненным входом. См. браузер.
• Учетные данные API и квота для каждого источника.
• Доступность сети для требуемых конечных точек.
• Требуемые инструменты, включенные для агента, такие как lobster, browser и llm-task.
• Настроенное место назначения для сбоев cron, чтобы предполетные сбои были видны. См. запланированные задачи.

Рекомендуемые поля происхождения данных для каждого собранного элемента:

{  "sourceUrl": "https://example.com/report",  "retrievedAt": "2026-04-24T12:00:00Z",  "asOf": "2026-04-24",  "title": "Example report",  "content": "..."}

Сделайте так, чтобы рабочий процесс отклонял или помечал устаревшие элементы перед созданием сводки. Шаг LLM должен получать только структурированный JSON, и его следует попросить сохранять sourceUrl, retrievedAt и asOf в своем выводе. Используйте задачу LLM, когда внутри рабочего процесса нужен шаг модели с проверкой по схеме.

Для повторно используемых командных или общественных рабочих процессов упакуйте CLI, файлы .lobster и любые примечания по настройке как навык или plugin и опубликуйте через ClawHub. Держите защитные ограничения, специфичные для рабочего процесса, в этом пакете, если только API plugin не лишен необходимой универсальной возможности.

Режимы синхронизации

Управляемый режим

Поток задач полностью владеет жизненным циклом. Он создает задачи как шаги потока, доводит их до завершения и автоматически продвигает состояние потока.

Пример: поток еженедельного отчета, который (1) собирает данные, (2) создает отчет и (3) доставляет его. Поток задач создает каждый шаг как фоновую задачу, ожидает завершения, а затем переходит к следующему шагу.

Flow: weekly-report  Step 1: gather-data     → task created → succeeded  Step 2: generate-report → task created → succeeded  Step 3: deliver         → task created → running

Зеркальный режим

Поток задач наблюдает задачи, созданные извне, и поддерживает состояние потока в синхронизации, не принимая на себя владение созданием задач. Это полезно, когда задачи поступают из заданий cron, команд CLI или других источников, а вам нужен единый вид их прогресса как потока.

Пример: три независимых задания cron, которые вместе образуют процедуру «утренних операций». Зеркальный поток отслеживает их совокупный прогресс, не управляя тем, когда и как они запускаются.

Долговечное состояние и отслеживание ревизий

Каждый поток сохраняет собственное состояние и отслеживает ревизии, чтобы прогресс переживал перезапуски Gateway. Отслеживание ревизий позволяет обнаруживать конфликты, когда несколько источников пытаются одновременно продвинуть один и тот же поток. Реестр потоков использует SQLite с ограниченным обслуживанием журнала упреждающей записи, включая периодические контрольные точки и контрольные точки при завершении, чтобы долгоживущие Gateway не сохраняли неограниченные побочные файлы registry.sqlite-wal.

Поведение отмены

openclaw tasks flow cancel устанавливает закрепленное намерение отмены для потока. Активные задачи внутри потока отменяются, и новые шаги не запускаются. Намерение отмены сохраняется при перезапусках, поэтому отмененный поток остается отмененным, даже если Gateway перезапускается до завершения всех дочерних задач.

Команды CLI

# List active and recent flowsopenclaw tasks flow list # Show details for a specific flowopenclaw tasks flow show <lookup> # Cancel a running flow and its active tasksopenclaw tasks flow cancel <lookup>

Как потоки связаны с задачами

Потоки координируют задачи, а не заменяют их. Один поток может управлять несколькими фоновыми задачами за время своего существования. Используйте openclaw tasks, чтобы проверять отдельные записи задач, и openclaw tasks flow, чтобы проверять оркестрирующий поток.

См. также

• Фоновые задачи — отсоединенный журнал работы, который координируют потоки
• CLI: задачи — справочник команд CLI для openclaw tasks flow
• Обзор автоматизации — все механизмы автоматизации в одном обзоре
• Задания Cron — запланированные задания, которые могут поступать в потоки