Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Discard master-slave terminology #1

Open
wants to merge 1 commit into
base: master
Choose a base branch
from
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
22 changes: 11 additions & 11 deletions boto/emr/connection.py
Original file line number Diff line number Diff line change
Expand Up @@ -189,8 +189,8 @@ def modify_instance_groups(self, instance_group_ids, new_sizes):
return self.get_object('ModifyInstanceGroups', params, ModifyInstanceGroupsResponse, verb='POST')

def run_jobflow(self, name, log_uri, ec2_keyname=None, availability_zone=None,
master_instance_type='m1.small',
slave_instance_type='m1.small', num_instances=1,
main_instance_type='m1.small',
subordinate_instance_type='m1.small', num_instances=1,
action_on_failure='TERMINATE_JOB_FLOW', keep_alive=False,
enable_debugging=False,
hadoop_version='0.18',
Expand All @@ -207,10 +207,10 @@ def run_jobflow(self, name, log_uri, ec2_keyname=None, availability_zone=None,
:param ec2_keyname: EC2 key used for the instances
:type availability_zone: str
:param availability_zone: EC2 availability zone of the cluster
:type master_instance_type: str
:param master_instance_type: EC2 instance type of the master
:type slave_instance_type: str
:param slave_instance_type: EC2 instance type of the slave nodes
:type main_instance_type: str
:param main_instance_type: EC2 instance type of the main
:type subordinate_instance_type: str
:param subordinate_instance_type: EC2 instance type of the subordinate nodes
:type num_instances: int
:param num_instances: Number of instances in the Hadoop cluster
:type action_on_failure: str
Expand All @@ -233,7 +233,7 @@ def run_jobflow(self, name, log_uri, ec2_keyname=None, availability_zone=None,

# Instance args
instance_params = self._build_instance_args(ec2_keyname, availability_zone,
master_instance_type, slave_instance_type,
main_instance_type, subordinate_instance_type,
num_instances, keep_alive, hadoop_version)
params.update(instance_params)

Expand Down Expand Up @@ -310,11 +310,11 @@ def _build_step_list(self, steps):
params['Steps.member.%s.%s' % (i+1, key)] = value
return params

def _build_instance_args(self, ec2_keyname, availability_zone, master_instance_type,
slave_instance_type, num_instances, keep_alive, hadoop_version):
def _build_instance_args(self, ec2_keyname, availability_zone, main_instance_type,
subordinate_instance_type, num_instances, keep_alive, hadoop_version):
params = {
'Instances.MasterInstanceType' : master_instance_type,
'Instances.SlaveInstanceType' : slave_instance_type,
'Instances.MainInstanceType' : main_instance_type,
'Instances.SubordinateInstanceType' : subordinate_instance_type,
'Instances.InstanceCount' : num_instances,
'Instances.KeepJobFlowAliveWhenNoSteps' : str(keep_alive).lower(),
'Instances.HadoopVersion' : hadoop_version
Expand Down
2 changes: 1 addition & 1 deletion boto/emr/step.py
Original file line number Diff line number Diff line change
Expand Up @@ -122,7 +122,7 @@ def __init__(self, name, mapper, reducer=None,
:type output: str
:param output: The output uri
:type jar: str
:param jar: The hadoop streaming jar. This can be either a local path on the master node, or an s3:// URI.
:param jar: The hadoop streaming jar. This can be either a local path on the main node, or an s3:// URI.
"""
self.name = name
self.mapper = mapper
Expand Down
2 changes: 1 addition & 1 deletion boto/pyami/bootstrap.py
Original file line number Diff line number Diff line change
Expand Up @@ -88,7 +88,7 @@ def load_boto(self):
if update.find(':') >= 0:
method, version = update.split(':')
else:
version = 'master'
version = 'main'
self.run('git checkout %s' % version, cwd=location)
else:
# first remove the symlink needed when running from subversion
Expand Down
24 changes: 12 additions & 12 deletions boto/rds/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -113,7 +113,7 @@ def get_all_dbinstances(self, instance_id=None, max_records=None,
return self.get_list('DescribeDBInstances', params, [('DBInstance', DBInstance)])

def create_dbinstance(self, id, allocated_storage, instance_class,
master_username, master_password, port=3306,
main_username, main_password, port=3306,
engine='MySQL5.1', db_name=None, param_group=None,
security_groups=None, availability_zone=None,
preferred_maintenance_window=None,
Expand Down Expand Up @@ -150,13 +150,13 @@ def create_dbinstance(self, id, allocated_storage, instance_class,
:type engine: str
:param engine: Name of database engine. Must be MySQL5.1 for now.

:type master_username: str
:param master_username: Name of master user for the DBInstance.
:type main_username: str
:param main_username: Name of main user for the DBInstance.
Must be 1-15 alphanumeric characters, first
must be a letter.

:type master_password: str
:param master_password: Password of master user for the DBInstance.
:type main_password: str
:param main_password: Password of main user for the DBInstance.
Must be 4-16 alphanumeric characters.

:type port: int
Expand Down Expand Up @@ -217,8 +217,8 @@ def create_dbinstance(self, id, allocated_storage, instance_class,
'AllocatedStorage' : allocated_storage,
'DBInstanceClass' : instance_class,
'Engine' : engine,
'MasterUsername' : master_username,
'MasterUserPassword' : master_password}
'MainUsername' : main_username,
'MainUserPassword' : main_password}
if port:
params['Port'] = port
if db_name:
Expand Down Expand Up @@ -321,7 +321,7 @@ def create_dbinstance_read_replica(self, id, source_id,

def modify_dbinstance(self, id, param_group=None, security_groups=None,
preferred_maintenance_window=None,
master_password=None, allocated_storage=None,
main_password=None, allocated_storage=None,
instance_class=None,
backup_retention_period=None,
preferred_backup_window=None,
Expand All @@ -343,8 +343,8 @@ def modify_dbinstance(self, id, param_group=None, security_groups=None,
occur.
Default is Sun:05:00-Sun:09:00

:type master_password: str
:param master_password: Password of master user for the DBInstance.
:type main_password: str
:param main_password: Password of main user for the DBInstance.
Must be 4-15 alphanumeric characters.

:type allocated_storage: int
Expand Down Expand Up @@ -402,8 +402,8 @@ def modify_dbinstance(self, id, param_group=None, security_groups=None,
self.build_list_params(params, l, 'DBSecurityGroups.member')
if preferred_maintenance_window:
params['PreferredMaintenanceWindow'] = preferred_maintenance_window
if master_password:
params['MasterUserPassword'] = master_password
if main_password:
params['MainUserPassword'] = main_password
if allocated_storage:
params['AllocatedStorage'] = allocated_storage
if instance_class:
Expand Down
14 changes: 7 additions & 7 deletions boto/rds/dbinstance.py
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,7 @@ def __init__(self, connection=None, id=None):
self.allocated_storage = None
self.endpoint = None
self.instance_class = None
self.master_username = None
self.main_username = None
self.parameter_group = None
self.security_group = None
self.availability_zone = None
Expand Down Expand Up @@ -82,8 +82,8 @@ def endElement(self, name, value, connection):
self.allocated_storage = int(value)
elif name == 'DBInstanceClass':
self.instance_class = value
elif name == 'MasterUsername':
self.master_username = value
elif name == 'MainUsername':
self.main_username = value
elif name == 'Port':
if self._in_endpoint:
self._port = int(value)
Expand Down Expand Up @@ -176,7 +176,7 @@ def stop(self, skip_final_snapshot=False, final_snapshot_id=''):

def modify(self, param_group=None, security_groups=None,
preferred_maintenance_window=None,
master_password=None, allocated_storage=None,
main_password=None, allocated_storage=None,
instance_class=None,
backup_retention_period=None,
preferred_backup_window=None,
Expand All @@ -195,8 +195,8 @@ def modify(self, param_group=None, security_groups=None,
occur.
Default is Sun:05:00-Sun:09:00

:type master_password: str
:param master_password: Password of master user for the DBInstance.
:type main_password: str
:param main_password: Password of main user for the DBInstance.
Must be 4-15 alphanumeric characters.

:type allocated_storage: int
Expand Down Expand Up @@ -245,7 +245,7 @@ def modify(self, param_group=None, security_groups=None,
param_group,
security_groups,
preferred_maintenance_window,
master_password,
main_password,
allocated_storage,
instance_class,
backup_retention_period,
Expand Down
6 changes: 3 additions & 3 deletions boto/rds/dbsnapshot.py
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@ def __init__(self, connection=None, id=None):
self.port = None
self.status = None
self.availability_zone = None
self.master_username = None
self.main_username = None
self.allocated_storage = None
self.instance_id = None
self.availability_zone = None
Expand Down Expand Up @@ -61,8 +61,8 @@ def endElement(self, name, value, connection):
self.status = value
elif name == 'AvailabilityZone':
self.availability_zone = value
elif name == 'MasterUsername':
self.master_username = value
elif name == 'MainUsername':
self.main_username = value
elif name == 'AllocatedStorage':
self.allocated_storage = int(value)
elif name == 'SnapshotTime':
Expand Down
2 changes: 1 addition & 1 deletion django/conf/global_settings.py
Original file line number Diff line number Diff line change
Expand Up @@ -209,7 +209,7 @@

# Default e-mail address to use for various automated correspondence from
# the site managers.
DEFAULT_FROM_EMAIL = 'webmaster@localhost'
DEFAULT_FROM_EMAIL = 'webmain@localhost'

# Subject-line prefix for email messages send with django.core.mail.mail_admins
# or ...mail_managers. Make sure to include the trailing space.
Expand Down
6 changes: 3 additions & 3 deletions django/db/backends/sqlite3/introspection.py
Original file line number Diff line number Diff line change
Expand Up @@ -46,7 +46,7 @@ def get_table_list(self, cursor):
# Skip the sqlite_sequence system table used for autoincrement key
# generation.
cursor.execute("""
SELECT name FROM sqlite_master
SELECT name FROM sqlite_main
WHERE type='table' AND NOT name='sqlite_sequence'
ORDER BY name""")
return [row[0] for row in cursor.fetchall()]
Expand All @@ -66,7 +66,7 @@ def get_relations(self, cursor, table_name):
relations = {}

# Schema for this table
cursor.execute("SELECT sql FROM sqlite_master WHERE tbl_name = %s AND type = %s", [table_name, "table"])
cursor.execute("SELECT sql FROM sqlite_main WHERE tbl_name = %s AND type = %s", [table_name, "table"])
results = cursor.fetchone()[0].strip()
results = results[results.index('(')+1:results.rindex(')')]

Expand All @@ -84,7 +84,7 @@ def get_relations(self, cursor, table_name):

table, column = [s.strip('"') for s in m.groups()]

cursor.execute("SELECT sql FROM sqlite_master WHERE tbl_name = %s", [table])
cursor.execute("SELECT sql FROM sqlite_main WHERE tbl_name = %s", [table])
result = cursor.fetchall()[0]
other_table_results = result[0].strip()
li, ri = other_table_results.index('('), other_table_results.rindex(')')
Expand Down
28 changes: 14 additions & 14 deletions django/test/_doctest.py
Original file line number Diff line number Diff line change
Expand Up @@ -1466,7 +1466,7 @@ def summarize(self, verbose=None):
return totalf, totalt

#/////////////////////////////////////////////////////////////////
# Backward compatibility cruft to maintain doctest.master.
# Backward compatibility cruft to maintain doctest.main.
#/////////////////////////////////////////////////////////////////
def merge(self, other):
d = self._name2ft
Expand Down Expand Up @@ -1760,7 +1760,7 @@ def report_failure(self, out, test, example, got):

# For backward compatibility, a global instance of a DocTestRunner
# class, updated by testmod.
master = None
main = None

def testmod(m=None, name=None, globs=None, verbose=None, isprivate=None,
report=True, optionflags=0, extraglobs=None,
Expand Down Expand Up @@ -1829,13 +1829,13 @@ def testmod(m=None, name=None, globs=None, verbose=None, isprivate=None,

Advanced tomfoolery: testmod runs methods of a local instance of
class doctest.Tester, then merges the results into (or creates)
global Tester instance doctest.master. Methods of doctest.master
global Tester instance doctest.main. Methods of doctest.main
can be called directly too, if you want to do something unusual.
Passing report=0 to testmod is especially useful then, to delay
displaying a summary. Invoke doctest.master.summarize(verbose)
displaying a summary. Invoke doctest.main.summarize(verbose)
when you're done fiddling.
"""
global master
global main

if isprivate is not None:
warnings.warn("the isprivate argument is deprecated; "
Expand Down Expand Up @@ -1871,10 +1871,10 @@ class doctest.Tester, then merges the results into (or creates)
if report:
runner.summarize()

if master is None:
master = runner
if main is None:
main = runner
else:
master.merge(runner)
main.merge(runner)

return runner.failures, runner.tries

Expand Down Expand Up @@ -1947,13 +1947,13 @@ def testfile(filename, module_relative=True, name=None, package=None,

Advanced tomfoolery: testmod runs methods of a local instance of
class doctest.Tester, then merges the results into (or creates)
global Tester instance doctest.master. Methods of doctest.master
global Tester instance doctest.main. Methods of doctest.main
can be called directly too, if you want to do something unusual.
Passing report=0 to testmod is especially useful then, to delay
displaying a summary. Invoke doctest.master.summarize(verbose)
displaying a summary. Invoke doctest.main.summarize(verbose)
when you're done fiddling.
"""
global master
global main

if package and not module_relative:
raise ValueError("Package may only be specified for module-"
Expand Down Expand Up @@ -1989,10 +1989,10 @@ class doctest.Tester, then merges the results into (or creates)
if report:
runner.summarize()

if master is None:
master = runner
if main is None:
main = runner
else:
master.merge(runner)
main.merge(runner)

return runner.failures, runner.tries

Expand Down
2 changes: 1 addition & 1 deletion django/test/client.py
Original file line number Diff line number Diff line change
Expand Up @@ -370,7 +370,7 @@ def _session(self):

def request(self, **request):
"""
The master request method. Composes the environment dictionary
The main request method. Composes the environment dictionary
and passes to the handler, returning the result of the handler.
Assumes defaults for the query environment, which can be overridden
using the arguments to the request.
Expand Down