Class default

Manages

Constructors

constructor

Properties

cancelJobs emitter jobPoolCapacities jobPoolCounters maintainerMasterEventEmitter maintainerMasterThread queueConsumeTimePeriodInSeconds queues runningJobs

Methods

cancelJob createMaintainerMaster createMaintainerWorker destroy pushJobToQueue

Constructors

constructor

  • new default(): default

  • Constructs the supervisor. Populates the instance variables with trackers for all the HPCs in the config. Creates the master maintainer.

    Returns default

Properties

Private cancelJobs

cancelJobs: Record<string, Job[]> = {}

Private emitter

emitter: default = ...

Private jobPoolCapacities

jobPoolCapacities: Record<string, number> = {}

Private jobPoolCounters

jobPoolCounters: Record<string, number> = {}

Private maintainerMasterEventEmitter

maintainerMasterEventEmitter: EventEmitter<DefaultEventMap> = ...

Private maintainerMasterThread

maintainerMasterThread: null | Timeout = null

Private queueConsumeTimePeriodInSeconds

queueConsumeTimePeriodInSeconds: number = config.queue_consume_time_period_in_seconds

Private queues

queues: Record<string, JobQueue> = {}

Private runningJobs

runningJobs: Record<string, Job[]> = {}

Methods

cancelJob

  • cancelJob(jobId): null | Job

  • Cancels the job associated with the given job id.

    Parameters

    • jobId: string

    Returns null | Job

    the job that was cancelled

createMaintainerMaster

  • createMaintainerMaster(): void

  • Creates the main maintainer for all job execution. Runs in an infinite spaced loop. Ends on destruction.

    Returns void

createMaintainerWorker

  • createMaintainerWorker(job): Promise<void>

  • Creates an object that keeps track of a job throughout its lifecycle on the HPC, recording changes in internal variables.

    Parameters

    Returns Promise<void>

destroy

pushJobToQueue

  • pushJobToQueue(job): Promise<void>

  • Adds a job to the job queue.

    Parameters

    • job: Job

      job to add

    Returns Promise<void>

Settings

Member Visibility

Theme

On This Page

constructorcancelJobsemitterjobPoolCapacitiesjobPoolCountersmaintainerMasterEventEmittermaintainerMasterThreadqueueConsumeTimePeriodInSecondsqueuesrunningJobscancelJobcreateMaintainerMastercreateMaintainerWorkerdestroypushJobToQueue

Generated using TypeDoc