git://git.onelab.eu
/
nepi.git
/ commitdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
|
patch
|
inline
| side by side (parent:
c957791
)
Fixing bug in group deployment. Repeated start_with_conditions invokation
author
Alina Quereilhac
<alina.quereilhac@inria.fr>
Mon, 29 Jul 2013 21:49:12 +0000
(14:49 -0700)
committer
Alina Quereilhac
<alina.quereilhac@inria.fr>
Mon, 29 Jul 2013 21:49:12 +0000
(14:49 -0700)
src/nepi/execution/ec.py
patch
|
blob
|
history
diff --git
a/src/nepi/execution/ec.py
b/src/nepi/execution/ec.py
index
e81854b
..
de013d1
100644
(file)
--- a/
src/nepi/execution/ec.py
+++ b/
src/nepi/execution/ec.py
@@
-581,8
+581,10
@@
class ExperimentController(object):
if isinstance(guids, int):
guids = [guids]
if isinstance(guids, int):
guids = [guids]
- # Create deployment group
+ # Create deployment group
+ new_group = False
if not group:
if not group:
+ new_group = True
group = self._group_id_generator.next(guid)
if group not in self._groups:
group = self._group_id_generator.next(guid)
if group not in self._groups:
@@
-623,7
+625,7
@@
class ExperimentController(object):
rm = self.get_resource(guid)
self.schedule("0s", rm.start_with_conditions)
rm = self.get_resource(guid)
self.schedule("0s", rm.start_with_conditions)
- if wait_all_ready:
+ if wait_all_ready
and new_group
:
# Schedule a function to check that all resources are
# READY, and only then schedule the start.
# This aimes at reducing the number of tasks looping in the
# Schedule a function to check that all resources are
# READY, and only then schedule the start.
# This aimes at reducing the number of tasks looping in the