caps.pl

sub job_info {
  return undef
    unless my $job = shift->pg->db->query(
    'SELECT id, args, EXTRACT(EPOCH FROM created) AS created,
       EXTRACT(EPOCH FROM delayed) AS delayed,
       EXTRACT(EPOCH FROM finished) AS finished, priority, result,
       EXTRACT(EPOCH FROM retried) AS retried, retries,
       EXTRACT(EPOCH FROM started) AS started, state, task, worker
     FROM minion_jobs WHERE id = ?', shift
    )->hash;
  map { $job->{$_} and $job->{$_} = decode_json $job->{$_} } qw(args result);
  return $job;
}

sub job_info {
  return undef
    unless my $job = shift->pg->db->query(
    'select id, args, extract(epoch from created) as created,
       extract(epoch from delayed) as delayed,
       extract(epoch from finished) as finished, priority, result,
       extract(epoch from retried) as retried, retries,
       extract(epoch from started) as started, state, task, worker
     from minion_jobs where id = ?', shift
    )->hash;
  map { $job->{$_} and $job->{$_} = decode_json $job->{$_} } qw(args result);
  return $job;
}