Commit 941896e5 authored by Cédric Le Ninivin's avatar Cédric Le Ninivin Committed by Titouan Soulard

slapos: slapgrid tests work with slaptool for backward compatibility

parent 80914cc3
...@@ -580,39 +580,41 @@ stderr_logfile_backups=1 ...@@ -580,39 +580,41 @@ stderr_logfile_backups=1
launchSupervisord(instance_root=self.instance_root, logger=self.logger) launchSupervisord(instance_root=self.instance_root, logger=self.logger)
def getComputerPartitionList(self): def getComputerPartitionList(self):
if self.computer_partition_list is None: if not self.api_backward_compatibility:
if not self.api_backward_compatibility: if self.computer_partition_list is None:
self.computer_partition_list = self.slap.jio_api_connector.allDocs({ self.computer_partition_list = self.slap.jio_api_connector.allDocs({
"portal_type": "Software Instance", "portal_type": "Software Instance",
"compute_node_id": self.computer_id, "compute_node_id": self.computer_id,
}).get("result_list", []) }).get("result_list", [])
else: else:
try:
slap_partition_list = self.computer.getComputerPartitionList()
except socket.error as exc:
self.logger.fatal(exc)
raise
self.computer_partition_list = []
for partition in slap_partition_list:
try: try:
slap_partition_list = self.computer.getComputerPartitionList() software_release_uri = partition.getSoftwareRelease().getURI()
except socket.error as exc: except (NotFoundError, TypeError, NameError):
self.logger.fatal(exc) software_release_uri = None
raise
self.computer_partition_list = [] parameter_dict = partition.getInstanceParameterDict()
for partition in slap_partition_list: self.computer_partition_list.append({
try: "reference": partition._instance_guid,
software_release_uri = partition.getSoftwareRelease().getURI() "portal_type": "Software Instance",
except (NotFoundError, TypeError, NameError): "compute_partition_id": partition.getId(),
software_release_uri = None "state": partition.getState(),
self.computer_partition_list.append({ "software_type": parameter_dict.get('slap_software_type', None),
"reference": partition._instance_guid, "parameters": parameter_dict,
"portal_type": "Software Instance", "processing_timestamp": parameter_dict.get("timestamp"),
"compute_partition_id": partition.getId(), "slap_partition": partition,
"state": partition.getState(), "ip_list": parameter_dict["ip_list"],
"software_type": partition.getInstanceParameterDict().get( "full_ip_list": parameter_dict.get("full_ip_list", []),
'slap_software_type', None), "access_status_message": partition.getAccessStatus(),
"parameters": partition.getInstanceParameterDict(), "software_release_uri": software_release_uri,
"instance_processing_timestamp": partition.getInstanceParameterDict().get( "sla_parameters": getattr(partition, '_filter_dict', {}),
"timestamp"), })
"slap_partition": partition,
"access_status_message": partition.getAccessStatus(),
"software_release_uri": software_release_uri,
"sla_parameters": getattr(partition, '_filter_dict', {}),
})
return self.computer_partition_list return self.computer_partition_list
def sendPartitionError(self, partition, error_message, logger=None): def sendPartitionError(self, partition, error_message, logger=None):
......
This source diff could not be displayed because it is too large. You can view the blob instead.
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment