From c459362d985bb9272165c006f49dc00260619f5c Mon Sep 17 00:00:00 2001 From: Sergii Mikhtoniuk Date: Sat, 14 Dec 2019 18:05:41 -0800 Subject: [PATCH] Fix recursive pull --- src/main/scala/dev/kamu/cli/commands/PullCommand.scala | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/main/scala/dev/kamu/cli/commands/PullCommand.scala b/src/main/scala/dev/kamu/cli/commands/PullCommand.scala index fc136663f6..b62cc3ac7f 100644 --- a/src/main/scala/dev/kamu/cli/commands/PullCommand.scala +++ b/src/main/scala/dev/kamu/cli/commands/PullCommand.scala @@ -57,7 +57,9 @@ class PullCommand( kind match { case Dataset.Kind.Root => pullRoot(batch) - case Dataset.Kind.Derivative => pullDerivative(batch) + case Dataset.Kind.Derivative => + // TODO: Streaming transform currently doesn't handle dependencies + batch.foreach(ds => pullDerivative(Seq(ds))) case Dataset.Kind.Remote => throw new NotImplementedError("Cannot pull remote datasets") }