1 package SL::DB::Manager::BackgroundJob;
5 use SL::DB::Helper::Manager;
6 use base qw(SL::DB::Helper::Manager);
8 use SL::DB::Helper::Sorted;
10 sub object_class { 'SL::DB::BackgroundJob' }
12 __PACKAGE__->make_manager_methods;
15 return ( default => [ 'next_run_at', 1 ],
16 columns => { SIMPLE => 'ALL' } );
21 $class->delete_all(where => [ and => [ type => 'once', last_run_at => { lt => DateTime->now_local->subtract(days => '1') } ] ]);
24 sub get_all_need_to_run {
27 my $now = DateTime->now_local;
28 my @interval_args = (and => [ type => 'interval',
30 next_run_at => { le => $now } ]);
31 my @once_args = (and => [ type => 'once',
34 or => [ cron_spec => undef,
37 next_run_at => { le => $now } ] ]);
39 return $class->get_all(query => [ or => [ @interval_args, @once_args ] ]);