class QueuedJobService (View source)

A service that can be used for starting, stopping and listing queued jobs.

When a job is first added, it is initialised, its job type determined, then persisted to the database

When the queues are scanned, a job is reloaded and processed. Ignoring the persistence and reloading, it looks something like

job->getJobType(); job->getJobData(); data->write(); job->setup(); while !job->isComplete job->process(); job->getJobData(); data->write();

Traits

Provides extensions to this object to integrate it with standard config API methods.

A class that can be instantiated or replaced via DI

Allows an object to have extensions applied to it.

Allows an object to declare a set of custom methods

Properties

static private array $extensions

An array of extension names and parameters to be applied to this object upon construction.

from  Extensible
static private int $stall_threshold
static private int $memory_limit

How much ram will we allow before pausing and releasing the memory?

static private int $time_limit

Optional time limit (in seconds) to run the service before restarting to release resources.

static private bool $disable_health_check

Disable health checks that usually occur when a runner first picks up a queue. Note that completely disabling health checks could result in many jobs that are always marked as running - that will never be restarted. If this option is disabled you may alternatively use the build task

static private int $max_init_jobs

Maximum number of jobs that can be initialised at any one time.

static private string $initialising_state_ttl

Duration for TTL of initialising state based on ISO 8601 duration specification.

static private bool $use_shutdown_function

Should "immediate" jobs be managed using the shutdown function?

static private string $cache_dir

The location for immediate jobs to be stored in

static private bool $lock_file_enabled

Maintenance lock file feature enabled / disable setting

static private string $lock_file_name

Maintenance lock file name

static private string $lock_file_path

Maintenance lock path (relative path starting at the base folder) Note that this path needs to point to a folder on a shared drive if multiple instances are used

DefaultQueueHandler $queueHandler
TaskRunnerEngine $queueRunner
array $defaultJobs

Config controlled list of default/required jobs

Methods

static Config_ForClass
config()

Get a configuration accessor for this class. Short hand for Config::inst()->get($this->class, .....).

mixed
uninherited(string $name)

Gets the uninherited value for the given config option

static Injectable
create(mixed ...$args)

An implementation of the factory method, allows you to create an instance of a class

static Injectable
singleton(string $class = null)

Creates a class instance by the "singleton" design pattern.

mixed
__call(string $method, array $arguments)

Attempts to locate and call a method dynamically added to a class at runtime if a default cannot be located

bool
hasMethod(string $method)

Return TRUE if a method exists on this object

array
allMethodNames(bool $custom = false)

Return the names of all the methods available on this object

static bool
add_extension(string $classOrExtension, string $extension = null)

Add an extension to a specific class.

static 
remove_extension(string $extension)

Remove an extension from a class.

static array
get_extensions(string $class = null, bool $includeArgumentString = false)

No description

static array|null
get_extra_config_sources(string $class = null)

Get extra config sources for this class

static bool
has_extension(string $classOrExtension, string $requiredExtension = null, bool $strict = false)

Return TRUE if a class has a specified extension.

array
invokeWithExtensions(string $method, mixed ...$arguments)

Calls a method if available on both this object and all applied {@link Extensions}, and then attempts to merge all results into an array

array
extend(string $method, mixed ...$arguments)

Run the given function on all of this object's extensions. Note that this method originally returned void, so if you wanted to return results, you're hosed

Extension|null
getExtensionInstance(string $extension)

Get an extension instance attached to this object by name.

bool
hasExtension(string $extension)

Returns TRUE if this object instance has a specific extension applied in {@link $extension_instances}. Extension instances are initialized at constructor time, meaning if you use {@link add_extension()} afterwards, the added extension will just be added to new instances of the extended class. Use the static method {@link has_extension()} to check if a class (not an instance) has a specific extension.

getExtensionInstances()

Get all extension instances for this specific object instance.

__construct()

QueuedJobService constructor.

int
queueJob(QueuedJob $job, null|string $startAfter = null, null|int $userId = null, null|int $queueName = null)

Adds a job to the queue to be started

startJob(QueuedJobDescriptor $jobDescriptor, string $startAfter = null)

Start a job (or however the queue handler determines it should be started)

bool
isAtMaxJobs()

Check if maximum number of jobs are currently initialised.

getNextPendingJob(string $type = null)

Check the current job queues and see if any of the jobs currently in there should be started. If so, return the next job that should be executed

array
checkJobHealth(int $queue = null)

Runs an explicit check on all currently running jobs to make sure their "processed" count is incrementing between each run. If it's not, then we need to flag it as paused due to an error.

checkDefaultJobs($queue = null)

Checks through ll the scheduled jobs that are expected to exist

bool
runJob(int $jobId)

Start the actual execution of a job.

getJobList(string $type = null, int $includeUpUntil = 0)

Gets a list of all the current jobs (or jobs that have recently finished)

string
getJobListFilter(string $type = null, int $includeUpUntil = 0)

Return the SQL filter used to get the job list - this is used by the UI for displaying the job list.

runQueue(string $queue)

Process the job queue with the current queue runner

processJobQueue(string $name)

Process all jobs from a given queue

onShutdown()

When PHP shuts down, we want to process all of the immediate queue items

LoggerInterface
getLogger()

Get a logger

setLogger(LoggerInterface $logger)

No description

enableMaintenanceLock()

No description

disableMaintenanceLock()

No description

bool
isMaintenanceLockActive()

No description

Details

static Config_ForClass config()

Get a configuration accessor for this class. Short hand for Config::inst()->get($this->class, .....).

Return Value

Config_ForClass

mixed uninherited(string $name)

Gets the uninherited value for the given config option

Parameters

string $name

Return Value

mixed

static Injectable create(mixed ...$args)

An implementation of the factory method, allows you to create an instance of a class

This method will defer class substitution to the Injector API, which can be customised via the Config API to declare substitution classes.

This can be called in one of two ways - either calling via the class directly, or calling on Object and passing the class name as the first parameter. The following are equivalent: $list = DataList::create(SiteTree::class); $list = SiteTree::get();

Parameters

mixed ...$args

Return Value

Injectable

static Injectable singleton(string $class = null)

Creates a class instance by the "singleton" design pattern.

It will always return the same instance for this class, which can be used for performance reasons and as a simple way to access instance methods which don't rely on instance data (e.g. the custom SilverStripe static handling).

Parameters

string $class

Optional classname to create, if the called class should not be used

Return Value

Injectable

The singleton instance

mixed __call(string $method, array $arguments)

Attempts to locate and call a method dynamically added to a class at runtime if a default cannot be located

You can add extra methods to a class using {@link Extensions}, {@link Object::createMethod()} or {@link Object::addWrapperMethod()}

Parameters

string $method
array $arguments

Return Value

mixed

Exceptions

BadMethodCallException

bool hasMethod(string $method)

Return TRUE if a method exists on this object

This should be used rather than PHP's inbuild method_exists() as it takes into account methods added via extensions

Parameters

string $method

Return Value

bool

array allMethodNames(bool $custom = false)

Return the names of all the methods available on this object

Parameters

bool $custom

include methods added dynamically at runtime

Return Value

array

Map of method names with lowercase keys

static bool add_extension(string $classOrExtension, string $extension = null)

Add an extension to a specific class.

The preferred method for adding extensions is through YAML config, since it avoids autoloading the class, and is easier to override in more specific configurations.

As an alternative, extensions can be added to a specific class directly in the {@link Object::$extensions} array. See {@link SiteTree::$extensions} for examples. Keep in mind that the extension will only be applied to new instances, not existing ones (including all instances created through {@link singleton()}).

Parameters

string $classOrExtension

Class that should be extended - has to be a subclass of {@link Object}

string $extension

Subclass of {@link Extension} with optional parameters as a string, e.g. "Versioned"

Return Value

bool

Flag if the extension was added

See also

http://doc.silverstripe.org/framework/en/trunk/reference/dataextension

static remove_extension(string $extension)

Remove an extension from a class.

Note: This will not remove extensions from parent classes, and must be called directly on the class assigned the extension.

Keep in mind that this won't revert any datamodel additions of the extension at runtime, unless its used before the schema building kicks in (in your _config.php). Doesn't remove the extension from any {@link Object} instances which are already created, but will have an effect on new extensions. Clears any previously created singletons through {@link singleton()} to avoid side-effects from stale extension information.

Parameters

string $extension

class name of an {@link Extension} subclass, without parameters

static array get_extensions(string $class = null, bool $includeArgumentString = false)

Parameters

string $class

If omitted, will get extensions for the current class

bool $includeArgumentString

Include the argument string in the return array, FALSE would return array("Versioned"), TRUE returns array("Versioned('Stage','Live')").

Return Value

array

Numeric array of either {@link DataExtension} class names, or eval'ed class name strings with constructor arguments.

static array|null get_extra_config_sources(string $class = null)

Get extra config sources for this class

Parameters

string $class

Name of class. If left null will return for the current class

Return Value

array|null

static bool has_extension(string $classOrExtension, string $requiredExtension = null, bool $strict = false)

Return TRUE if a class has a specified extension.

This supports backwards-compatible format (static Object::has_extension($requiredExtension)) and new format ($object->has_extension($class, $requiredExtension))

Parameters

string $classOrExtension

Class to check extension for, or the extension name to check if the second argument is null.

string $requiredExtension

If the first argument is the parent class, this is the extension to check. If left null, the first parameter will be treated as the extension.

bool $strict

if the extension has to match the required extension and not be a subclass

Return Value

bool

Flag if the extension exists

array invokeWithExtensions(string $method, mixed ...$arguments)

Calls a method if available on both this object and all applied {@link Extensions}, and then attempts to merge all results into an array

Parameters

string $method

the method name to call

mixed ...$arguments

List of arguments

Return Value

array

List of results with nulls filtered out

array extend(string $method, mixed ...$arguments)

Run the given function on all of this object's extensions. Note that this method originally returned void, so if you wanted to return results, you're hosed

Currently returns an array, with an index resulting every time the function is called. Only adds returns if they're not NULL, to avoid bogus results from methods just defined on the parent extension. This is important for permission-checks through extend, as they use min() to determine if any of the returns is FALSE. As min() doesn't do type checking, an included NULL return would fail the permission checks.

The extension methods are defined during {@link __construct()} in {@link defineMethods()}.

Parameters

string $method

the name of the method to call on each extension

mixed ...$arguments

Return Value

array

Extension|null getExtensionInstance(string $extension)

Get an extension instance attached to this object by name.

Parameters

string $extension

Return Value

Extension|null

bool hasExtension(string $extension)

Returns TRUE if this object instance has a specific extension applied in {@link $extension_instances}. Extension instances are initialized at constructor time, meaning if you use {@link add_extension()} afterwards, the added extension will just be added to new instances of the extended class. Use the static method {@link has_extension()} to check if a class (not an instance) has a specific extension.

Caution: Don't use singleton()->hasExtension() as it will give you inconsistent results based on when the singleton was first accessed.

Parameters

string $extension

Classname of an {@link Extension} subclass without parameters

Return Value

bool

Extension[] getExtensionInstances()

Get all extension instances for this specific object instance.

See {@link get_extensions()} to get all applied extension classes for this class (not the instance).

This method also provides lazy-population of the extension_instances property.

Return Value

Extension[]

Map of {@link DataExtension} instances, keyed by classname.

__construct()

QueuedJobService constructor.

int queueJob(QueuedJob $job, null|string $startAfter = null, null|int $userId = null, null|int $queueName = null)

Adds a job to the queue to be started

Parameters

QueuedJob $job

The job to start.

null|string $startAfter

The date (in Y-m-d H:i:s format) to start execution after

null|int $userId

The ID of a user to execute the job as. Defaults to the current user

null|int $queueName

Return Value

int

Exceptions

ValidationException

startJob(QueuedJobDescriptor $jobDescriptor, string $startAfter = null)

Start a job (or however the queue handler determines it should be started)

Parameters

QueuedJobDescriptor $jobDescriptor
string $startAfter

bool isAtMaxJobs()

Check if maximum number of jobs are currently initialised.

Return Value

bool

QueuedJobDescriptor|null getNextPendingJob(string $type = null)

Check the current job queues and see if any of the jobs currently in there should be started. If so, return the next job that should be executed

Parameters

string $type

Job type

Return Value

QueuedJobDescriptor|null

array checkJobHealth(int $queue = null)

Runs an explicit check on all currently running jobs to make sure their "processed" count is incrementing between each run. If it's not, then we need to flag it as paused due to an error.

This typically happens when a PHP fatal error is thrown, which can't be picked up by the error handler or exception checker; in this case, we detect these stalled jobs later and fix (try) to fix them

This function returns the IDs of stalled and broken jobs this information can be used to implement some custom follow up actions such as sending email reports

Parameters

int $queue

The queue to check against

Return Value

array

stalled job and broken job IDs

Exceptions

Exception

checkDefaultJobs($queue = null)

Checks through ll the scheduled jobs that are expected to exist

Parameters

$queue

bool runJob(int $jobId)

Start the actual execution of a job.

The assumption is the jobID refers to a {@link QueuedJobDescriptor} that is status set as "Queued".

This method will continue executing until the job says it's completed

Parameters

int $jobId

The ID of the job to start executing

Return Value

bool

Exceptions

Exception

DataList|QueuedJobDescriptor[] getJobList(string $type = null, int $includeUpUntil = 0)

Gets a list of all the current jobs (or jobs that have recently finished)

Parameters

string $type

if we're after a particular job list

int $includeUpUntil

The number of seconds to include jobs that have just finished, allowing a job list to be built that includes recently finished jobs

Return Value

DataList|QueuedJobDescriptor[]

string getJobListFilter(string $type = null, int $includeUpUntil = 0)

Return the SQL filter used to get the job list - this is used by the UI for displaying the job list.

..

Parameters

string $type

if we're after a particular job list

int $includeUpUntil

The number of seconds to include jobs that have just finished, allowing a job list to be built that includes recently finished jobs

Return Value

string

runQueue(string $queue)

Process the job queue with the current queue runner

Parameters

string $queue

processJobQueue(string $name)

Process all jobs from a given queue

Parameters

string $name

The job queue to completely process

onShutdown()

When PHP shuts down, we want to process all of the immediate queue items

We use the 'getNextPendingJob' method, instead of just iterating the queue, to ensure we ignore paused or stalled jobs.

LoggerInterface getLogger()

Get a logger

Return Value

LoggerInterface

setLogger(LoggerInterface $logger)

Parameters

LoggerInterface $logger

enableMaintenanceLock()

disableMaintenanceLock()

bool isMaintenanceLockActive()

Return Value

bool