Scala flow/task execution engine