vultr/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-05-06 12:30:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor: share task executor param types

Browse Source
This commit is contained in:
Peter Steinberger
2026-04-19 05:28:03 +01:00
parent c72f539ced
commit 3e081c5d21
1 changed files with 34 additions and 61 deletions
Download Patch File Download Diff File Expand all files Collapse all files

95
src/tasks/task-executor.ts
View File

@@ -82,7 +82,7 @@ function ensureSingleTaskFlow(params: {
}
}
export function createQueuedTaskRun(params: {
type TaskRunCreateParams = {
runtime: TaskRuntime;
taskKind?: string;
sourceId?: string;
@@ -100,7 +100,15 @@ export function createQueuedTaskRun(params: {
preferMetadata?: boolean;
notifyPolicy?: TaskNotifyPolicy;
deliveryStatus?: TaskDeliveryStatus;
}): TaskRecord {
};
type RunningTaskRunCreateParams = TaskRunCreateParams & {
startedAt?: number;
lastEventAt?: number;
progressSummary?: string | null;
};
export function createQueuedTaskRun(params: TaskRunCreateParams): TaskRecord {
const task = createTaskRecord({
...params,
status: "queued",
@@ -115,28 +123,7 @@ export function getFlowTaskSummary(flowId: string): TaskRegistrySummary {
return summarizeTaskRecords(listTasksForFlowId(flowId));
}
export function createRunningTaskRun(params: {
runtime: TaskRuntime;
taskKind?: string;
sourceId?: string;
requesterSessionKey?: string;
ownerKey?: string;
scopeKind?: TaskScopeKind;
requesterOrigin?: TaskDeliveryState["requesterOrigin"];
parentFlowId?: string;
childSessionKey?: string;
parentTaskId?: string;
agentId?: string;
runId?: string;
label?: string;
task: string;
notifyPolicy?: TaskNotifyPolicy;
deliveryStatus?: TaskDeliveryStatus;
preferMetadata?: boolean;
startedAt?: number;
lastEventAt?: number;
progressSummary?: string | null;
}): TaskRecord {
export function createRunningTaskRun(params: RunningTaskRunCreateParams): TaskRecord {
const task = createTaskRecord({
...params,
status: "running",
@@ -147,6 +134,25 @@ export function createRunningTaskRun(params: {
});
}
type RunTaskInFlowParams = {
flowId: string;
runtime: TaskRuntime;
sourceId?: string;
childSessionKey?: string;
parentTaskId?: string;
agentId?: string;
runId?: string;
label?: string;
task: string;
notifyPolicy?: TaskNotifyPolicy;
deliveryStatus?: TaskDeliveryStatus;
preferMetadata?: boolean;
status?: "queued" | "running";
startedAt?: number;
lastEventAt?: number;
progressSummary?: string | null;
};
export function startTaskRunByRunId(params: {
runId: string;
runtime?: TaskRuntime;
@@ -485,24 +491,7 @@ function mapRunTaskInFlowCreateError(params: {
throw params.error;
}
export function runTaskInFlow(params: {
flowId: string;
runtime: TaskRuntime;
sourceId?: string;
childSessionKey?: string;
parentTaskId?: string;
agentId?: string;
runId?: string;
label?: string;
task: string;
preferMetadata?: boolean;
notifyPolicy?: TaskNotifyPolicy;
deliveryStatus?: TaskDeliveryStatus;
status?: "queued" | "running";
startedAt?: number;
lastEventAt?: number;
progressSummary?: string | null;
}): RunTaskInFlowResult {
export function runTaskInFlow(params: RunTaskInFlowParams): RunTaskInFlowResult {
const flow = getTaskFlowById(params.flowId);
if (!flow) {
return {
@@ -579,25 +568,9 @@ export function runTaskInFlow(params: {
};
}
export function runTaskInFlowForOwner(params: {
flowId: string;
callerOwnerKey: string;
runtime: TaskRuntime;
sourceId?: string;
childSessionKey?: string;
parentTaskId?: string;
agentId?: string;
runId?: string;
label?: string;
task: string;
preferMetadata?: boolean;
notifyPolicy?: TaskNotifyPolicy;
deliveryStatus?: TaskDeliveryStatus;
status?: "queued" | "running";
startedAt?: number;
lastEventAt?: number;
progressSummary?: string | null;
}): RunTaskInFlowResult {
export function runTaskInFlowForOwner(
params: RunTaskInFlowParams & { callerOwnerKey: string },
): RunTaskInFlowResult {
const flow = getTaskFlowByIdForOwner({
flowId: params.flowId,
callerOwnerKey: params.callerOwnerKey,