# Path: teuthology/config.py
# def init_logging():
#     def __init__(self, yaml_path=None):
#     def load(self, conf=None):
#     def update(self, in_dict):
#     def from_dict(cls, in_dict):
#     def to_dict(self):
#     def from_str(cls, in_str):
#     def to_str(self):
#     def get(self, key, default=None):
#     def __str__(self):
#     def __repr__(self):
#     def __getitem__(self, name):
#     def __getattr__(self, name):
#     def __contains__(self, name):
#     def __setattr__(self, name, value):
#     def __delattr__(self, name):
#     def __len__(self):
#     def __iter__(self):
#     def __setitem__(self, name, value):
#     def __delitem__(self, name):
#     def __init__(self, yaml_path=None):
#     def get_ceph_cm_ansible_git_url(self):
#     def get_ceph_qa_suite_git_url(self):
#     def get_ceph_git_url(self):
#     def __init__(self, config_dict=None):
#     def _clean_config(self, config_dict):
#     def __getattr__(self, name):
#     def __setattr__(self, name, value):
#     def __repr__(self):
#     def __str__(self):
# def set_config_attr(obj):
# def _get_config_path():
# class YamlConfig(collections.MutableMapping):
# class TeuthologyConfig(YamlConfig):
# class JobConfig(YamlConfig):
# class FakeNamespace(YamlConfig):
# 
# Path: teuthology/report.py
# def init_logging():
# def main(args):
#     def __init__(self, archive_base, log=None):
#     def job_info(self, run_name, job_id, pretty=False, simple=False):
#     def json_for_job(self, run_name, job_id, pretty=False):
#     def jobs_for_run(self, run_name):
#     def running_jobs_for_run(self, run_name):
#     def all_runs(self):
#     def __init__(self, archive_base=None, base_uri=None, save=False,
#                  refresh=False, log=None):
#     def _make_session(self, max_retries=10):
#     def report_all_runs(self):
#     def report_runs(self, run_names):
#     def report_run(self, run_name, dead=False):
#     def report_jobs(self, run_name, job_ids, dead=False):
#     def report_job(self, run_name, job_id, job_info=None, dead=False):
#     def last_run(self):
#     def last_run(self, run_name):
#     def last_run(self):
#     def get_jobs(self, run_name, job_id=None, fields=None):
#     def get_run(self, run_name, fields=None):
#     def _parse_log_line(self, line, prefix):
#     def get_rerun_conf(self, run_name):
#     def delete_job(self, run_name, job_id):
#     def delete_jobs(self, run_name, job_ids):
#     def delete_run(self, run_name):
# def push_job_info(run_name, job_id, job_info, base_uri=None):
# def try_push_job_info(job_config, extra_info=None):
# def try_delete_jobs(run_name, job_ids, delete_empty_run=True):
#     def try_delete_job(job_id):
# def try_mark_run_dead(run_name):
# class ResultsSerializer(object):
# class ResultsReporter(object):


import beanstalkc
import yaml
import logging
import pprint
import sys
from collections import OrderedDict
from teuthology.config import config
from teuthology import report


log = logging.getLogger(__name__)


def connect():
    host = config.queue_host

# Path: teuthology/config.py
# def init_logging():
#     def __init__(self, yaml_path=None):
#     def load(self, conf=None):
#     def update(self, in_dict):
#     def from_dict(cls, in_dict):
#     def to_dict(self):
#     def from_str(cls, in_str):
#     def to_str(self):
#     def get(self, key, default=None):
#     def __str__(self):
#     def __repr__(self):
#     def __getitem__(self, name):
#     def __getattr__(self, name):
#     def __contains__(self, name):
#     def __setattr__(self, name, value):
#     def __delattr__(self, name):
#     def __len__(self):
#     def __iter__(self):
#     def __setitem__(self, name, value):
#     def __delitem__(self, name):
#     def __init__(self, yaml_path=None):
#     def get_ceph_cm_ansible_git_url(self):
#     def get_ceph_qa_suite_git_url(self):
#     def get_ceph_git_url(self):
#     def __init__(self, config_dict=None):
#     def _clean_config(self, config_dict):
#     def __getattr__(self, name):
#     def __setattr__(self, name, value):
#     def __repr__(self):
#     def __str__(self):
# def set_config_attr(obj):
# def _get_config_path():
# class YamlConfig(collections.MutableMapping):
# class TeuthologyConfig(YamlConfig):
# class JobConfig(YamlConfig):
# class FakeNamespace(YamlConfig):
# 
# Path: teuthology/report.py
# def init_logging():
# def main(args):
#     def __init__(self, archive_base, log=None):
#     def job_info(self, run_name, job_id, pretty=False, simple=False):
#     def json_for_job(self, run_name, job_id, pretty=False):
#     def jobs_for_run(self, run_name):
#     def running_jobs_for_run(self, run_name):
#     def all_runs(self):
#     def __init__(self, archive_base=None, base_uri=None, save=False,
#                  refresh=False, log=None):
#     def _make_session(self, max_retries=10):
#     def report_all_runs(self):
#     def report_runs(self, run_names):
#     def report_run(self, run_name, dead=False):
#     def report_jobs(self, run_name, job_ids, dead=False):
#     def report_job(self, run_name, job_id, job_info=None, dead=False):
#     def last_run(self):
#     def last_run(self, run_name):
#     def last_run(self):
#     def get_jobs(self, run_name, job_id=None, fields=None):
#     def get_run(self, run_name, fields=None):
#     def _parse_log_line(self, line, prefix):
#     def get_rerun_conf(self, run_name):
#     def delete_job(self, run_name, job_id):
#     def delete_jobs(self, run_name, job_ids):
#     def delete_run(self, run_name):
# def push_job_info(run_name, job_id, job_info, base_uri=None):
# def try_push_job_info(job_config, extra_info=None):
# def try_delete_jobs(run_name, job_ids, delete_empty_run=True):
#     def try_delete_job(job_id):
# def try_mark_run_dead(run_name):
# class ResultsSerializer(object):
# class ResultsReporter(object):


# Path: teuthology/beanstalk.py
import beanstalkc
import yaml
import logging
import pprint
import sys
from collections import OrderedDict
from teuthology.config import config
from teuthology import report



log = logging.getLogger(__name__)


def connect():
    host = config.queue_host

    port = config.queue_port