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

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

Используйте поток задач, когда работа охватывает несколько последовательных или ветвящихся шагов и вам нужно долговечное отслеживание прогресса при перезапусках Gateway. Для одиночных фоновых операций достаточно обычной задачи.
СценарийИспользование
Одиночное фоновое заданиеОбычная задача
Многошаговый конвейер (A, затем B, затем C)Поток задач (управляемый)
Наблюдать задачи, созданные извнеПоток задач (зеркальный)
Одноразовое напоминаниеЗадание Cron

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

Для повторяющихся рабочих процессов, таких как сводки рыночной аналитики, рассматривайте расписание, оркестрацию и проверки надежности как отдельные уровни:
  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-brief
steps:
  - 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 flows
openclaw tasks flow list

# Show details for a specific flow
openclaw tasks flow show <lookup>

# Cancel a running flow and its active tasks
openclaw tasks flow cancel <lookup>
КомандаОписание
openclaw tasks flow listПоказывает отслеживаемые потоки со статусом и режимом синхронизации
openclaw tasks flow show <id>Проверить один поток по идентификатору потока или ключу поиска
openclaw tasks flow cancel <id>Отменить выполняющийся поток и его активные задачи

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

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

См. также