Fix recursive pull

kamu-data · Dec 15, 2019 · c459362 · c459362
1 parent 4b1d2f8
commit c459362
Showing 1 changed file with 3 additions and 1 deletion.
diff --git 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")
       }