Class JobLifecycleService

java.lang.Object

com.bluebell.greenhouse.radicle.services.job.JobLifecycleService

@Service
public class JobLifecycleService
extends Object

Performs short, fenced lifecycle transactions around durable action execution.

Version:

3.0.6

Author:

Stephen Prizio

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	JobLifecycleService.JobCancellationRequestedException	Signals cooperative cancellation to the worker loop.
static final class	JobLifecycleService.StaleJobClaimException	Signals that a worker lost ownership and must stop writing lifecycle state.

Constructor Summary

Constructors

Constructor	Description
JobLifecycleService()

Method Summary

Modifier and Type	Method	Description
void	cancelJob(JobClaim claim)	Completes cooperative cancellation at a safe checkpoint.
void	completeAction(JobClaim claim, String executionId, ActionData actionData)	Completes an action after confirming that the worker still owns the job.
void	completeJob(JobClaim claim)	Completes a successfully executed attempt.
void	failAction(JobClaim claim, String executionId, String failureKind, String failureCode, String message, Throwable throwable)	Records a structured action failure and skips later action plan items.
List<Long>	orderedActionIds(JobClaim claim)	Returns ordered action identifiers after validating current worker ownership.
ActionExecution	startAction(JobClaim claim, Long actionId)	Starts an action after confirming that the worker still owns the job.

Methods inherited from class Object

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

Constructor Details

JobLifecycleService

public JobLifecycleService()

Method Details

startAction

@Transactional
public ActionExecution startAction(JobClaim claim,
 Long actionId)

Starts an action after confirming that the worker still owns the job.

Parameters:

claim - current claim

actionId - action database identifier

Returns:

created execution

completeAction

@Transactional
public void completeAction(JobClaim claim,
 String executionId,
 ActionData actionData)

Completes an action after confirming that the worker still owns the job.

Parameters:

claim - current claim

executionId - public execution identifier

actionData - handler result

failAction

@Transactional
public void failAction(JobClaim claim,
 String executionId,
 String failureKind,
 String failureCode,
 String message,
 Throwable throwable)

Records a structured action failure and skips later action plan items.

Parameters:

claim - current claim

executionId - public execution identifier

failureKind - failure category

failureCode - stable failure code

message - operator-safe message

throwable - optional diagnostic cause

completeJob

@Transactional
public void completeJob(JobClaim claim)

Completes a successfully executed attempt.

Parameters:

claim - current claim

cancelJob

@Transactional
public void cancelJob(JobClaim claim)

Completes cooperative cancellation at a safe checkpoint.

Parameters:

claim - current claim

orderedActionIds

@Transactional(readOnly=true)
public List<Long> orderedActionIds(JobClaim claim)

Returns ordered action identifiers after validating current worker ownership.

Parameters:

claim - current claim

Returns:

ordered action database identifiers