Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(425)

Unified Diff: tools/telemetry/third_party/gsutil/third_party/boto/boto/emr/emrobject.py

Issue 1260493004: Revert "Add gsutil 4.13 to telemetry/third_party" (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Created 5 years, 5 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: tools/telemetry/third_party/gsutil/third_party/boto/boto/emr/emrobject.py
diff --git a/tools/telemetry/third_party/gsutil/third_party/boto/boto/emr/emrobject.py b/tools/telemetry/third_party/gsutil/third_party/boto/boto/emr/emrobject.py
deleted file mode 100644
index 73f7060ba17aaa0999aebc9bf7760e8cd084e27d..0000000000000000000000000000000000000000
--- a/tools/telemetry/third_party/gsutil/third_party/boto/boto/emr/emrobject.py
+++ /dev/null
@@ -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

Powered by Google App Engine
This is Rietveld 408576698