File Coverage

blib/lib/Beam/Minion/Command/run.pm

Criterion	Covered	Total	%
statement	12	12	100.0
branch			n/a
condition			n/a
subroutine	4	4	100.0
pod	0	1	0.0
total	16	17	94.1

package Beam::Minion::Command::run;
our $VERSION = '0.016';
# ABSTRACT: Command to enqueue a job on Beam::Minion job queue

#pod =head1 SYNOPSIS
#pod
#pod     beam minion run [-d ] [-a ] [-p
#pod           [...]
#pod
#pod =head1 DESCRIPTION
#pod
#pod This command adds a job to the L queue to execute the given
#pod C from the given C.
#pod
#pod In order for the job to run, you must run a Minion worker using the
#pod L.
#pod
#pod =head1 ARGUMENTS
#pod
#pod =head2 container
#pod
#pod The container that contains the task to run. This can be an absolute
#pod path to a container file, a relative path from the current directory, or
#pod a relative path from one of the directories in the C environment
#pod variable (separated by C<:>).
#pod
#pod =head2 service
#pod
#pod The service that defines the task to run. Must be an object that consumes
#pod the L role.
#pod
#pod =head1 OPTIONS
#pod
#pod =head2 delay
#pod
#pod The amount of time, in seconds, to delay the start of the job (from now).
#pod Defaults to C<0>.
#pod
#pod =head2 attempts
#pod
#pod The number of times to automatically retry the job if it fails.
#pod Subsequent attempts will be delayed by an increasing amount of time
#pod (calculated by C<(retries ** 4) + 15>).
#pod
#pod =head2 priority
#pod
#pod The job's priority. Higher priority jobs will be run first. Defaults to C<0>.
#pod
#pod =head1 ENVIRONMENT
#pod
#pod =head2 BEAM_MINION
#pod
#pod This variable defines the shared database to coordinate the Minion workers. This
#pod database is used to queue the job. This must be the same for all workers
#pod and every job running.
#pod
#pod See L for how to set this variable.
#pod
#pod =head2 BEAM_PATH
#pod
#pod This variable is a colon-separated list of directories to search for
#pod containers.
#pod
#pod =head1 SEE ALSO
#pod
#pod L, L
#pod
#pod =cut

use Mojo::Base -base;
use Beam::Minion;
use Getopt::Long qw( GetOptionsFromArray );

sub run {
    my ( $self, $container, $service_name, @args ) = @_;
    GetOptionsFromArray( \@args, \my %opt,
        'delay|d=i',
        'attempts|a=i',
        'priority|p=i',
    );
    Beam::Minion->enqueue( $container, $service_name, \@args, \%opt );
}

1;

__END__