You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by di...@apache.org on 2019/04/05 19:32:18 UTC
[airavata] branch staging updated: Fixing a minor bug in workflow
operator load balancing logic
This is an automated email from the ASF dual-hosted git repository.
dimuthuupe pushed a commit to branch staging
in repository https://gitbox.apache.org/repos/asf/airavata.git
The following commit(s) were added to refs/heads/staging by this push:
new 05694e3 Fixing a minor bug in workflow operator load balancing logic
05694e3 is described below
commit 05694e389e8601b87be61d5bf22abe9d68abcaf6
Author: Dimuthu Wannipurage <di...@gmail.com>
AuthorDate: Fri Apr 5 15:32:09 2019 -0400
Fixing a minor bug in workflow operator load balancing logic
---
.../java/org/apache/airavata/helix/impl/workflow/WorkflowManager.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/workflow/WorkflowManager.java b/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/workflow/WorkflowManager.java
index 97f7c02..197b823 100644
--- a/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/workflow/WorkflowManager.java
+++ b/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/workflow/WorkflowManager.java
@@ -122,7 +122,7 @@ public class WorkflowManager {
public WorkflowOperator getWorkflowOperator() {
currentOperator++;
- if (workflowOperators.size() >= currentOperator) {
+ if (workflowOperators.size() <= currentOperator) {
currentOperator = 0;
}
return workflowOperators.get(currentOperator);