Interface TaskBroker

interface TaskBroker {
    cancel(taskId: string): Promise<void>;
    claim(options?: { signal?: AbortSignal }): Promise<TaskContext>;
    dispatch(
        options: TaskBrokerDispatchOptions,
    ): Promise<TaskBrokerDispatchResult>;
    event$(
        options: { after: number | undefined; taskId: string },
    ): Observable<{ events: SerializedTaskEvent[] }>;
    get(taskId: string): Promise<SerializedTask>;
    list(
        options?: {
            filters?: {
                createdBy?: string | string[];
                status?: TaskStatus | TaskStatus[];
            };
            order?: { field: string; order: "asc"
            | "desc" }[];
            pagination?: { limit?: number; offset?: number };
            permissionFilters?: PermissionCriteria<TaskFilters>;
        },
    ): Promise<{ tasks: SerializedTask[]; totalTasks?: number }>;
    recoverTasks(): Promise<void>;
    retry(options: { secrets?: TaskSecrets; taskId: string }): Promise<void>;
    vacuumTasks(options: { timeoutS: number }): Promise<void>;
}