Options
All
  • Public
  • Public/Protected
  • All
Menu

Hierarchy

Index

Constructors

Properties

_lock: boolean = false

mutex

appParam: {} = {}

Type declaration

  • [keys: string]: string
appParamValidators: any = undefined
config: maintainerConfig = undefined
connector: default | default = undefined

HPC connectors

envParam: {} = {}

Type declaration

  • [keys: string]: string
envParamDefault: {} = {}

Type declaration

  • [keys: string]: string
envParamValidators: {} = undefined

Type declaration

  • [keys: string]: ((val: string) => boolean)
      • (val: string): boolean
      • Parameters

        • val: string

        Returns boolean

events: event[] = []
hpc: hpcConfig = undefined
id: string = undefined
initRetry: number = 3

parameters

isEnd: boolean = false
isInit: boolean = false

states

isPaused: boolean = false
job: Job = undefined

config

jobOnHpc: boolean = false
lifeCycleState: { createdAt: any; initCounter: number } = ...

Type declaration

  • createdAt: any
  • initCounter: number
logs: string[] = []

data

maintainThresholdInHours: number = 100000
slurm: slurm = undefined
supervisor: default

parent pointer

validator: typeof validator = validator

packages

Methods

  • dumpLogs(): string[]
  • emitEvent(type: string, message: string): void
  • Update this.events with the new event, and this.isInit or this.isEnd as appropriate

    Parameters

    • type: string

      Type of event to be recorded

    • message: string

      Message associated with the event

    Returns void

  • emitLog(message: string): void
  • init(): Promise<void>
  • maintain(): Promise<void>
  • Ensure that the job is still running, and if the runtime has exceeded the maintain threshold, terminate and update events.

    async

    Returns Promise<void>

  • onCancel(): Promise<void>
  • onDefine(): void
  • onInit(): Promise<void>
  • onMaintain(): Promise<void>
  • onPause(): Promise<void>
  • onResume(): Promise<void>

Generated using TypeDoc