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

- Made changes to spectre to handle finished workflows better.

Browse source
This commit is contained in:
JT Smith 2006-07-12 20:21:10 +00:00
parent 06e1acf350
commit 1440fec057
3 changed files with 7 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

4
lib/Spectre/Workflow.pm
View file

@ -108,6 +108,10 @@ sub checkInstances {
my ($kernel, $self) = @_[KERNEL, OBJECT];
$self->debug("Checking to see if we can run anymore instances right now.");
if ($self->countRunningInstances < $self->config->get("maxWorkers")) {
$self->debug("Total workflows waiting to run: ".scalar(keys %{$self->{_instances}}));
$self->debug("Priority 1 count: ".scalar(@{$self->{_priority1}}));
$self->debug("Priority 2 count: ".scalar(@{$self->{_priority2}}));
$self->debug("Priority 3 count: ".scalar(@{$self->{_priority3}}));
my $instance = $self->getNextInstance;
if (defined $instance) {
# mark it running so that it doesn't run twice at once