search

NAMD / pypelinin

Python library to distribute jobs and pipelines among a cluster
3 stars 5 forks source link

Add pipe notation #6

Open turicas opened 11 years ago

turicas commented 11 years ago

As the pipe notation can't represent a directed acyclic graph (a pipeline is one) completly, I removed this representation (a7d6c5f4828f67800ff7b1c44db95723acf4bc9c). But in some cases that we want to represent simple pipelines (jobs in sequence), this representation could help. For example, instead of:

pipeline = {Job('worker_1'): Job('worker_2'), Job('worker_2'): Job('worker_3')}

I can write something as:

pipeline = Job('worker_1') | Job('worker_2') | Job('worker_3')

But I don't know if we really need this.