diff options
| author | Arun Isaac | 2021-04-26 18:38:19 +0530 |
|---|---|---|
| committer | Arun Isaac | 2021-04-26 18:38:19 +0530 |
| commit | 1d936f2b39d4dc2b682b0efa80d277940194560b (patch) | |
| tree | a4ddf7debdcd316b258113ac67c9ccd39d0cfbee | |
| parent | e64acfac83e5d4150af630e6b0cc1ffc42279405 (diff) | |
| download | ccwl-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.scm | 37 |
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 |