From b48d42dfb93e35e747694e64da19e19c5bbeacbd Mon Sep 17 00:00:00 2001 From: Philipp Kunz Date: Thu, 19 Jan 2023 14:20:44 +0100 Subject: [PATCH] fix(core): update --- ts/00_commitinfo_data.ts | 2 +- ts/taskbuffer.classes.distributedcoordinator.ts | 8 ++++---- ts/taskbuffer.classes.taskmanager.ts | 2 +- 3 files changed, 6 insertions(+), 6 deletions(-) diff --git a/ts/00_commitinfo_data.ts b/ts/00_commitinfo_data.ts index 1968678..57aacb2 100644 --- a/ts/00_commitinfo_data.ts +++ b/ts/00_commitinfo_data.ts @@ -3,6 +3,6 @@ */ export const commitinfo = { name: '@pushrocks/taskbuffer', - version: '3.0.8', + version: '3.0.9', description: 'flexible task management. TypeScript ready!' } diff --git a/ts/taskbuffer.classes.distributedcoordinator.ts b/ts/taskbuffer.classes.distributedcoordinator.ts index 143718a..decc280 100644 --- a/ts/taskbuffer.classes.distributedcoordinator.ts +++ b/ts/taskbuffer.classes.distributedcoordinator.ts @@ -4,7 +4,7 @@ import * as plugins from './taskbuffer.plugins.js'; /** * constains all data for the final coordinator to actually make an informed decision */ -export interface IDistributedDecisionInfoBasis { +export interface IDistributedTaskRequest { /** * this needs to correlate to the consultationResult */ @@ -17,7 +17,7 @@ export interface IDistributedDecisionInfoBasis { status: 'requesting' | 'gotRejected' | 'failed' | 'succeeded'; } -export interface IDsitributedTaskConsultationResult { +export interface IDsitributedTaskRequestResult { /** * this needs to correlate to the decisionInfoBasis */ @@ -29,6 +29,6 @@ export interface IDsitributedTaskConsultationResult { } export abstract class AbstractDistributedCoordinator { - public abstract announceDistributedDecisionInfoBasis(infoBasisArg: IDistributedDecisionInfoBasis): Promise - public abstract updateDistributedDevisionInfoBasis(infoBasisArg: IDistributedDecisionInfoBasis): Promise + public abstract fireDistributedTaskRequest(infoBasisArg: IDistributedTaskRequest): Promise + public abstract updateDistributedTaskRequest(infoBasisArg: IDistributedTaskRequest): Promise } \ No newline at end of file diff --git a/ts/taskbuffer.classes.taskmanager.ts b/ts/taskbuffer.classes.taskmanager.ts index ccf5a14..ff8f011 100644 --- a/ts/taskbuffer.classes.taskmanager.ts +++ b/ts/taskbuffer.classes.taskmanager.ts @@ -89,7 +89,7 @@ export class TaskManager { ); if (this.options.distributedCoordinator) { console.log(`Found a distrubuted coordinator, performing distributed consultation.`); - const announcementResult = await this.options.distributedCoordinator.announceDistributedDecisionInfoBasis({ + const announcementResult = await this.options.distributedCoordinator.fireDistributedTaskRequest({ submitterRandomId: this.randomId, status: 'requesting', taskExecutionParallel: 1,