You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by is...@apache.org on 2022/06/01 20:36:20 UTC
[airavata-data-lake] branch master updated: Change from Nonblocking to blocking task
This is an automated email from the ASF dual-hosted git repository.
isjarana 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 6f5d4c8 Change from Nonblocking to blocking task
new a97a0ff Merge pull request #109 from isururanawaka/master
6f5d4c8 is described below
commit 6f5d4c81b5e98cd71a65a65ee59ee811f50e97b4
Author: Isuru Ranawaka <ir...@gmail.com>
AuthorDate: Wed Jun 1 16:35:35 2022 -0400
Change from Nonblocking to blocking task
---
.../engine/task/impl/DataParsingWorkflowResourceCleanUpTask.java | 4 ++--
.../workflow-engine-worker/src/main/dist/conf/task-list.yaml | 1 -
2 files changed, 2 insertions(+), 3 deletions(-)
diff --git a/data-orchestrator/workflow-engine/workflow-engine-core/src/main/java/org/apache/airavata/datalake/orchestrator/workflow/engine/task/impl/DataParsingWorkflowResourceCleanUpTask.java b/data-orchestrator/workflow-engine/workflow-engine-core/src/main/java/org/apache/airavata/datalake/orchestrator/workflow/engine/task/impl/DataParsingWorkflowResourceCleanUpTask.java
index 526312a..562ecee 100644
--- a/data-orchestrator/workflow-engine/workflow-engine-core/src/main/java/org/apache/airavata/datalake/orchestrator/workflow/engine/task/impl/DataParsingWorkflowResourceCleanUpTask.java
+++ b/data-orchestrator/workflow-engine/workflow-engine-core/src/main/java/org/apache/airavata/datalake/orchestrator/workflow/engine/task/impl/DataParsingWorkflowResourceCleanUpTask.java
@@ -1,7 +1,7 @@
package org.apache.airavata.datalake.orchestrator.workflow.engine.task.impl;
import org.apache.airavata.datalake.orchestrator.workflow.engine.task.BlockingTask;
-import org.apache.airavata.datalake.orchestrator.workflow.engine.task.annotation.NonBlockingTaskDef;
+import org.apache.airavata.datalake.orchestrator.workflow.engine.task.annotation.BlockingTaskDef;
import org.apache.airavata.datalake.orchestrator.workflow.engine.task.annotation.TaskParam;
import org.apache.helix.task.TaskResult;
import org.slf4j.Logger;
@@ -10,7 +10,7 @@ import org.slf4j.LoggerFactory;
import java.nio.file.Files;
import java.nio.file.Paths;
-@NonBlockingTaskDef(name = "DataParsingWorkflowResourceCleanUpTask")
+@BlockingTaskDef(name = "DataParsingWorkflowResourceCleanUpTask")
public class DataParsingWorkflowResourceCleanUpTask extends BlockingTask {
private final static Logger logger = LoggerFactory.getLogger(DataParsingWorkflowResourceCleanUpTask.class);
diff --git a/data-orchestrator/workflow-engine/workflow-engine-worker/src/main/dist/conf/task-list.yaml b/data-orchestrator/workflow-engine/workflow-engine-worker/src/main/dist/conf/task-list.yaml
index b3c6420..a6364e7 100644
--- a/data-orchestrator/workflow-engine/workflow-engine-worker/src/main/dist/conf/task-list.yaml
+++ b/data-orchestrator/workflow-engine/workflow-engine-worker/src/main/dist/conf/task-list.yaml
@@ -9,5 +9,4 @@ tasks:
- org.apache.airavata.datalake.orchestrator.workflow.engine.task.impl.ExampleNonBlockingTask
- org.apache.airavata.datalake.orchestrator.workflow.engine.task.impl.AsyncDataTransferTask
- org.apache.airavata.datalake.orchestrator.workflow.engine.task.impl.DataTransferPreValidationTask
-