Class RunProcessAction

java.lang.Object

com.kingsrook.qqq.backend.core.actions.processes.RunProcessAction

Direct Known Subclasses:

CancelProcessAction

public class RunProcessAction
extends Object

Action handler for running q-processes (which are a sequence of q-steps).

Field Summary

Fields

Modifier and Type	Field	Description
static final String	BASEPULL_CONFIGURATION
static final String	BASEPULL_DID_QUERY_USING_TIMESTAMP_FIELD
static final String	BASEPULL_KEY_VALUE
static final String	BASEPULL_LAST_RUNTIME_KEY
static final String	BASEPULL_READY_TO_UPDATE_TIMESTAMP_FIELD	/////////////////////////////////////////////////////////////////////////////////////////////
static final String	BASEPULL_THIS_RUNTIME_KEY
static final String	BASEPULL_TIMESTAMP_FIELD
static final String	PROCESS_TRACER_CODE_REFERENCE_FIELD

Constructor Summary

Constructors

Constructor	Description
RunProcessAction()

Method Summary

Modifier and Type	Method	Description
protected String	determineBasepullKeyValue(QProcessMetaData process, RunProcessInput runProcessInput, BasepullConfiguration basepullConfiguration)
RunProcessOutput	execute(RunProcessInput runProcessInput)
static Optional<ProcessState>	getState(String processUUID)	public method to get a process state just by UUID.
QStateMachineStep	getStateMachineStepContainingSubStep(QProcessMetaData process, String stepName)
static StateProviderInterface	getStateProvider()	Load an instance of the appropriate state provider
protected void	persistLastRunTime(RunProcessInput runProcessInput, QProcessMetaData process, BasepullConfiguration basepullConfiguration)	Lookup the last runtime for this basepull, and set it (plus now) in the process's values.
protected void	storeLastRunTime(RunProcessInput runProcessInput, QProcessMetaData process, BasepullConfiguration basepullConfiguration)	Insert or update the last runtime value for this basepull into the backend.

Methods inherited from class java.lang.Object

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

Field Details

BASEPULL_KEY_VALUE

public static final String BASEPULL_KEY_VALUE

See Also:

• Constant Field Values

BASEPULL_THIS_RUNTIME_KEY

public static final String BASEPULL_THIS_RUNTIME_KEY

See Also:

• Constant Field Values

BASEPULL_LAST_RUNTIME_KEY

public static final String BASEPULL_LAST_RUNTIME_KEY

See Also:

• Constant Field Values

BASEPULL_TIMESTAMP_FIELD

public static final String BASEPULL_TIMESTAMP_FIELD

See Also:

• Constant Field Values

BASEPULL_CONFIGURATION

public static final String BASEPULL_CONFIGURATION

See Also:

• Constant Field Values

PROCESS_TRACER_CODE_REFERENCE_FIELD

public static final String PROCESS_TRACER_CODE_REFERENCE_FIELD

See Also:

• Constant Field Values

BASEPULL_READY_TO_UPDATE_TIMESTAMP_FIELD

public static final String BASEPULL_READY_TO_UPDATE_TIMESTAMP_FIELD

/////////////////////////////////////////////////////////////////////////////////////////////

See Also:

• Constant Field Values

BASEPULL_DID_QUERY_USING_TIMESTAMP_FIELD

public static final String BASEPULL_DID_QUERY_USING_TIMESTAMP_FIELD

See Also:

• Constant Field Values

Constructor Details

RunProcessAction

public RunProcessAction()

Method Details

execute

public RunProcessOutput execute(RunProcessInput runProcessInput)
                         throws QException

Throws:

QException

getStateMachineStepContainingSubStep

public QStateMachineStep getStateMachineStepContainingSubStep(QProcessMetaData process,
 String stepName)

getStateProvider

public static StateProviderInterface getStateProvider()

Load an instance of the appropriate state provider

getState

public static Optional<ProcessState> getState(String processUUID)

public method to get a process state just by UUID.

determineBasepullKeyValue

protected String determineBasepullKeyValue(QProcessMetaData process,
 RunProcessInput runProcessInput,
 BasepullConfiguration basepullConfiguration)
                                    throws QException

Throws:

QException

storeLastRunTime

protected void storeLastRunTime(RunProcessInput runProcessInput,
 QProcessMetaData process,
 BasepullConfiguration basepullConfiguration)
                         throws QException

Insert or update the last runtime value for this basepull into the backend.

Throws:

QException

persistLastRunTime

protected void persistLastRunTime(RunProcessInput runProcessInput,
 QProcessMetaData process,
 BasepullConfiguration basepullConfiguration)
                           throws QException

Lookup the last runtime for this basepull, and set it (plus now) in the process's values.

Throws:

QException