A DSL for data-driven computational pipelines