summaryrefslogtreecommitdiffstats
path: root/base/server/python/pki/server/upgrade.py
diff options
context:
space:
mode:
authorAde Lee <alee@redhat.com>2014-06-07 01:46:41 +0800
committerAde Lee <alee@redhat.com>2014-06-10 20:55:10 +0700
commitf603869e1e9964617fc36c82d19a3105c59a2495 (patch)
treeeef6164bf86aaa95076f267456dd4311cd134704 /base/server/python/pki/server/upgrade.py
parent759565d9b641106fcd60988524659b1f5071592c (diff)
downloadpki-f603869e1e9964617fc36c82d19a3105c59a2495.tar.gz
pki-f603869e1e9964617fc36c82d19a3105c59a2495.tar.xz
pki-f603869e1e9964617fc36c82d19a3105c59a2495.zip
Fix pycharm warnings for server python classes
Mostly reformatting due to PEP8. Not all pycharm warnings are addressed, but the vast majority are.
Diffstat (limited to 'base/server/python/pki/server/upgrade.py')
-rw-r--r--base/server/python/pki/server/upgrade.py86
1 files changed, 55 insertions, 31 deletions
diff --git a/base/server/python/pki/server/upgrade.py b/base/server/python/pki/server/upgrade.py
index 57662b5d2..4cae695d1 100644
--- a/base/server/python/pki/server/upgrade.py
+++ b/base/server/python/pki/server/upgrade.py
@@ -80,26 +80,33 @@ class PKIServerUpgradeScriptlet(pki.upgrade.PKIUpgradeScriptlet):
continue
if not self.can_upgrade_server(instance):
- if verbose: print 'Skipping ' + str(instance) + ' instance.'
+ if verbose:
+ print 'Skipping ' + str(instance) + ' instance.'
continue
try:
- if verbose: print 'Upgrading ' + str(instance) + ' instance.'
+ if verbose:
+ print 'Upgrading ' + str(instance) + ' instance.'
self.upgrade_instance(instance)
self.update_server_tracker(instance)
except Exception as e:
- if verbose: traceback.print_exc()
- else: print 'ERROR: ' + e.message
+ if verbose:
+ traceback.print_exc()
+ else:
+ print 'ERROR: ' + e.message
message = 'Failed upgrading ' + str(instance) + ' instance.'
if self.upgrader.silent:
print message
else:
- result = pki.read_text(message + ' Continue (Yes/No)',
- options=['Y', 'N'], default='Y', delimiter='?', case_sensitive=False).lower()
- if result == 'y': continue
+ result = pki.read_text(
+ message + ' Continue (Yes/No)',
+ options=['Y', 'N'], default='Y',
+ delimiter='?', case_sensitive=False).lower()
+ if result == 'y':
+ continue
raise pki.server.PKIServerException(
'Upgrade failed in ' + str(instance) + ': ' + e.message,
@@ -110,26 +117,33 @@ class PKIServerUpgradeScriptlet(pki.upgrade.PKIUpgradeScriptlet):
for subsystem in self.upgrader.subsystems(instance):
if not self.can_upgrade_server(instance, subsystem):
- if verbose: print 'Skipping ' + str(subsystem) + ' subsystem.'
+ if verbose:
+ print 'Skipping ' + str(subsystem) + ' subsystem.'
continue
try:
- if verbose: print 'Upgrading ' + str(subsystem) + ' subsystem.'
+ if verbose:
+ print 'Upgrading ' + str(subsystem) + ' subsystem.'
self.upgrade_subsystem(instance, subsystem)
self.update_server_tracker(instance, subsystem)
except Exception as e:
- if verbose: traceback.print_exc()
- else: print 'ERROR: ' + e.message
+ if verbose:
+ traceback.print_exc()
+ else:
+ print 'ERROR: ' + e.message
message = 'Failed upgrading ' + str(subsystem) + ' subsystem.'
if self.upgrader.silent:
print message
else:
- result = pki.read_text(message + ' Continue (Yes/No)',
- options=['Y', 'N'], default='Y', delimiter='?', case_sensitive=False).lower()
- if result == 'y': continue
+ result = pki.read_text(
+ message + ' Continue (Yes/No)',
+ options=['Y', 'N'], default='Y',
+ delimiter='?', case_sensitive=False).lower()
+ if result == 'y':
+ continue
raise pki.server.PKIServerException(
'Upgrade failed in ' + str(subsystem) + ': ' + e.message,
@@ -146,14 +160,17 @@ class PKIServerUpgradeScriptlet(pki.upgrade.PKIUpgradeScriptlet):
class PKIServerUpgrader(pki.upgrade.PKIUpgrader):
- def __init__(self, instanceName=None, instanceType=None, subsystemName=None, \
- upgrade_dir=UPGRADE_DIR, version=None, index=None, silent=False):
+ def __init__(
+ self, instanceName=None, instanceType=None, subsystemName=None,
+ upgrade_dir=UPGRADE_DIR, version=None, index=None, silent=False):
- super(PKIServerUpgrader, self).__init__(upgrade_dir, version, index, silent)
+ super(PKIServerUpgrader, self).__init__(
+ upgrade_dir, version, index, silent)
if subsystemName and not instanceName:
raise pki.PKIException(
- 'Invalid subsystem: ' + subsystemName + ', Instance not defined')
+ 'Invalid subsystem: ' + subsystemName +
+ ', Instance not defined')
self.instanceName = instanceName
self.instanceType = instanceType
@@ -165,7 +182,8 @@ class PKIServerUpgrader(pki.upgrade.PKIUpgrader):
def instances(self):
if self.instanceName and self.instanceType:
- return [pki.server.PKIInstance(self.instanceName, self.instanceType)]
+ return [pki.server.PKIInstance(
+ self.instanceName, self.instanceType)]
instance_list = []
@@ -173,23 +191,24 @@ class PKIServerUpgrader(pki.upgrade.PKIUpgrader):
if os.path.exists(os.path.join(pki.server.REGISTRY_DIR, 'tomcat')):
for instanceName in os.listdir(pki.server.INSTANCE_BASE_DIR):
if not self.instanceName or \
- self.instanceName == instanceName:
- instance_list.append(pki.server.PKIInstance(instanceName))
+ self.instanceName == instanceName:
+ instance_list.append(
+ pki.server.PKIInstance(instanceName))
if not self.instanceType or self.instanceType == 9:
for s in pki.server.SUBSYSTEM_TYPES:
if os.path.exists(os.path.join(pki.server.REGISTRY_DIR, s)):
- for instanceName in \
- os.listdir(os.path.join(pki.server.REGISTRY_DIR, s)):
+ for instanceName in os.listdir(
+ os.path.join(pki.server.REGISTRY_DIR, s)):
if not self.instanceName or \
- self.instanceName == instanceName:
- instance_list.append(pki.server.PKIInstance(instanceName, 9))
+ self.instanceName == instanceName:
+ instance_list.append(
+ pki.server.PKIInstance(instanceName, 9))
instance_list.sort()
return instance_list
-
def subsystems(self, instance):
if self.subsystemName:
@@ -198,11 +217,13 @@ class PKIServerUpgrader(pki.upgrade.PKIUpgrader):
subsystem_list = []
if instance.type >= 10:
- registry_dir = os.path.join(pki.server.REGISTRY_DIR, 'tomcat',
+ registry_dir = os.path.join(
+ pki.server.REGISTRY_DIR, 'tomcat',
instance.name)
for subsystemName in os.listdir(registry_dir):
if subsystemName in pki.server.SUBSYSTEM_TYPES:
- subsystem_list.append(pki.server.PKISubsystem(instance, subsystemName))
+ subsystem_list.append(
+ pki.server.PKISubsystem(instance, subsystemName))
else:
for subsystemName in pki.server.SUBSYSTEM_TYPES:
registry_dir = os.path.join(
@@ -210,7 +231,8 @@ class PKIServerUpgrader(pki.upgrade.PKIUpgrader):
subsystemName,
instance.name)
if os.path.exists(registry_dir):
- subsystem_list.append(pki.server.PKISubsystem(instance, subsystemName))
+ subsystem_list.append(
+ pki.server.PKISubsystem(instance, subsystemName))
subsystem_list.sort()
@@ -223,7 +245,8 @@ class PKIServerUpgrader(pki.upgrade.PKIUpgrader):
try:
tracker = self.subsystem_trackers[instance]
except KeyError:
- tracker = pki.upgrade.PKIUpgradeTracker(name + ' subsystem',
+ tracker = pki.upgrade.PKIUpgradeTracker(
+ name + ' subsystem',
SUBSYSTEM_TRACKER % subsystem.conf_dir,
version_key='cms.product.version',
index_key='cms.upgrade.index')
@@ -233,7 +256,8 @@ class PKIServerUpgrader(pki.upgrade.PKIUpgrader):
try:
tracker = self.instance_trackers[str(instance)]
except KeyError:
- tracker = pki.upgrade.PKIUpgradeTracker(str(instance) + ' instance',
+ tracker = pki.upgrade.PKIUpgradeTracker(
+ str(instance) + ' instance',
INSTANCE_TRACKER % instance.conf_dir,
version_key='PKI_VERSION',
index_key='PKI_UPGRADE_INDEX')