Class JobProgressLifecycle

java.lang.Object

com.kingsrook.qqq.backend.core.jobs.progress.JobProgressLifecycle

public final class JobProgressLifecycle
extends Object

Progress changes owned by the kernel at reclaim and terminal transitions.

Method Summary

Modifier and Type	Method	Description
static void	finished(DurableJobStore store, QRecord job, JobStatus status, String summary)	Append the winning terminal transition summary after its snapshot commits.
static void	reclaimed(DurableJobStore store, QRecord chunk)	Reset live fields to committed work, preserving the interrupted attempt log.
static JobProgressSnapshot	snapshot(QRecord job)	Read a snapshot, falling back to committed counts for existing jobs.
static Map<String,Serializable>	terminalValues(DurableJobStore store, QRecord job, JobStatus status, String summary)	Persist final progress atomically with the winning status transition.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

snapshot

public static JobProgressSnapshot snapshot(QRecord job)

Read a snapshot, falling back to committed counts for existing jobs.

reclaimed

public static void reclaimed(DurableJobStore store,
 QRecord chunk)
                      throws QException

Reset live fields to committed work, preserving the interrupted attempt log.

Throws:

QException

finished

public static void finished(DurableJobStore store,
 QRecord job,
 JobStatus status,
 String summary)

Append the winning terminal transition summary after its snapshot commits.

terminalValues

public static Map<String,Serializable> terminalValues(DurableJobStore store,
 QRecord job,
 JobStatus status,
 String summary)

Persist final progress atomically with the winning status transition.