style: fix prettier drift after merge
This commit is contained in:
@@ -81,15 +81,7 @@ export async function runAgentForGroup(
|
|||||||
onOutput?: (output: AgentOutput) => Promise<void>;
|
onOutput?: (output: AgentOutput) => Promise<void>;
|
||||||
},
|
},
|
||||||
): Promise<'success' | 'error'> {
|
): Promise<'success' | 'error'> {
|
||||||
const {
|
const { group, prompt, chatJid, runId, startSeq, endSeq, onOutput } = args;
|
||||||
group,
|
|
||||||
prompt,
|
|
||||||
chatJid,
|
|
||||||
runId,
|
|
||||||
startSeq,
|
|
||||||
endSeq,
|
|
||||||
onOutput,
|
|
||||||
} = args;
|
|
||||||
const isMain = group.isMain === true;
|
const isMain = group.isMain === true;
|
||||||
const sessions = deps.getSessions();
|
const sessions = deps.getSessions();
|
||||||
|
|
||||||
@@ -388,10 +380,7 @@ export async function runAgentForGroup(
|
|||||||
if (!evaluation.shouldForwardOutput) {
|
if (!evaluation.shouldForwardOutput) {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
if (
|
if (typeof outputText === 'string' && outputText.length > 0) {
|
||||||
typeof outputText === 'string' &&
|
|
||||||
outputText.length > 0
|
|
||||||
) {
|
|
||||||
streamedState = {
|
streamedState = {
|
||||||
...evaluation.state,
|
...evaluation.state,
|
||||||
sawVisibleOutput: true,
|
sawVisibleOutput: true,
|
||||||
|
|||||||
@@ -1580,10 +1580,7 @@ describe('createMessageRuntime', () => {
|
|||||||
});
|
});
|
||||||
|
|
||||||
expect(result).toBe(true);
|
expect(result).toBe(true);
|
||||||
expect(channel.sendMessage).toHaveBeenCalledWith(
|
expect(channel.sendMessage).toHaveBeenCalledWith(chatJid, 'visible reply');
|
||||||
chatJid,
|
|
||||||
'visible reply',
|
|
||||||
);
|
|
||||||
expect(channel.setTyping).toHaveBeenCalledWith(chatJid, true);
|
expect(channel.setTyping).toHaveBeenCalledWith(chatJid, true);
|
||||||
expect(channel.setTyping).toHaveBeenCalledWith(chatJid, false);
|
expect(channel.setTyping).toHaveBeenCalledWith(chatJid, false);
|
||||||
});
|
});
|
||||||
|
|||||||
@@ -456,5 +456,4 @@ describe('paired execution context', () => {
|
|||||||
}),
|
}),
|
||||||
);
|
);
|
||||||
});
|
});
|
||||||
|
|
||||||
});
|
});
|
||||||
|
|||||||
@@ -3,10 +3,7 @@ import crypto from 'crypto';
|
|||||||
import fs from 'fs';
|
import fs from 'fs';
|
||||||
import path from 'path';
|
import path from 'path';
|
||||||
|
|
||||||
import {
|
import { DATA_DIR, PAIRED_MAX_ROUND_TRIPS } from './config.js';
|
||||||
DATA_DIR,
|
|
||||||
PAIRED_MAX_ROUND_TRIPS,
|
|
||||||
} from './config.js';
|
|
||||||
import {
|
import {
|
||||||
createPairedTask,
|
createPairedTask,
|
||||||
getLatestPairedTaskForChat,
|
getLatestPairedTaskForChat,
|
||||||
|
|||||||
@@ -124,9 +124,9 @@ describe('paired workspace manager', () => {
|
|||||||
expect(
|
expect(
|
||||||
db.getPairedWorkspace('paired-task-1', 'reviewer')?.snapshot_refreshed_at,
|
db.getPairedWorkspace('paired-task-1', 'reviewer')?.snapshot_refreshed_at,
|
||||||
).toBeTruthy();
|
).toBeTruthy();
|
||||||
expect(db.getPairedWorkspace('paired-task-1', 'reviewer')?.snapshot_ref).toBe(
|
expect(
|
||||||
null,
|
db.getPairedWorkspace('paired-task-1', 'reviewer')?.snapshot_ref,
|
||||||
);
|
).toBe(null);
|
||||||
});
|
});
|
||||||
|
|
||||||
it('uses the shared DB owner workspace across service-local data dirs', async () => {
|
it('uses the shared DB owner workspace across service-local data dirs', async () => {
|
||||||
|
|||||||
Reference in New Issue
Block a user