Index: scheduler/drone_manager.py |
diff --git a/scheduler/drone_manager.py b/scheduler/drone_manager.py |
index 75724f382b83c0849b01ff2ed5194134ab4c0ff1..e094f14f1fb080ef9108b90b287b0b46f49e78ae 100644 |
--- a/scheduler/drone_manager.py |
+++ b/scheduler/drone_manager.py |
@@ -159,8 +159,7 @@ class DroneManager(object): |
self._results_dir = base_results_dir |
for hostname in drone_hostnames: |
- drone = self._add_drone(hostname) |
- drone.call('initialize', self.absolute_path('')) |
+ self._add_drone(hostname) |
if not self._drones: |
# all drones failed to initialize |
@@ -205,8 +204,9 @@ class DroneManager(object): |
def _add_drone(self, hostname): |
logging.info('Adding drone %s' % hostname) |
drone = drones.get_drone(hostname) |
- self._drones[drone.hostname] = drone |
- return drone |
+ if drone: |
+ self._drones[drone.hostname] = drone |
+ drone.call('initialize', self.absolute_path('')) |
def _remove_drone(self, hostname): |