import json
from teuthology import safepath
-from teuthology import lockstatus
from .orchestra import run
from .config import config
import re
import subprocess
import sys
-import tempfile
from textwrap import dedent, fill
import time
import yaml
from teuthology import misc
-from teuthology import safepath
from teuthology import lock as lock
-from teuthology.config import config
log = logging.getLogger(__name__)
+
def main():
parser = argparse.ArgumentParser(description="""
Run a suite of ceph integration tests.
from cStringIO import StringIO
import random
import time
-import re
import gevent
import json
import threading
import sys
import logging
-import contextlib
from teuthology import run_tasks
from teuthology import parallel
-from ..orchestra import run
log = logging.getLogger(__name__)
+
def task(ctx, config):
"""
Run a group of tasks in parallel.
Sequential task and Parallel tasks can be nested.
"""
-
+
log.info('starting parallel...')
with parallel.parallel() as p:
for entry in config:
# grep '^ *# TESTCASE' | sed 's/^ *# TESTCASE //'
#
-import contextlib
import copy
import json
import logging
import teuthology.task_util.rgw as rgw_utils
from teuthology import misc as teuthology
-from teuthology import contextutil
from teuthology.task_util.rgw import rgwadmin
log = logging.getLogger(__name__)
+
def successful_ops(out):
summary = out['summary']
if len(summary) == 0:
import sys
import logging
-import contextlib
from teuthology import run_tasks
-from ..orchestra import run
log = logging.getLogger(__name__)
+
def task(ctx, config):
"""
Sequentialize a group of tasks into one executable block
import logging
import time
-from teuthology import misc as teuthology
-from ..orchestra import run
-
log = logging.getLogger(__name__)
+
def task(ctx, config):
"""
Sleep for some number of seconds.
import contextlib
import time
-from ..orchestra import run
-
log = logging.getLogger(__name__)
@contextlib.contextmanager
sequential task options.
example:
-
+
tasks:
- sequential:
- tasktest:
"""
try:
delay = config.get('delay', 0)
- id = config.get('id', 'UNKNOWN')
+ id = config.get('id', 'UNKNOWN')
except AttributeError:
delay = 0
id = 'UNKNOWN'
import proc_thrasher
from ..orchestra import run
-from teuthology import misc as teuthology
log = logging.getLogger(__name__)
+
@contextlib.contextmanager
def task(ctx, config):
"""