Added taskOption to WorkflowTraverser

silk-workspace/src/main/scala/org/silkframework/workspace/activity/workflow/WorkflowTraverser.scala

@@ -1,7 +1,10 @@
 package org.silkframework.workspace.activity.workflow
 
+import org.silkframework.util.Identifier
 import org.silkframework.workspace.{Project, Task}
 
+import scala.reflect.ClassTag
+
 /**
   * Allows to traverse through the workflow.
   *
@@ -12,6 +15,10 @@ class WorkflowTraverser(operator: WorkflowNode)(implicit workflow: Task[Workflow
 
   def task: Task[_] = workflow.project.anyTask(operator.task)
 
+  def taskOption[T : ClassTag](taskName: Identifier): Option[Task[T]] = {
+    workflow.project.taskOption[T](taskName)
+  }
+
   def inputs: Seq[WorkflowTraverser] = {
     operator.inputs.map(input => new WorkflowTraverser(workflow.data.node(input)))
   }