refactor(tasks): relocate BashService to PluginService

kestra-io · Aug 17, 2023 · bb1171b · bb1171b
1 parent c7dbca0
commit bb1171b
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/main/java/io/kestra/plugin/azure/batch/job/Create.java b/src/main/java/io/kestra/plugin/azure/batch/job/Create.java
@@ -11,7 +11,7 @@
 import io.kestra.core.models.executions.metrics.Timer;
 import io.kestra.core.models.tasks.RunnableTask;
 import io.kestra.core.runners.RunContext;
-import io.kestra.core.tasks.scripts.BashService;
+import io.kestra.core.tasks.PluginUtilsService;
 import io.kestra.plugin.azure.batch.AbstractBatch;
 import io.kestra.plugin.azure.batch.models.Job;
 import io.kestra.plugin.azure.batch.models.Task;
@@ -198,12 +198,12 @@ public Output run(RunContext runContext) throws Exception {
 
                 // log
                 TaskService.readRemoteLog(runContext, client, jobId, task, "stdout.txt", msg -> {
-                    outputs.putAll(BashService.parseOut(msg, logger, runContext));
+                    outputs.putAll(PluginUtilsService.parseOut(msg, logger, runContext));
                     logger.info(msg);
                 });
 
                 TaskService.readRemoteLog(runContext, client, jobId, task, "stderr.txt", msg -> {
-                    outputs.putAll(BashService.parseOut(msg, logger, runContext));
+                    outputs.putAll(PluginUtilsService.parseOut(msg, logger, runContext));
                     logger.warn(msg);
                 });