Package de.dlr.proseo.planner.kubernetes
Klasse KubeJobFinish
java.lang.Object
java.lang.Thread
de.dlr.proseo.planner.kubernetes.KubeJobFinish
- Alle implementierten Schnittstellen:
Runnable
Monitors the completion of a Kubernetes job.
This class runs as a separate thread and waits for a Kubernetes job to finish. It periodically checks for the job's completion
status and retrieves the finish info. Once the job is finished, it performs additional actions based on the job's outcome. The
thread stops after a maximum number of cycles or when the job is found to be finished.
Note: This class requires initialization with the planner, kube job, and job name.
- Autor:
- Ernst Melchinger
-
Verschachtelte Klassen - Übersicht
Von Klasse geerbte verschachtelte Klassen/Schnittstellen java.lang.Thread
Thread.Builder, Thread.State, Thread.UncaughtExceptionHandler
-
Feldübersicht
Von Klasse geerbte Felder java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
-
Konstruktorübersicht
KonstruktorenKonstruktorBeschreibungKubeJobFinish
(KubeJob kubeJob, ProductionPlanner planner, String jobName) Creates a new thread instance to monitor a Kubernetes job until its completion. -
Methodenübersicht
Modifizierer und TypMethodeBeschreibungvoid
run()
Starts the thread to monitor the Kubernetes job until it finishes and the finish info is retrieved.Von Klasse geerbte Methoden java.lang.Thread
activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, isVirtual, join, join, join, join, ofPlatform, ofVirtual, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, sleep, start, startVirtualThread, stop, suspend, threadId, toString, yield
-
Konstruktordetails
-
KubeJobFinish
Creates a new thread instance to monitor a Kubernetes job until its completion.- Parameter:
kubeJob
- The planner kube job.planner
- The production planner instance.jobName
- The Kubernetes job name.
-
-
Methodendetails
-
run
public void run()Starts the thread to monitor the Kubernetes job until it finishes and the finish info is retrieved. This check sleeps for a defined time between cycles and stops after a maximum number of cycles (parameters are defined in the configuration).
-