File Coverage

blib/lib/Kevin/Command/kevin/jobs.pm

Criterion	Covered	Total	%
statement	15	28	53.5
branch			n/a
condition			n/a
subroutine	5	9	55.5
pod	1	1	100.0
total	21	38	55.2

package Kevin::Command::kevin::jobs;
$Kevin::Command::kevin::jobs::VERSION = '0.7.1';
# ABSTRACT: Command to list Minion jobs
use Mojo::Base 'Mojolicious::Command';

use Kevin::Commands::Util ();
use Mojo::Util qw(getopt);
use Text::Yeti::Table qw(render_table);
use Time::HiRes qw(time);

has description => 'List Minion jobs';
has usage => sub { shift->extract_usage };

sub run {
  my ($self, @args) = @_;

  my $app    = $self->app;
  my $minion = $app->minion;

  my ($args, $options) = ([], {});
  getopt \@args,
    'l|limit=i'  => \(my $limit  = 100),
    'o|offset=i' => \(my $offset = 0),
    'q|queue=s@' => \$options->{queues},
    'S|state=s@' => \$options->{states},
    't|task=s@'  => \$options->{tasks};

  my $results = $minion->backend->list_jobs($offset, $limit, $options);
  my $items = $results->{jobs};

  my $spec = $self->_table_spec;
  render_table($items, $spec);
}

*_created_since = *Kevin::Commands::Util::_created_since;
*_job_status    = *Kevin::Commands::Util::_job_status;

sub _table_spec {

  my $now = time;
  return [
    qw(id),
    ['priority', undef, 'PRI'],
    qw( task state queue ),
    ['created', sub { _created_since($now - shift) }],
    ['state', sub { _job_status($_[1], $now) }, 'STATUS'],
    qw(worker),
  ];
}

1;

#pod =encoding utf8
#pod
#pod =head1 SYNOPSIS
#pod
#pod   Usage: APPLICATION kevin jobs [OPTIONS]
#pod
#pod     ./myapp.pl kevin jobs
#pod     ./myapp.pl kevin jobs -l 10 -o 20
#pod     ./myapp.pl kevin jobs -q important -t foo -t bar -S inactive
#pod
#pod   Options:
#pod     -h, --help                  Show this summary of available options
#pod     -l, --limit         Number of jobs to show when listing
#pod                                 them, defaults to 100
#pod     -o, --offset        Number of jobs to skip when listing
#pod                                 them, defaults to 0
#pod     -q, --queue           List only jobs in these queues
#pod     -S, --state           List only jobs in these states
#pod     -t, --task            List only jobs for these tasks
#pod
#pod =head1 DESCRIPTION
#pod
#pod L lists jobs at a L queue.
#pod It produces output as below.
#pod
#pod     ID       PRI    TASK         STATE      QUEUE           CREATED          STATUS                    WORKER
#pod     925851   0      resize       finished   image-resizer   7 minutes ago    Finished 7 minutes ago    27297
#pod     925838   1000   search       failed     item-searcher   13 minutes ago   Failed 13 minutes ago     27191
#pod     925835   1000   upload       finished   uploader        13 minutes ago   Finished 13 minutes ago   27185
#pod     925832   1000   search       finished   item-searcher   13 minutes ago   Finished 13 minutes ago   27188
#pod     925831   100    poke         failed     poker           13 minutes ago   Failed 13 minutes ago     26819
#pod     925830   100    poke         failed     poker           31 hours ago     Failed 31 hours ago       26847
#pod
#pod =head1 ATTRIBUTES
#pod
#pod L inherits all attributes from
#pod L and implements the following new ones.
#pod
#pod =head2 description
#pod
#pod   my $description = $command->description;
#pod   $command        = $command->description('Foo');
#pod
#pod Short description of this command, used for the command list.
#pod
#pod =head2 usage
#pod
#pod   my $usage = $command->usage;
#pod   $command  = $command->usage('Foo');
#pod
#pod Usage information for this command, used for the help screen.
#pod
#pod =head1 METHODS
#pod
#pod L inherits all methods from
#pod L and implements the following new ones.
#pod
#pod =head2 run
#pod
#pod   $command->run(@ARGV);
#pod
#pod Run this command.
#pod
#pod =head1 SEE ALSO
#pod
#pod L, L.
#pod
#pod =cut

__END__