A bunch of unused imports and variables.
import urlparse
import yaml
import json
-import subprocess
from teuthology import safepath
from .orchestra import run
import argparse
import yaml
-import subprocess
def parse_args():
from teuthology.run import config_file
-from cStringIO import StringIO
-
import contextlib
import logging
-import os
-import re
-import yaml
from teuthology import misc as teuthology
from teuthology import contextutil
osds = ctx.cluster.only(teuthology.is_type('osd'))
for remote, roles_for_host in osds.remotes.iteritems():
log.info('Creating %s on %s' % (log_dir,remote.name))
- proc = remote.run(
+ remote.run(
args=['mkdir', '-p', '-m0755', '--', log_dir],
wait=False,
)
osds = ctx.cluster.only(teuthology.is_type('osd'))
for remote, roles_for_host in osds.remotes.iteritems():
roles_to_devs = ctx.disk_config.remote_to_roles_to_dev[remote]
- roles_to_journals = ctx.disk_config.remote_to_roles_to_journals[remote]
for id_ in teuthology.roles_of_type(roles_for_host, 'osd'):
if roles_to_devs.get(id_):
dev = roles_to_devs[id_]
import contextlib
import logging
-import os
import time
from ..orchestra import run
(role_remote,) = ctx.cluster.only(role).remotes.keys()
if enable:
log.info('Enabling kdb on {role}...'.format(role=role))
- proc = role_remote.run(
+ role_remote.run(
args=[
'echo', 'ttyS1',
run.Raw('|'),
])
else:
log.info('Disabling kdb on {role}...'.format(role=role))
- proc = role_remote.run(
+ role_remote.run(
args=[
'echo', '',
run.Raw('|'),
import logging
import ceph_manager
from teuthology import misc as teuthology
-import time
log = logging.getLogger(__name__)
# write some more (make sure osd.2 really is divergent)
p = rados_start(mon, ['-p', 'rbd', 'bench', '15', 'write', '-b', '4096'])
- err = p.exitstatus.get();
+ p.exitstatus.get();
# revive divergent osd
manager.revive_osd(2)
# lots of objects in rbd (no pg log, will backfill)
p = rados_start(mon, ['-p', 'rbd', 'bench', '30', 'write', '-b', '4096'])
- err = p.exitstatus.get()
+ p.exitstatus.get()
# few objects in metadata pool (with pg log, normal recovery)
for f in range(1, 20):
p = rados_start(mon, ['-p', 'metadata', 'put',
'foo.%d' % f, '/etc/passwd'])
- err = p.exitstatus.get()
+ p.exitstatus.get()
# move it back
manager.raw_cluster_cmd('osd', 'in', '0', '1')
import contextlib
import logging
-import yaml
from teuthology import misc as teuthology
from teuthology import contextutil
"""Take car of some yaml parsing here"""
if config is not None and not isinstance(config, list) and not isinstance(config, dict):
- assert(false), "task parallel_example only supports a list or dictionary for configuration"
+ assert(False), "task parallel_example only supports a list or dictionary for configuration"
if config is None:
config = ['client.{id}'.format(id=id_)
for id_ in teuthology.all_roles_of_type(ctx.cluster, 'client')]
# the 5th should fail.
failed = False
try:
- bucket5 = connection.create_bucket(bucket_name + '5')
+ connection.create_bucket(bucket_name + '5')
except:
failed = True
assert failed
import contextlib
import logging
-from ..orchestra import run
from teuthology.parallel import parallel
log = logging.getLogger(__name__)