skills/pbakaus_impeccable
1
0
Fork 0
mirror of https://github.com/pbakaus/impeccable.git synced 2026-09-17 00:26:41 +03:00
Code Issues Packages Projects Releases Wiki Activity

Deliver Live variant two independently

Browse Source
This commit is contained in:
Paul Bakaus
2026-07-13 11:42:25 -07:00
parent 2f619f9bdb
commit 4c07124198
10 changed files with 207 additions and 37 deletions
Download Patch File Download Diff File Expand all files Collapse all files
skill/scripts/live/codex-worker-supervisor.mjs
+29 -4
View File
@@ -9,6 +9,7 @@ import {
selectQualityCodexModel,
} from './codex-app-server-client.mjs';
import { loadContext } from '../context.mjs';
import { reconcilePublishedSourceVariants } from './generation-publisher.mjs';
import {
CODEX_WORKER_OWNER,
@@ -207,9 +208,17 @@ export class CodexLiveWorkerSupervisor {
const expectedVariants = Number(event.count || 1);
const snapshot = this.sessionStore.getSnapshot(event.id, { includeCompleted: true });
const sameEpoch = Number(snapshot?.generationEpoch || 1) === Number(event.generationEpoch || 1);
const arrivedVariants = sameEpoch ? Number(snapshot?.arrivedVariants || 0) : 0;
let arrivedVariants = sameEpoch ? Number(snapshot?.arrivedVariants || 0) : 0;
if (this.config.delivery === 'progressive' && expectedVariants > 1) {
if (arrivedVariants < 1) await this.runGenerationPhase(event, 'first', 1);
if (arrivedVariants < 1) {
await this.runGenerationPhase(event, 'first', 1);
arrivedVariants = 1;
}
if (this.isCanceled(event.id)) return;
if (expectedVariants > 2 && arrivedVariants < 2) {
await this.runGenerationPhase(event, 'second', 2);
arrivedVariants = 2;
}
if (this.isCanceled(event.id)) return;
if (arrivedVariants < expectedVariants) {
await this.runGenerationPhase(event, 'final', expectedVariants);
@@ -288,7 +297,7 @@ export class CodexLiveWorkerSupervisor {
const phaseStartedAt = Date.now();
await this.publishPhase(this.base, this.token, {
eventId: event.id,
phase: phase === 'final' ? 'remaining_variants_generating' : 'first_variant_generating',
phase: generationPhaseName(phase, 'generating'),
});
const prepared = prepareCodexWorkerPhase({
id: event.id,
@@ -323,7 +332,7 @@ export class CodexLiveWorkerSupervisor {
publicationPromise = (async () => {
await this.publishPhase(this.base, this.token, {
eventId: event.id,
phase: phase === 'final' ? 'remaining_variants_validating' : 'first_variant_validating',
phase: generationPhaseName(phase, 'validating'),
durationMs: Date.now() - phaseStartedAt,
});
const applied = applyCodexWorkerOutput({
@@ -334,6 +343,16 @@ export class CodexLiveWorkerSupervisor {
cwd: this.cwd,
maxBytes: this.config.maxArtifactBytes,
});
if (!prepared.previewMode && (phase === 'second' || phase === 'final')) {
const candidatePath = path.resolve(this.cwd, prepared.artifactFile);
const reconciled = reconcilePublishedSourceVariants({
current: artifact.content,
candidate: fs.readFileSync(candidatePath, 'utf-8'),
priorArrived: Math.max(1, arrivedVariants - 1),
});
if (!reconciled.ok) throw supervisorError(`reconcile_${reconciled.error}`);
fs.writeFileSync(candidatePath, reconciled.content, 'utf-8');
}
if (applied.plan) {
this.sessionStore.appendEvent({ type: 'variant_plan', id: event.id, plan: applied.plan });
}
@@ -519,6 +538,12 @@ export class CodexLiveWorkerSupervisor {
}
}
function generationPhaseName(phase, state) {
if (phase === 'first') return `first_variant_${state}`;
if (phase === 'second') return `second_variant_${state}`;
return `remaining_variants_${state}`;
}
function preferredEffort(model, requested) {
const supported = (model?.supportedReasoningEfforts || [])
.map((option) => typeof option === 'string' ? option : option?.reasoningEffort)