oqapi/webgui
2
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Make spectre wait a little bit between submitting CRON jobs to be run. Fixes bug #11093

Browse source
This commit is contained in:
Colin Kuskie 2009-10-20 17:20:37 -07:00
parent 5bd5bb48a9
commit 7b4572ae34
2 changed files with 13 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

16
lib/Spectre/Cron.pm
View file

@ -162,8 +162,9 @@ sub checkSchedule {
&& $self->checkSegment($now->day, $job->{dayOfMonth}, [1..31])
&& $self->checkSegment($now->month, $job->{monthOfYear}, [1..12])
&& $self->checkSegment($now->dow % 7, $job->{dayOfWeek}, [0..6]) ) {
$self->debug("It's time to run ".$jobId.". Creating workflow instance.");
$kernel->yield("runJob",$jobId);
$self->debug("It's time to run ".$jobId.". Creating workflow instance in ".$self->{_jobDelay}." seconds.");
$kernel->delay_set("runJob", $self->{_jobDelay}, $jobId);
$self->{_jobDelay} += $self->config->get('timeBetweenRunningWorkflows');
}
}
@ -180,8 +181,9 @@ sub checkSchedules {
$self->debug("Checking schedules against current time.");
my $now = DateTime->now(time_zone => 'local');
foreach my $id (keys %{$self->{_jobs}}) {
$kernel->yield("checkSchedule", $id, $now)
$kernel->delay_set("checkSchedule", $self->{_jobDelay}, $id, $now)
}
$self->{_jobDelay} = $self->config->get('timeBetweenRunningWorkflows');
$kernel->delay_set("checkSchedules",60);
}
@ -380,7 +382,13 @@ sub new {
my $config = shift;
my $logger = shift;
my $debug = shift;
my $self = {_jobs=>{}, _debug=>$debug, _config=>$config, _logger=>$logger};
my $self = {
_jobs => {},
_debug => $debug,
_config => $config,
_logger => $logger,
_jobDelay => $config->get('timeBetweenRunningWorkflows'),
};
bless $self, $class;
my @publicEvents = qw(runJob runJobResponse addJob deleteJob getJsonStatus);
POE::Session->create(