惯性聚合 高效追踪和阅读你感兴趣的博客、新闻、科技资讯
阅读原文 在惯性聚合中打开

推荐订阅源

GbyAI
GbyAI
Y
Y Combinator Blog
Martin Fowler
Martin Fowler
D
Docker
N
Netflix TechBlog - Medium
酷 壳 – CoolShell
酷 壳 – CoolShell
WordPress大学
WordPress大学
L
LangChain Blog
让小产品的独立变现更简单 - ezindie.com
让小产品的独立变现更简单 - ezindie.com
博客园 - 三生石上(FineUI控件)
博客园_首页
量子位
罗磊的独立博客
Blog — PlanetScale
Blog — PlanetScale
云风的 BLOG
云风的 BLOG
Microsoft Azure Blog
Microsoft Azure Blog
宝玉的分享
宝玉的分享
Apple Machine Learning Research
Apple Machine Learning Research
D
DataBreaches.Net
I
InfoQ
Engineering at Meta
Engineering at Meta
The Cloudflare Blog
H
Help Net Security
V
V2EX

Recent Commits to openclaw:main

test: merge chat side-result checks · openclaw/openclaw@ddd2c2a test: merge cron history checks · openclaw/openclaw@f7eb746 test: merge responsive navigation shell checks · openclaw/openclaw@c2e4b47 docs(changelog): add codex oauth fixes · openclaw/openclaw@628e6cd test: merge navigation routing cases · openclaw/openclaw@5d8cecb Tests: mock channel registry bundled fallback · openclaw/openclaw@2b08233 Secrets: avoid broad web search discovery for single plugin config · openclaw/openclaw@a464f59 test: merge config view browser checks · openclaw/openclaw@20cf511 fix(status): align oauth health with runtime · openclaw/openclaw@eed7116 feat: add macOS screen snapshots for monitor preview (#67954) thanks … · openclaw/openclaw@f377db1 fix: report shared auth scopes in hello-ok (#67810) thanks @BunsDev · openclaw/openclaw@0b6c39b Auto-reply: avoid eager bundled route fallback · openclaw/openclaw@3ea1bf4 Tests: narrow session binding contract setup · openclaw/openclaw@54e4e16 fix(macOS): enable undo/redo in webchat composer text input (#34962) · openclaw/openclaw@00951dc Tests: speed up channel setup promotion · openclaw/openclaw@82b529a Docs: refresh agent instructions · openclaw/openclaw@5775fe2 fix(auth): serialize OAuth refresh across agents to fix #26322 (#67876) · openclaw/openclaw@8e79080 test: allow ollama public surface boundary test · openclaw/openclaw@7d4f1a6 Docs: add test performance guardrails · openclaw/openclaw@89706d3 Tests: restore context-engine usage proof · openclaw/openclaw@e4c4f95 Tests: slim context engine runtime coverage · openclaw/openclaw@74c198f ci: retry failed custom checkouts · openclaw/openclaw@0ee5baf test: trim duplicate provider auth onboarding cases · openclaw/openclaw@1ffc02e matrix: fix sessions_spawn --thread subagent session spawning (#67643) · openclaw/openclaw@1ce2596 test: reduce auth choice fixture churn · openclaw/openclaw@857b9cd test: mock health status config boundaries · openclaw/openclaw@9d5ab4a test: mock onboard config io boundary · openclaw/openclaw@299694d test: mock legacy state plugin boundaries · openclaw/openclaw@2713089 test: mock channel install boundaries · openclaw/openclaw@b945248 test: mock doctor preview channel boundaries · openclaw/openclaw@b1a3ad4
fix(heartbeat): keep due task runs tool-capable · opencla...
clawsweeper · 2026-05-01 · via Recent Commits to openclaw:main

@@ -716,8 +716,7 @@ async function resolveHeartbeatPreflight(params: {

716716

reasonFlags.isExecEventReason ||

717717

reasonFlags.isCronEventReason ||

718718

reasonFlags.isWakeReason ||

719-

hasTaggedCronEvents ||

720-

dueCommitments.length > 0;

719+

hasTaggedCronEvents;

721720

const basePreflight = {

722721

...reasonFlags,

723722

session,

@@ -738,7 +737,11 @@ async function resolveHeartbeatPreflight(params: {

738737

try {

739738

heartbeatFileContent = await fs.readFile(heartbeatFilePath, "utf-8");

740739

const tasks = parseHeartbeatTasks(heartbeatFileContent);

741-

if (isHeartbeatContentEffectivelyEmpty(heartbeatFileContent) && tasks.length === 0) {

740+

if (

741+

isHeartbeatContentEffectivelyEmpty(heartbeatFileContent) &&

742+

tasks.length === 0 &&

743+

dueCommitments.length === 0

744+

) {

742745

return {

743746

...basePreflight,

744747

skipReason: "empty-heartbeat-file",

@@ -773,6 +776,23 @@ type HeartbeatPromptResolution = {

773776

hasDueCommitments: boolean;

774777

};

775778779+

function resolveDueHeartbeatTasks(

780+

preflight: Pick<HeartbeatPreflight, "session" | "tasks">,

781+

startedAt: number,

782+

): HeartbeatTask[] {

783+

const tasks = preflight.tasks;

784+

if (!tasks || tasks.length === 0) {

785+

return [];

786+

}

787+

return tasks.filter((task) =>

788+

isTaskDue(

789+

(preflight.session.entry?.heartbeatTaskState as Record<string, number>)?.[task.name],

790+

task.interval,

791+

startedAt,

792+

),

793+

);

794+

}

795+776796

function appendHeartbeatWorkspacePathHint(prompt: string, workspaceDir: string): string {

777797

if (!/heartbeat\.md/i.test(prompt)) {

778798

return prompt;

@@ -821,6 +841,7 @@ function resolveHeartbeatRunPrompt(params: {

821841

canRelayToUser: boolean;

822842

workspaceDir: string;

823843

startedAt: number;

844+

dueTasks: HeartbeatTask[];

824845

heartbeatFileContent?: string;

825846

}): HeartbeatPromptResolution {

826847

const pendingEventEntries = params.preflight.pendingEventEntries;

@@ -844,14 +865,7 @@ function resolveHeartbeatRunPrompt(params: {

844865

const hasDueCommitments = Boolean(commitmentPrompt);

845866846867

if (params.preflight.tasks && params.preflight.tasks.length > 0) {

847-

const tasks = params.preflight.tasks;

848-

const dueTasks = tasks.filter((task) =>

849-

isTaskDue(

850-

(params.preflight.session.entry?.heartbeatTaskState as Record<string, number>)?.[task.name],

851-

task.interval,

852-

params.startedAt,

853-

),

854-

);

868+

const dueTasks = params.dueTasks;

855869856870

if (dueTasks.length > 0) {

857871

const taskList = dueTasks.map((task) => `- ${task.name}: ${task.prompt}`).join("\n");

@@ -867,15 +881,12 @@ After completing all due tasks, reply HEARTBEAT_OK.`;

867881

prompt += `\n\nAdditional context from HEARTBEAT.md:\n${directives}`;

868882

}

869883

}

870-

if (commitmentPrompt) {

871-

prompt += `\n\n${commitmentPrompt}`;

872-

}

873884

return {

874885

prompt,

875886

hasExecCompletion: false,

876887

hasRelayableExecCompletion: false,

877888

hasCronEvents: false,

878-

hasDueCommitments,

889+

hasDueCommitments: false,

879890

};

880891

}

881892

if (commitmentPrompt) {

@@ -1002,16 +1013,18 @@ export async function runHeartbeatOnce(opts: {

10021013

}

1003101410041015

const previousUpdatedAt = entry?.updatedAt;

1016+

const dueHeartbeatTasks = resolveDueHeartbeatTasks(preflight, startedAt);

1005101710061018

// When isolatedSession is enabled, create a fresh session via the same

10071019

// pattern as cron sessionTarget: "isolated". This gives the heartbeat

10081020

// a new session ID (empty transcript) each run, avoiding the cost of

10091021

// sending the full conversation history (~100K tokens) to the LLM.

10101022

// Delivery routing still uses the main session entry (lastChannel, lastTo).

10111023

const useIsolatedSession = heartbeat?.isolatedSession === true;

1012-

const firstDueCommitment = canHeartbeatDeliverCommitments(heartbeat)

1013-

? preflight.dueCommitments[0]

1014-

: undefined;

1024+

const firstDueCommitment =

1025+

canHeartbeatDeliverCommitments(heartbeat) && dueHeartbeatTasks.length === 0

1026+

? preflight.dueCommitments[0]

1027+

: undefined;

10151028

const commitmentDeliveryContext = firstDueCommitment

10161029

? {

10171030

channel: firstDueCommitment.channel,

@@ -1083,6 +1096,7 @@ export async function runHeartbeatOnce(opts: {

10831096

canRelayToUser,

10841097

workspaceDir,

10851098

startedAt,

1099+

dueTasks: dueHeartbeatTasks,

10861100

heartbeatFileContent: preflight.heartbeatFileContent,

10871101

});

10881102

const dueCommitmentIds = hasDueCommitments