push.rocks/taskbuffer
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(core): update

Browse Source
This commit is contained in:
Philipp Kunz 2023-01-19 14:20:44 +01:00
parent 5bf568d0cd
commit b48d42dfb9
3 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
ts/00_commitinfo_data.ts
View File

@ -3,6 +3,6 @@
*/ */
export const commitinfo = { export const commitinfo = {
name: '@pushrocks/taskbuffer', name: '@pushrocks/taskbuffer',
version: '3.0.8', version: '3.0.9',
description: 'flexible task management. TypeScript ready!' description: 'flexible task management. TypeScript ready!'
} }

8
ts/taskbuffer.classes.distributedcoordinator.ts
View File

@ -4,7 +4,7 @@ import * as plugins from './taskbuffer.plugins.js';
/** /**
* constains all data for the final coordinator to actually make an informed decision * 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 * this needs to correlate to the consultationResult
*/ */
@ -17,7 +17,7 @@ export interface IDistributedDecisionInfoBasis {
status: 'requesting' | 'gotRejected' | 'failed' | 'succeeded'; status: 'requesting' | 'gotRejected' | 'failed' | 'succeeded';
} }
export interface IDsitributedTaskConsultationResult { export interface IDsitributedTaskRequestResult {
/** /**
* this needs to correlate to the decisionInfoBasis * this needs to correlate to the decisionInfoBasis
*/ */
@ -29,6 +29,6 @@ export interface IDsitributedTaskConsultationResult {
} }
export abstract class AbstractDistributedCoordinator { export abstract class AbstractDistributedCoordinator {
public abstract announceDistributedDecisionInfoBasis(infoBasisArg: IDistributedDecisionInfoBasis): Promise<IDsitributedTaskConsultationResult> public abstract fireDistributedTaskRequest(infoBasisArg: IDistributedTaskRequest): Promise<IDsitributedTaskRequestResult>
public abstract updateDistributedDevisionInfoBasis(infoBasisArg: IDistributedDecisionInfoBasis): Promise<void> public abstract updateDistributedTaskRequest(infoBasisArg: IDistributedTaskRequest): Promise<void>
} }

2
ts/taskbuffer.classes.taskmanager.ts
View File

@ -89,7 +89,7 @@ export class TaskManager {
); );
if (this.options.distributedCoordinator) { if (this.options.distributedCoordinator) {
console.log(`Found a distrubuted coordinator, performing distributed consultation.`); 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, submitterRandomId: this.randomId,
status: 'requesting', status: 'requesting',
taskExecutionParallel: 1, taskExecutionParallel: 1,