From bb1171b00cf877ef41b26eb3874a3d3b644cde97 Mon Sep 17 00:00:00 2001 From: Ludovic DEHON Date: Thu, 17 Aug 2023 19:56:39 +0200 Subject: [PATCH] refactor(tasks): relocate BashService to PluginService --- src/main/java/io/kestra/plugin/azure/batch/job/Create.java | 6 +++--- 1 file changed, 3 insertions(+), 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 index 7db839a..8fcb551 100644 --- 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); });