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 2021/08/23 14:27:39 UTC
[airavata-data-lake] branch master updated: Fixing issue of
scheduled workflow submission
This is an automated email from the ASF dual-hosted git repository.
dimuthuupe pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/airavata-data-lake.git
The following commit(s) were added to refs/heads/master by this push:
new abe0c9a Fixing issue of scheduled workflow submission
abe0c9a is described below
commit abe0c9a31a9185328f75d44170a12e083d740f28
Author: Dimuthu Wannipurage <di...@gmail.com>
AuthorDate: Mon Aug 23 10:27:31 2021 -0400
Fixing issue of scheduled workflow submission
---
.../workflow/engine/wm/datasync/WorkflowEngineAPIHandler.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/data-orchestrator/workflow-engine/datasync-workflow-manager/src/main/java/org/apache/airavata/datalake/workflow/engine/wm/datasync/WorkflowEngineAPIHandler.java b/data-orchestrator/workflow-engine/datasync-workflow-manager/src/main/java/org/apache/airavata/datalake/workflow/engine/wm/datasync/WorkflowEngineAPIHandler.java
index 8128ff3..51f8a00 100644
--- a/data-orchestrator/workflow-engine/datasync-workflow-manager/src/main/java/org/apache/airavata/datalake/workflow/engine/wm/datasync/WorkflowEngineAPIHandler.java
+++ b/data-orchestrator/workflow-engine/datasync-workflow-manager/src/main/java/org/apache/airavata/datalake/workflow/engine/wm/datasync/WorkflowEngineAPIHandler.java
@@ -29,8 +29,8 @@ import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import java.util.Optional;
+import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
-import java.util.concurrent.ScheduledExecutorService;
@GRpcService
public class WorkflowEngineAPIHandler extends WorkflowServiceGrpc.WorkflowServiceImplBase {
@@ -45,7 +45,7 @@ public class WorkflowEngineAPIHandler extends WorkflowServiceGrpc.WorkflowServic
@Autowired
private DataParsingWorkflowManager dataParsingWorkflowManager;
- private final ScheduledExecutorService workflowExecutorService = Executors.newSingleThreadScheduledExecutor();
+ private final ExecutorService workflowExecutorService = Executors.newFixedThreadPool(5);
@Override
public void invokeWorkflow(WorkflowInvocationRequest request,