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

implemented run once cron jobs

Browse source
This commit is contained in:
JT Smith 2006-02-12 21:24:29 +00:00
parent d7e2264153
commit 3a174e4eb5
1 changed files with 5 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

6
lib/Spectre/Cron.pm
View file

@ -115,13 +115,17 @@ sub checkSchedule {
my $cron = DateTime::Cron::Simple->new($job->{schedule}); my $cron = DateTime::Cron::Simple->new($job->{schedule});
if ($cron->validate_time($now)) { if ($cron->validate_time($now)) {
my $session = WebGUI::Session->open($self->{_config}->getWebguiRoot, $job->{config}); my $session = WebGUI::Session->open($self->{_config}->getWebguiRoot, $job->{config});
my $instance = WebGUI::Workflow::Instance->create($session, { WebGUI::Workflow::Instance->create($session, {
workflowId=>$job->{workflowId}, workflowId=>$job->{workflowId},
className=>$job->{className}, className=>$job->{className},
methodName=>$job->{methodName}, methodName=>$job->{methodName},
parameters=>$job->{parameters}, parameters=>$job->{parameters},
priority=>$job->{priority} priority=>$job->{priority}
}); });
if ($job->{runOnce}) {
my $cron = WebGUI::Workflow::Cron->new($session, $job->{jobId});
$cron->delete if defined $cron;
}
$session->close; $session->close;
} }
} }