summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorArun Isaac2021-04-26 18:38:19 +0530
committerArun Isaac2021-04-26 18:38:19 +0530
commit1d936f2b39d4dc2b682b0efa80d277940194560b (patch)
treea4ddf7debdcd316b258113ac67c9ccd39d0cfbee
parente64acfac83e5d4150af630e6b0cc1ffc42279405 (diff)
downloadccwl-1d936f2b39d4dc2b682b0efa80d277940194560b.tar.gz
ccwl-1d936f2b39d4dc2b682b0efa80d277940194560b.tar.lz
ccwl-1d936f2b39d4dc2b682b0efa80d277940194560b.zip
Remove deprecated pipeline function.
* ccwl/ccwl.scm (pipeline): Delete function.
-rw-r--r--ccwl/ccwl.scm37
1 files changed, 0 insertions, 37 deletions
diff --git a/ccwl/ccwl.scm b/ccwl/ccwl.scm
index 07c0976..f16a9e7 100644
--- a/ccwl/ccwl.scm
+++ b/ccwl/ccwl.scm
@@ -192,43 +192,6 @@
(tree tree)))))
steps))))
-(define* (pipeline id steps
- #:optional
- (outputs
- (list (output (string-append id "_stdout")
- #:source (string-append (step-id (last steps))
- "/stdout")))))
- ;; Error out if any step does not encapsulate a command.
- (cond
- ((find (lambda (step)
- (not (command? (step-run step))))
- steps)
- => (lambda (step)
- (error "Step does not encapsulate command" step))))
- (workflow id
- (reverse
- (fold (lambda (step result)
- (match result
- ((previous-step tail ...)
- (cons*
- ;; Add an stdin input that is connected to the stdout
- ;; of the previous step.
- (let ((stdin (set-input-source %stdin
- (string-append (step-id previous-step) "/" (output-id %stdout)))))
- (append-step-in (modify-step-run step
- (cut set-command-stdin <> stdin))
- stdin))
- previous-step
- tail))
- (() (list step))))
- (list)
- ;; Add an stdout output to all steps.
- (map (lambda (step)
- (append-step-out (modify-step-run step (cut append-command-outputs <> %stdout))
- %stdout))
- steps)))
- outputs))
-
(define (output->cwl output)
`(,(output-id output)
,@(filter identity