@@ -590,7 +590,7 @@ export type TaskStoreListEventsOptions = {
|
||||
|
||||
// @public
|
||||
export type TaskStoreRecoverTaskOptions = {
|
||||
timeoutS: HumanDuration;
|
||||
timeout: HumanDuration;
|
||||
};
|
||||
|
||||
// @public
|
||||
|
||||
@@ -482,7 +482,7 @@ export class DatabaseTaskStore implements TaskStore {
|
||||
|
||||
async recoverTasks(options: TaskStoreRecoverTaskOptions): Promise<string[]> {
|
||||
const taskIdsToRecover: string[] = [];
|
||||
const timeoutS = Duration.fromObject(options.timeoutS).as('seconds');
|
||||
const timeoutS = Duration.fromObject(options.timeout).as('seconds');
|
||||
|
||||
await this.db.transaction(async tx => {
|
||||
let heartbeatInterval = this.db.raw(
|
||||
|
||||
@@ -216,7 +216,7 @@ export class StorageTaskBroker implements TaskBroker {
|
||||
if (enabled) {
|
||||
const recoveredTaskIds =
|
||||
(await this.storage.recoverTasks?.({
|
||||
timeoutS: readDuration(
|
||||
timeout: readDuration(
|
||||
this.config,
|
||||
'scaffolder.EXPERIMENTAL_recoverTasksTimeout',
|
||||
{
|
||||
|
||||
@@ -147,7 +147,7 @@ export type TaskStoreCreateTaskOptions = {
|
||||
* @public
|
||||
*/
|
||||
export type TaskStoreRecoverTaskOptions = {
|
||||
timeoutS: HumanDuration;
|
||||
timeout: HumanDuration;
|
||||
};
|
||||
|
||||
/**
|
||||
|
||||
Reference in New Issue
Block a user