Mercurial > repos > shellac > guppy_basecaller
diff env/lib/python3.7/site-packages/boto/emr/emrobject.py @ 5:9b1c78e6ba9c draft default tip
"planemo upload commit 6c0a8142489327ece472c84e558c47da711a9142"
author | shellac |
---|---|
date | Mon, 01 Jun 2020 08:59:25 -0400 |
parents | 79f47841a781 |
children |
line wrap: on
line diff
--- a/env/lib/python3.7/site-packages/boto/emr/emrobject.py Thu May 14 16:47:39 2020 -0400 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,511 +0,0 @@ -# Copyright (c) 2010 Spotify AB -# Copyright (c) 2010 Jeremy Thurgood <firxen+boto@gmail.com> -# Copyright (c) 2010-2011 Yelp -# -# Permission is hereby granted, free of charge, to any person obtaining a -# copy of this software and associated documentation files (the -# "Software"), to deal in the Software without restriction, including -# without limitation the rights to use, copy, modify, merge, publish, dis- -# tribute, sublicense, and/or sell copies of the Software, and to permit -# persons to whom the Software is furnished to do so, subject to the fol- -# lowing conditions: -# -# The above copyright notice and this permission notice shall be included -# in all copies or substantial portions of the Software. -# -# THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS -# OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABIL- -# ITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT -# SHALL THE AUTHOR BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, -# WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, -# OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS -# IN THE SOFTWARE. - -""" -This module contains EMR response objects -""" - -from boto.resultset import ResultSet - - -class EmrObject(object): - Fields = set() - - def __init__(self, connection=None): - self.connection = connection - - def startElement(self, name, attrs, connection): - pass - - def endElement(self, name, value, connection): - if name in self.Fields: - setattr(self, name.lower(), value) - - -class RunJobFlowResponse(EmrObject): - Fields = set(['JobFlowId']) - -class AddInstanceGroupsResponse(EmrObject): - Fields = set(['InstanceGroupIds', 'JobFlowId']) - -class ModifyInstanceGroupsResponse(EmrObject): - Fields = set(['RequestId']) - - -class Arg(EmrObject): - def __init__(self, connection=None): - self.value = None - - def endElement(self, name, value, connection): - self.value = value - - -class StepId(Arg): - pass - - -class SupportedProduct(Arg): - pass - - -class JobFlowStepList(EmrObject): - def __ini__(self, connection=None): - self.connection = connection - self.stepids = None - - def startElement(self, name, attrs, connection): - if name == 'StepIds': - self.stepids = ResultSet([('member', StepId)]) - return self.stepids - else: - return None - - -class BootstrapAction(EmrObject): - Fields = set([ - 'Args', - 'Name', - 'Path', - 'ScriptPath', - ]) - - def startElement(self, name, attrs, connection): - if name == 'Args': - self.args = ResultSet([('member', Arg)]) - return self.args - - -class KeyValue(EmrObject): - Fields = set([ - 'Key', - 'Value', - ]) - - -class Step(EmrObject): - Fields = set([ - 'ActionOnFailure', - 'CreationDateTime', - 'EndDateTime', - 'Jar', - 'LastStateChangeReason', - 'MainClass', - 'Name', - 'StartDateTime', - 'State', - ]) - - def __init__(self, connection=None): - self.connection = connection - self.args = None - - def startElement(self, name, attrs, connection): - if name == 'Args': - self.args = ResultSet([('member', Arg)]) - return self.args - if name == 'Properties': - self.properties = ResultSet([('member', KeyValue)]) - return self.properties - - -class InstanceGroup(EmrObject): - Fields = set([ - 'BidPrice', - 'CreationDateTime', - 'EndDateTime', - 'InstanceGroupId', - 'InstanceRequestCount', - 'InstanceRole', - 'InstanceRunningCount', - 'InstanceType', - 'LastStateChangeReason', - 'LaunchGroup', - 'Market', - 'Name', - 'ReadyDateTime', - 'StartDateTime', - 'State', - ]) - - -class JobFlow(EmrObject): - Fields = set([ - 'AmiVersion', - 'AvailabilityZone', - 'CreationDateTime', - 'Ec2KeyName', - 'EndDateTime', - 'HadoopVersion', - 'Id', - 'InstanceCount', - 'JobFlowId', - 'KeepJobFlowAliveWhenNoSteps', - 'LastStateChangeReason', - 'LogUri', - 'MasterInstanceId', - 'MasterInstanceType', - 'MasterPublicDnsName', - 'Name', - 'NormalizedInstanceHours', - 'ReadyDateTime', - 'RequestId', - 'SlaveInstanceType', - 'StartDateTime', - 'State', - 'TerminationProtected', - 'Type', - 'Value', - 'VisibleToAllUsers', - ]) - - def __init__(self, connection=None): - self.connection = connection - self.steps = None - self.instancegroups = None - self.bootstrapactions = None - - def startElement(self, name, attrs, connection): - if name == 'Steps': - self.steps = ResultSet([('member', Step)]) - return self.steps - elif name == 'InstanceGroups': - self.instancegroups = ResultSet([('member', InstanceGroup)]) - return self.instancegroups - elif name == 'BootstrapActions': - self.bootstrapactions = ResultSet([('member', BootstrapAction)]) - return self.bootstrapactions - elif name == 'SupportedProducts': - self.supported_products = ResultSet([('member', SupportedProduct)]) - return self.supported_products - else: - return None - - -class ClusterTimeline(EmrObject): - Fields = set([ - 'CreationDateTime', - 'ReadyDateTime', - 'EndDateTime' - ]) - -class ClusterStateChangeReason(EmrObject): - Fields = set([ - 'Code', - 'Message' - ]) - -class ClusterStatus(EmrObject): - Fields = set([ - 'State', - 'StateChangeReason', - 'Timeline' - ]) - - def __init__(self, connection=None): - self.connection = connection - self.timeline = None - - def startElement(self, name, attrs, connection): - if name == 'Timeline': - self.timeline = ClusterTimeline() - return self.timeline - elif name == 'StateChangeReason': - self.statechangereason = ClusterStateChangeReason() - return self.statechangereason - else: - return None - - -class Ec2InstanceAttributes(EmrObject): - Fields = set([ - 'Ec2KeyName', - 'Ec2SubnetId', - 'Ec2AvailabilityZone', - 'IamInstanceProfile' - ]) - - -class Application(EmrObject): - Fields = set([ - 'Name', - 'Version', - 'Args', - 'AdditionalInfo' - ]) - - -class Cluster(EmrObject): - Fields = set([ - 'Id', - 'Name', - 'LogUri', - 'RequestedAmiVersion', - 'RunningAmiVersion', - 'AutoTerminate', - 'TerminationProtected', - 'VisibleToAllUsers', - 'MasterPublicDnsName', - 'NormalizedInstanceHours', - 'ServiceRole' - ]) - - def __init__(self, connection=None): - self.connection = connection - self.status = None - self.ec2instanceattributes = None - self.applications = None - self.tags = None - - def startElement(self, name, attrs, connection): - if name == 'Status': - self.status = ClusterStatus() - return self.status - elif name == 'Ec2InstanceAttributes': - self.ec2instanceattributes = Ec2InstanceAttributes() - return self.ec2instanceattributes - elif name == 'Applications': - self.applications = ResultSet([('member', Application)]) - return self.applications - elif name == 'Tags': - self.tags = ResultSet([('member', KeyValue)]) - return self.tags - else: - return None - - -class ClusterSummary(EmrObject): - Fields = set([ - 'Id', - 'Name', - 'NormalizedInstanceHours' - ]) - - def __init__(self, connection): - self.connection = connection - self.status = None - - def startElement(self, name, attrs, connection): - if name == 'Status': - self.status = ClusterStatus() - return self.status - else: - return None - - -class ClusterSummaryList(EmrObject): - Fields = set([ - 'Marker' - ]) - - def __init__(self, connection): - self.connection = connection - self.clusters = None - - def startElement(self, name, attrs, connection): - if name == 'Clusters': - self.clusters = ResultSet([('member', ClusterSummary)]) - return self.clusters - else: - return None - - -class StepConfig(EmrObject): - Fields = set([ - 'Jar', - 'MainClass' - ]) - - def __init__(self, connection=None): - self.connection = connection - self.properties = None - self.args = None - - def startElement(self, name, attrs, connection): - if name == 'Properties': - self.properties = ResultSet([('member', KeyValue)]) - return self.properties - elif name == 'Args': - self.args = ResultSet([('member', Arg)]) - return self.args - else: - return None - - -class HadoopStep(EmrObject): - Fields = set([ - 'Id', - 'Name', - 'ActionOnFailure' - ]) - - def __init__(self, connection=None): - self.connection = connection - self.config = None - self.status = None - - def startElement(self, name, attrs, connection): - if name == 'Config': - self.config = StepConfig() - return self.config - elif name == 'Status': - self.status = ClusterStatus() - return self.status - else: - return None - - - -class InstanceGroupInfo(EmrObject): - Fields = set([ - 'Id', - 'Name', - 'Market', - 'InstanceGroupType', - 'BidPrice', - 'InstanceType', - 'RequestedInstanceCount', - 'RunningInstanceCount' - ]) - - def __init__(self, connection=None): - self.connection = connection - self.status = None - - def startElement(self, name, attrs, connection): - if name == 'Status': - self.status = ClusterStatus() - return self.status - else: - return None - - -class InstanceGroupList(EmrObject): - Fields = set([ - 'Marker' - ]) - - def __init__(self, connection=None): - self.connection = connection - self.instancegroups = None - - def startElement(self, name, attrs, connection): - if name == 'InstanceGroups': - self.instancegroups = ResultSet([('member', InstanceGroupInfo)]) - return self.instancegroups - else: - return None - - -class InstanceInfo(EmrObject): - Fields = set([ - 'Id', - 'Ec2InstanceId', - 'PublicDnsName', - 'PublicIpAddress', - 'PrivateDnsName', - 'PrivateIpAddress' - ]) - - def __init__(self, connection=None): - self.connection = connection - self.status = None - - def startElement(self, name, attrs, connection): - if name == 'Status': - self.status = ClusterStatus() - return self.status - else: - return None - - -class InstanceList(EmrObject): - Fields = set([ - 'Marker' - ]) - - def __init__(self, connection=None): - self.connection = connection - self.instances = None - - def startElement(self, name, attrs, connection): - if name == 'Instances': - self.instances = ResultSet([('member', InstanceInfo)]) - return self.instances - else: - return None - - -class StepSummary(EmrObject): - Fields = set([ - 'Id', - 'Name' - ]) - - def __init__(self, connection=None): - self.connection = connection - self.status = None - self.config = None - - def startElement(self, name, attrs, connection): - if name == 'Status': - self.status = ClusterStatus() - return self.status - elif name == 'Config': - self.config = StepConfig() - return self.config - else: - return None - - -class StepSummaryList(EmrObject): - Fields = set([ - 'Marker' - ]) - - def __init__(self, connection=None): - self.connection = connection - self.steps = None - - def startElement(self, name, attrs, connection): - if name == 'Steps': - self.steps = ResultSet([('member', StepSummary)]) - return self.steps - else: - return None - - -class BootstrapActionList(EmrObject): - Fields = set([ - 'Marker' - ]) - - def __init__(self, connection=None): - self.connection = connection - self.actions = None - - def startElement(self, name, attrs, connection): - if name == 'BootstrapActions': - self.actions = ResultSet([('member', BootstrapAction)]) - return self.actions - else: - return None