From a893e89ec03f478d247b69353fe7535ba6a6136b Mon Sep 17 00:00:00 2001 From: yoyama Date: Fri, 13 Sep 2019 16:51:13 +0900 Subject: [PATCH] Merge pull request #1221 from yoyama/echo-output2log Add echo log output to task log. --- .../digdag/standards/operator/EchoOperatorFactory.java | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/digdag-standards/src/main/java/io/digdag/standards/operator/EchoOperatorFactory.java b/digdag-standards/src/main/java/io/digdag/standards/operator/EchoOperatorFactory.java index f8b0cdf3cc..66343e688e 100644 --- a/digdag-standards/src/main/java/io/digdag/standards/operator/EchoOperatorFactory.java +++ b/digdag-standards/src/main/java/io/digdag/standards/operator/EchoOperatorFactory.java @@ -2,12 +2,16 @@ import com.google.inject.Inject; import io.digdag.client.config.Config; +import io.digdag.core.log.TaskContextLogging; +import io.digdag.core.log.TaskLogger; import io.digdag.spi.Operator; import io.digdag.spi.OperatorContext; import io.digdag.spi.OperatorFactory; import io.digdag.spi.TaskRequest; import io.digdag.spi.TaskResult; +import java.nio.charset.StandardCharsets; + public class EchoOperatorFactory implements OperatorFactory { @@ -45,6 +49,11 @@ public TaskResult run() System.out.println(message); + // To store the message to task log + TaskLogger logger = TaskContextLogging.getContext().getLogger(); + byte[] messageBytes = message.getBytes(StandardCharsets.UTF_8); + logger.log(messageBytes, 0, messageBytes.length); + return TaskResult.empty(request); } }