commit a few bugs in the new multiplex management

pipelet/task.py

@@ -168,14 +168,14 @@ class TaskList:
         output_set = method (*a)
 
         if directive.where:
-            f = multiplex._filter(parent_list, directive.where)
+            f = multiplex._where(parent_list, directive.where)
             output_set = filter(f, output_set)
 
         if directive.group_by:
             output_set = multiplex._group(output_set, parent_list, directive.group_by)
             
         ## e for each task to push
-        lst_task = [Task(seg, make_dict([(r[2],r[0]) for r in e]), status='queued', parents=[r[1] for r in e if r[1] is not None]) for e in output_set]
+        lst_task = [Task(seg, make_dict([(r[2],r[0]) for r in e]), status='queued', parents=list(set([r[1] for r in e if r[1] is not None]))) for e in output_set]
 
         return lst_task
 

test/seg_fourth_code.py

+#multiplex cross_prod group_by "0"
 p = glob_seg('third', 'Preambule.txt')
 t = glob_seg('second','test.txt')
 import subprocess

test/seg_second_code.py

+#multiplex cross_prod where 'first in ["Robin", "Arthur"]'
 tf = get_data_fn('test.txt')
 # Dude makes some kind of heavy computation
 i = 0