X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=sfa%2Fmanagers%2Faggregate_manager_eucalyptus.py;h=2356f333d7fc6f368b2cdcdf04734e990d690e60;hb=a0ef6e7c91c3c8fa376943d28fec8c5c204a78cd;hp=552f544690347f7df230514631e47e5010a18e5f;hpb=02a4a59a4a49183ec8c631cc03243b97f4602d50;p=sfa.git diff --git a/sfa/managers/aggregate_manager_eucalyptus.py b/sfa/managers/aggregate_manager_eucalyptus.py index 552f5446..2356f333 100644 --- a/sfa/managers/aggregate_manager_eucalyptus.py +++ b/sfa/managers/aggregate_manager_eucalyptus.py @@ -17,22 +17,19 @@ from sqlobject import * from sfa.util.faults import InvalidRSpec from sfa.util.xrn import urn_to_hrn, Xrn -from sfa.util.plxrn import hrn_to_pl_slicename, slicename_to_hrn from sfa.util.callids import Callids #comes with its own logging #from sfa.util.sfalogging import logger from sfa.util.version import version_core + from sfa.trust.credential import Credential -from sfa.plc.plaggregate import PlAggregate -# No Slice symbol in there -#from sfa.plc.plslices import Slice, Slices -from sfa.plc.plslices import PlSlices + from sfa.rspecs.version_manager import VersionManager from sfa.rspecs.rspec import RSpec -# not sure what this used to be nor where it is now defined -#from sfa.rspecs.sfa_rspec import sfa_rspec_version -# most likely this should now be -#from sfa.rspecs.version_manager import VersionManager + +from sfa.planetlab.plaggregate import PlAggregate +from sfa.planetlab.plslices import PlSlices +from sfa.planetlab.plxrn import slicename_to_hrn ## # Meta data of an instance. @@ -82,7 +79,7 @@ class EucaInstance(SQLObject): self.instance_id = instance.id # If there is an error, destroy itself. - except EC2ResponseError, ec2RespErr: + except EC2ResponseError as ec2RespErr: errTree = ET.fromstring(ec2RespErr.body) msg = errTree.find('.//Message') logger.error(msg.text) @@ -527,7 +524,7 @@ class AggregateManagerEucalyptus: instList.append(instInfoDict) AggregateManagerEucalyptus.cloud['instances'] = instancesDict - except EC2ResponseError, ec2RespErr: + except EC2ResponseError as ec2RespErr: errTree = ET.fromstring(ec2RespErr.body) errMsgE = errTree.find('.//Message') logger.error(errMsgE.text) @@ -647,7 +644,7 @@ class AggregateManagerEucalyptus: ramdisk_id = instRamDisk, key_pair = instKey, inst_type = instType, - meta = Meta(start_time=datetime.datetime.now())) + meta = Meta(start_time=datetime.datetime.utcnow())) eucaInst.reserveInstance(conn, pubKeys) # xxx - should return altered rspec @@ -664,7 +661,7 @@ class AggregateManagerEucalyptus: try: os.makedirs(outdir) - except OSError, e: + except OSError as e: if e.errno != errno.EEXIST: raise