التعافي الذاتي والتحسين الذاتي

​

استعادة الـ run الآن

import { createAgent, createProgressGuard } from 'lousho';
import { SqliteStore } from 'lousho/sqlite';

const agent = createAgent({
  provider,
  store: new SqliteStore('./.lousho/jobs.db'),
  hooks: [createProgressGuard()],
});

const recovery = agent.recover({
  retryWithDiagnosis: true,
  onRecovered: (run) => console.log('recovered', run.sessionId),
  onQuarantined: (run) => console.warn('needs a person', run.sessionId, run.lastError?.message),
  onOutage: (paused) => console.warn(paused ? 'provider down, paused' : 'provider back'),
  onError: (error, run) => console.error('recovery failed', run?.sessionId, error),
});

• التراجع (backoff). الـ run الذي فشل يُتخطّى حتى تنقضي مدة تراجعه: intervalMs مضاعفةً لكل محاولة فاشلة متتالية، حتى 15 دقيقة.
• العزل (quarantine). بعد maxAttempts حالات فشل متتالية (الافتراضي 10)، تتوقف الحلقة عن استئناف الـ run وتستدعي onQuarantined(run) مرة واحدة. وتظل agent.pending() تسرده، وتظل agent.resume() تشغّله، حتى يقرّر شخص. حفظ التقدّم يصفّر العدّاد.
• إعادة المحاولة مع تشخيص. مع retryWithDiagnosis: true (الافتراضي false)، يحصل الـ run الذي يبلغ الحد أولًا على محاولة أخرى: fork باسم <id>.heal، يُستأنَف من الخطوة نفسها، مع ملاحظة تقول لماذا فشل الـ run. تقتبس الملاحظة الخطأ كبيانات وتحدّ طوله. إذا اكتمل الـ fork، يُحذَف الأصلي ويُبلِّغ onRecovered بـ id الأصلي. وإذا بلغ الـ fork الحد هو أيضًا، يُعزَل الاثنان. ينطبق هذا على runs الـ send()، لا على دورات الجلسات، ويجب أن يحتفظ المخزن بـ سجل checkpoints.
• الأخطاء التي لن تزول. الـ run الذي يحمل آخر خطأ له retryable: false، مثل 400 من المزوّد، يُترك وشأنه.
• انقطاعات المزوّد. بعد 3 حالات فشل متتالية من المزوّد، عبر أي runs، تتوقف الحلقة مؤقتًا وتستدعي onOutage(true). ثم تجرّب run واحدًا في كل مرة، على فترات متزايدة، وتستدعي onOutage(false) بمجرد أن ينجح أحدها. ولا تُعزَل الـ runs بسبب فشل المزوّد أثناء التوقف المؤقت. ومفتاح API الخاطئ لا يُحسَب انقطاعًا.
• الموافقات. الـ run المتوقف على موافقة أو سؤال يُترك لشخص.

​

إيقاف الـ run الذي لا يحرز تقدّمًا

import { createAgent, createProgressGuard } from 'lousho';

const agent = createAgent({ provider, hooks: [createProgressGuard()] });

for await (const event of agent.stream('Where is order A-1?')) {
  if (event.type === 'heal.action') console.log(event.action, event.toolName, event.reason);
}

​

مراقبتها

• استدعاءات recover() الراجعة: onRecovered وonQuarantined وonOutage وonError. الاستدعاء الراجع الذي يرمي خطأ لا يوقف الحلقة.
• تسرد agent.pending() كل run غير مكتمل مع lastError وattempts، بما في ذلك المعزولة.
• النتيجة التي استبدلها حارس التقدّم تُعلَّم على span الأداة بـ lousho.tool.replaced_by_hook، ويُسجَّل الرفض كخطأ الـ span. راجع التتبّع والمراقبة للـ spans ولـ daemon الـ observe المحلي.

​

اقتراح تعديلات لاحقًا

import { createAgent } from 'lousho';
import { formatImproveResult, improveAgent, renderTranscript } from 'lousho/improve';

const result = await improveAgent({
  harness: { instructions: 'You answer from the docs.', skills: {} },
  cases: ['discount-question'],
  holdout: ['refund-question'],
  editor: { provider },
  maxTokens: 500_000,
  probe: async (candidate, caseId) => {
    const agent = createAgent({ provider, instructions: candidate.instructions });
    const run = await agent.send(caseId);
    return { passed: (run.text ?? '').includes('cannot'), transcript: renderTranscript(run.messages), tokens: run.usage?.totalTokens ?? 0, ended: run.finishReason };
  },
});

if (result.outcome === 'proposal') console.log(formatImproveResult(result));

• تُرجع اقتراحًا فقط. الـ outcome بقيمة proposal يأتي مع diff. يراجعه شخص، مستعينًا بـ formatImproveResult() للحصول على بطاقة مقروءة، ثم يطبّقه بنفسه.
• لا تستطيع تغيير إلا التعليمات والمهارات. لا تستطيع تغيير الأدوات أو الصلاحيات أو الحدود.
• تختبر قبل أن تقترح. يُشغِّل كل مرشّح حالاتك مرة أخرى ويجب أن يحسّن حالة تدريب واحدة على الأقل دون أن يجعل أي حالة أسوأ، بما في ذلك الحالات المحجوزة (held-out) التي لا يراها المحرّرون أبدًا. وتفحص أيضًا التكلفة لكل run ناجح مقابل maxCostIncrease (الافتراضي 0.5).
• الـ probe الخاص بك يشغّل الـ agent، فهو المسؤول عن الآثار الجانبية. أضف createShadowHook({ readOnly: [...] }) إلا إذا كانت كل أداة آمنة للتشغيل.

​

كيف تتكامل الطبقتان

​

الأدلة الحيّة (S29 وS30)

• نجح كل سيناريو اختبر شيئًا فعلًا. نجح planted-editor في محاولتين من محاولتين، ولم تصل محاولة ثالثة إلى المحرّرين، فلم تُحتسَب.
• تحقّق سجل التدقيق في كل مجلد محاولة.
• حكم التقرير هو INCOMPLETE (غير مكتمل)، لأن معايير القرار تتطلب من 5 إلى 10 محاولات لكل سيناريو.