)
return parser.parse_args()
-def callback( t):
- print(f'[{Engine.clock}] { t} finished ({ t.count})')
+def callback(t):
+ print(f'[{Engine.clock}] {t} finished ({t.count})')
-def switch( t, hosts, execs):
- comm0.destination = hosts[ t.count % 2]
- comm0.remove_successor(execs[ t.count % 2 - 1])
- comm0.add_successor(execs[ t.count % 2])
+def switch(t, hosts, execs):
+ comm0.destination = hosts[t.count % 2]
+ comm0.remove_successor(execs[t.count % 2 - 1])
+ comm0.add_successor(execs[t.count % 2])
if __name__ == '__main__':
args = parse()
# Add a function to be called before each executions of comm0
# This function modifies the graph of tasks by adding or removing
# successors to comm0
- comm0.on_this_start(lambda t: switch( t, [jupiter, fafard], [exec1,exec2]))
+ comm0.on_this_start(lambda t: switch(t, [jupiter, fafard], [exec1,exec2]))
# Enqueue two executions for task exec1
comm0.enqueue_execs(4)