@@ -19,7 +19,6 @@ def __init__(self, program):
19
19
def _generate_level (self , levels ):
20
20
level = levels [0 ]
21
21
names = set ()
22
- print ("GENERATE {0}" .format (level ))
23
22
24
23
def flatten (task ):
25
24
if isinstance (task , dict ):
@@ -35,21 +34,31 @@ def flatten(task):
35
34
yield t
36
35
mid_name = 'level_' + str (level ) + '_wait'
37
36
done_name = 'level_' + str (level ) + '_done'
38
- yield { 'basename' : mid_name , 'doc' : None , 'task_dep ' : list ( names ) , 'actions ' : [ 'echo' ] }
37
+ yield { 'basename' : mid_name , 'doc' : None , 'name ' : None , 'task_dep ' : list ( names ) }
39
38
done_deps = [mid_name ]
40
39
if len (levels ) > 1 :
41
40
gen_name = 'level_' + str (levels [1 ]) + '_done'
42
41
done_deps .append (gen_name )
43
42
yield Task (gen_name , None , loader = DelayedLoader (lambda : self ._generate_level (levels [1 :]), executed = mid_name ))
44
- yield { 'basename' : done_name , 'doc' : None , 'task_dep' : done_deps , 'actions' : ['echo' ] }
43
+ yield { 'basename' : done_name , 'doc' : None , 'name' : None , 'task_dep' : done_deps }
44
+
45
+ def _generate_all (self , levels ):
46
+ names = set ()
47
+ for level in levels :
48
+ for task in self .program .get_tasks (level ):
49
+ yield task
50
+ #yield { 'basename': 'level_all_done', 'doc': None, 'name': None, 'task_dep': [] }
45
51
46
52
def load_tasks (self , cmd , opt_values , pos_args ):
47
53
DOIT_CONFIG = {
48
54
'reporter' : ExecutedOnlyReporter ,
49
55
'outfile' : sys .stderr ,
50
56
}
51
57
levels = self .program .get_task_levels ()
52
- tasks = generate_tasks ('level_' + str (levels [0 ]) + '_generate' , self ._generate_level (levels ))
58
+ if cmd .execute_tasks :
59
+ tasks = generate_tasks ('level_' + str (levels [0 ]) + '_done' , self ._generate_level (levels ))
60
+ else :
61
+ tasks = generate_tasks ('level_all_done' , self ._generate_all (levels ))
53
62
return tasks , DOIT_CONFIG
54
63
55
64
@@ -111,15 +120,6 @@ def get_tasks(self, level):
111
120
}
112
121
yield self ._get_tasks_impl (suffix , level )
113
122
114
- def get_all_tasks (self ):
115
- yield {
116
- 'basename' : 'copy' ,
117
- 'name' : None ,
118
- 'doc' : 'Copies modified or non-existing files over' ,
119
- }
120
- for level in self .get_task_levels ():
121
- yield self ._get_tasks_impl ('' , level )
122
-
123
123
124
124
def main (args = None ):
125
125
program = Program ()
@@ -136,6 +136,6 @@ def main(args=None):
136
136
os .mkdir ('dest' )
137
137
write_content ('1' , 'bla' )
138
138
write_content ('2' , 'bla' )
139
- # sys.exit(main(['list']))
140
- sys .exit (main (['run' , '-v' , '2' ]))
139
+ sys .exit (main (['list' , '--all ' ]))
140
+ # sys.exit(main(['run', '-v', '2']))
141
141
#sys.exit(main(['run', '-n', '4', '-v', '2', '-P', 'thread']))
0 commit comments