package Minion::Backend::Pg91;
use Mojo::Base 'Minion::Backend';
use Mojo::IOLoop;
use Mojo::JSON qw(j);
use Mojo::Pg;
use Sys::Hostname 'hostname';
use Carp 'croak';
use Mojo::Util qw(dumper);
our
, task)
values (?, ?, (now() + (interval '1 second' * ?)), ?, ?, ?, ?)
returning id", { json => $args }, $options->{attempts} // 1,
$options->{delay} // 0, $options->{parents} // [],
now(), status = ? where id = ? returning 1';
return $id if $id && $self->pg->db->query($sql, { json => $options->{status} // {} }, $id)->rows;
$sql = q{insert into minion_workers (id, host, pid,