fixed bugs from rewrite
This commit is contained in:
parent
d14a93f399
commit
ba8ebc47d4
1 changed files with 3 additions and 2 deletions
|
|
@ -323,8 +323,9 @@ sub getNextInstance {
|
||||||
foreach my $instance (@instances) {
|
foreach my $instance (@instances) {
|
||||||
next unless $instance->{status} eq 'waiting';
|
next unless $instance->{status} eq 'waiting';
|
||||||
$waitingCount++;
|
$waitingCount++;
|
||||||
if ($instance->{workingPriority} > $lowPriority) {
|
if ($instance->{workingPriority} < $lowPriority) {
|
||||||
$lowInstance = $instance;
|
$lowInstance = $instance;
|
||||||
|
$lowPriority = $instance->{workingPriority};
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
$self->debug("Total workflows waiting to run: ".$waitingCount);
|
$self->debug("Total workflows waiting to run: ".$waitingCount);
|
||||||
|
|
@ -478,7 +479,7 @@ A hash reference of the properties of the instance.
|
||||||
sub updateInstance {
|
sub updateInstance {
|
||||||
my ($self, $instance) = @_;
|
my ($self, $instance) = @_;
|
||||||
$self->debug("Updating ".$instance->{instanceId}."'s properties.");
|
$self->debug("Updating ".$instance->{instanceId}."'s properties.");
|
||||||
$self->{_queue}{$instance->{instanceId}};
|
$self->{_queue}{$instance->{instanceId}} = $instance;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue