Scala based flow/task execution engine