Skip to content

Commit 9f36596

Browse files
JAVA-LWzk
andauthored
feat(cron): add queue protection and custom schedules (#3552)
Co-authored-by: zk <zk@users.noreply.local>
1 parent 29c9271 commit 9f36596

18 files changed

Lines changed: 569 additions & 20 deletions

File tree

79.2 KB
Loading

packages/desktop/src/common/adapter/ipcBridge.ts

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1349,6 +1349,7 @@ export const cron = {
13491349
agent_config: p.updates.metadata?.agent_config,
13501350
conversation_title: p.updates.metadata?.conversation_title,
13511351
max_retries: p.updates.state?.max_retries,
1352+
queue_enabled: p.updates.state?.queue_enabled,
13521353
})
13531354
),
13541355
removeJob: httpDelete<void, { job_id: string }>((p) => `/api/cron/jobs/${p.job_id}`),
@@ -1406,6 +1407,7 @@ export interface ICronJob {
14061407
run_count: number;
14071408
retry_count: number;
14081409
max_retries: number;
1410+
queue_enabled: boolean;
14091411
};
14101412
}
14111413

@@ -1449,6 +1451,7 @@ export interface ICreateCronJobParams {
14491451
conversation_title?: string;
14501452
created_by: 'user' | 'agent';
14511453
execution_mode?: 'existing' | 'new_conversation';
1454+
queue_enabled?: boolean;
14521455
agent_config?: ICronAgentConfigWrite;
14531456
}
14541457

@@ -1467,6 +1470,7 @@ export interface ICronJobUpdateParams {
14671470
};
14681471
state?: {
14691472
max_retries?: number;
1473+
queue_enabled?: boolean;
14701474
};
14711475
}
14721476

0 commit comments

Comments
 (0)