Skip to content

Commit

Permalink
pep8 fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
jkoelker committed May 31, 2011
1 parent 6085115 commit 36c9396
Show file tree
Hide file tree
Showing 11 changed files with 28 additions and 40 deletions.
3 changes: 2 additions & 1 deletion nova/db/sqlalchemy/api.py
Expand Up @@ -748,6 +748,7 @@ def fixed_ip_get_all_by_instance(context, instance_id):
raise exception.NoFixedIpsFoundForInstance(instance_id=instance_id)
return rv


@require_context
def fixed_ip_get_by_instance_and_network(context, instance_id,
network_id):
Expand Down Expand Up @@ -2434,7 +2435,7 @@ def project_get_networks(context, project_id, associate=True):
result = session.query(models.Network).\
filter_by(project_id=project_id).\
filter_by(deleted=False).all()

if not result:
if not associate:
return []
Expand Down
Expand Up @@ -160,8 +160,7 @@ def convert_backward(migrate_engine, old_quotas, new_quotas):
'project_id': quota.project_id,
'created_at': quota.created_at,
'updated_at': quota.updated_at,
quota.resource: quota.hard_limit
}
quota.resource: quota.hard_limit}
else:
quotas[quota.project_id]['created_at'] = earliest(
quota.created_at, quotas[quota.project_id]['created_at'])
Expand Down
3 changes: 1 addition & 2 deletions nova/scheduler/host_filter.py
Expand Up @@ -222,8 +222,7 @@ def instance_type_to_filter(self, instance_type):
required_disk = instance_type['local_gb']
query = ['and',
['>=', '$compute.host_memory_free', required_ram],
['>=', '$compute.disk_available', required_disk]
]
['>=', '$compute.disk_available', required_disk]]
return (self._full_name(), json.dumps(query))

def _parse_string(self, string, host, services):
Expand Down
2 changes: 1 addition & 1 deletion nova/test.py
Expand Up @@ -59,7 +59,7 @@ class skip_test(object):
"""decorator that skips a test"""
def __init__(self, msg):
self.message = msg

def __call__(self, func):
def _skipper(*args, **kw):
"""wrapped skipper function."""
Expand Down
2 changes: 1 addition & 1 deletion nova/tests/__init__.py
Expand Up @@ -67,6 +67,6 @@ def setup():
vlan_start=FLAGS.vlan_start)
for net in db.network_get_all(ctxt):
network.set_network_host(ctxt, net['id'])

cleandb = os.path.join(FLAGS.state_path, FLAGS.sqlite_clean_db)
shutil.copyfile(testdb, cleandb)
3 changes: 2 additions & 1 deletion nova/tests/api/openstack/test_servers.py
Expand Up @@ -465,7 +465,8 @@ def kernel_ramdisk_mapping(*args, **kwargs):
def image_id_from_hash(*args, **kwargs):
return 2

self.stubs.Set(nova.db.api, 'project_get_networks', project_get_networks)
self.stubs.Set(nova.db.api, 'project_get_networks',
project_get_networks)
self.stubs.Set(nova.db.api, 'instance_create', instance_create)
self.stubs.Set(nova.rpc, 'cast', fake_method)
self.stubs.Set(nova.rpc, 'call', fake_method)
Expand Down
29 changes: 10 additions & 19 deletions nova/tests/test_host_filter.py
Expand Up @@ -132,13 +132,10 @@ def test_json_driver(self):
raw = ['or',
['and',
['<', '$compute.host_memory_free', 30],
['<', '$compute.disk_available', 300]
],
['<', '$compute.disk_available', 300]],
['and',
['>', '$compute.host_memory_free', 70],
['>', '$compute.disk_available', 700]
]
]
['>', '$compute.disk_available', 700]]]
cooked = json.dumps(raw)
hosts = driver.filter_hosts(self.zone_manager, cooked)

Expand All @@ -149,8 +146,7 @@ def test_json_driver(self):
self.assertEquals('host%02d' % index, host)

raw = ['not',
['=', '$compute.host_memory_free', 30],
]
['=', '$compute.host_memory_free', 30],]
cooked = json.dumps(raw)
hosts = driver.filter_hosts(self.zone_manager, cooked)

Expand Down Expand Up @@ -182,27 +178,22 @@ def test_json_driver(self):
self.assertTrue(driver.filter_hosts(self.zone_manager, json.dumps([])))
self.assertTrue(driver.filter_hosts(self.zone_manager, json.dumps({})))
self.assertTrue(driver.filter_hosts(self.zone_manager, json.dumps(
['not', True, False, True, False]
)))
['not', True, False, True, False])))

try:
driver.filter_hosts(self.zone_manager, json.dumps(
'not', True, False, True, False
))
'not', True, False, True, False))
self.fail("Should give KeyError")
except KeyError, e:
pass

self.assertFalse(driver.filter_hosts(self.zone_manager, json.dumps(
['=', '$foo', 100]
)))
['=', '$foo', 100])))
self.assertFalse(driver.filter_hosts(self.zone_manager, json.dumps(
['=', '$.....', 100]
)))
['=', '$.....', 100])))
self.assertFalse(driver.filter_hosts(self.zone_manager, json.dumps(
['>', ['and', ['or', ['not', ['<', ['>=', ['<=', ['in', ]]]]]]]]
)))
['>', ['and', ['or', ['not', ['<', ['>=',
['<=', ['in', ]]]]]]]])))

self.assertFalse(driver.filter_hosts(self.zone_manager, json.dumps(
['=', {}, ['>', '$missing....foo']]
)))
['=', {}, ['>', '$missing....foo']])))
9 changes: 4 additions & 5 deletions nova/tests/test_virt.py
Expand Up @@ -82,6 +82,7 @@ def _setup_networking(instance_id, ip='1.2.3.4'):
db.fixed_ip_update(ctxt, ip, {'allocated': True,
'instance_id': instance_id})


class CacheConcurrencyTestCase(test.TestCase):
def setUp(self):
super(CacheConcurrencyTestCase, self).setUp()
Expand Down Expand Up @@ -173,8 +174,6 @@ def tearDown(self):
self.manager.delete_user(self.user)
super(LibvirtConnTestCase, self).tearDown()



test_ip = '10.11.12.13'
test_instance = {'memory_kb': '1024000',
'basepath': '/some/path',
Expand All @@ -183,7 +182,7 @@ def tearDown(self):
'vcpus': 2,
'project_id': 'fake',
'bridge': 'br101',
'instance_type_id': '5'} # m1.small
'instance_type_id': '5'} # m1.small

def lazy_load_library_exists(self):
"""check if libvirt is available."""
Expand Down Expand Up @@ -673,7 +672,8 @@ def test_get_host_ip_addr(self):
conn = libvirt_conn.LibvirtConnection(False)
ip = conn.get_host_ip_addr()
self.assertEquals(ip, FLAGS.my_ip)



class IptablesFirewallTestCase(test.TestCase):
def setUp(self):
super(IptablesFirewallTestCase, self).setUp()
Expand Down Expand Up @@ -891,7 +891,6 @@ def test_multinic_iptables(self):
self.assertEquals(ipv6_network_rules,
ipv6_rules_per_network * networks_count)


@test.skip_test("skipping libvirt tests")
def test_do_refresh_security_group_rules(self):
instance_ref = self._create_instance_ref()
Expand Down
2 changes: 2 additions & 0 deletions nova/tests/test_xenapi.py
Expand Up @@ -496,8 +496,10 @@ def test_spawn_vlanmanager(self):
network_manager='nova.network.manager.VlanManager',
network_driver='nova.network.xenapi_net',
vlan_interface='fake0')

def dummy(*args, **kwargs):
pass

self.stubs.Set(VMOps, 'create_vifs', dummy)
# Reset network table
xenapi_fake.reset_table('network')
Expand Down
10 changes: 3 additions & 7 deletions nova/tests/test_zone_aware_scheduler.py
Expand Up @@ -39,15 +39,11 @@ class FakeZoneManager(zone_manager.ZoneManager):
def __init__(self):
self.service_states = {
'host1': {
'compute': {'ram': 1000}
},
'compute': {'ram': 1000}},
'host2': {
'compute': {'ram': 2000}
},
'compute': {'ram': 2000}},
'host3': {
'compute': {'ram': 3000}
}
}
'compute': {'ram': 3000}}}


class FakeEmptyZoneManager(zone_manager.ZoneManager):
Expand Down
2 changes: 1 addition & 1 deletion tools/install_venv.py
Expand Up @@ -36,7 +36,7 @@


def die(message, *args):
print >>sys.stderr, message % args
print >> sys.stderr, message % args
sys.exit(1)


Expand Down

0 comments on commit 36c9396

Please sign in to comment.