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

added waiting

Browse source
This commit is contained in:
JT Smith 2006-04-27 02:40:36 +00:00
parent e7e85e1f14
commit 0a31083bd9
1 changed files with 18 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

22
lib/WebGUI/Workflow/Activity/CacheEMSPrereqs.pm
View file

@ -70,16 +70,30 @@ See WebGUI::Workflow::Activity::execute() for details.
sub execute { sub execute {
my $self = shift; my $self = shift;
my $object = shift;
my $instance = shift;
my ($emsId) = $self->session->db->quickArray("select assetId from asset where className='WebGUI::Asset::Wobject::EventManagementSystem' limit 1"); my ($emsId) = $self->session->db->quickArray("select assetId from asset where className='WebGUI::Asset::Wobject::EventManagementSystem' limit 1");
return $self->COMPLETE unless $emsId; return $self->COMPLETE unless $emsId;
WebGUI::Cache->new($self->session)->deleteChunk(["verifyAllPrerequisites"]); WebGUI::Cache->new($self->session)->deleteChunk(["verifyAllPrerequisites"]);
my $ems = WebGUI::Asset->newByDynamicClass($self->session,$emsId); my $ems = WebGUI::Asset->newByDynamicClass($self->session,$emsId);
my $start = time();
my $leftOff = $instance->getScratch("emsleftoff");
my $skip = ($leftOff ne "") ? 1 : 0;
my $status = $self->COMPLETE;
my @events = $self->session->db->buildArray("select productId from EventManagementSystem_products"); my @events = $self->session->db->buildArray("select productId from EventManagementSystem_products");
foreach (@events) { foreach my $event (@events) {
$ems->verifyAllPrerequisites($_); $skip = 0 if ($leftOff eq $event);
next if $skip;
if ((time() - $start) > 60) { # give up so something else can run for a while
$instance->setScratch("emsleftoff",$event);
$status = $self->WAITING;
last;
}
$self->session->errorHandler->warn('EMS Cacher Running '.$event);
$ems->verifyAllPrerequisites($event);
} }
$self->session->errorHandler->warn('EMS Cacher Ran!'); $self->session->errorHandler->warn('EMS Cacher Ran! Status: '.$status);
return $self->COMPLETE; return $status;
} }