The elastic_recheck.elasticRecheck Module

class elastic_recheck.elasticRecheck.Classifier(queries_dir, config=None)

Bases: object

Classify failed tempest-devstack jobs based.

Given a change and revision, query logstash with a list of known queries that are mapped to specific bugs.

classify(change_number, patch_number, build_short_uuid, recent=False)

Returns either empty list or list with matched bugs.

hits_by_query(query, queue=None, facet=None, size=100, days=0)

log = <logging.Logger object at 0x7fdf1209bdd0>

most_recent()

Return the datetime of the most recently indexed event.

queries = None

exception elastic_recheck.elasticRecheck.ConsoleNotReady

Bases: exceptions.Exception

class elastic_recheck.elasticRecheck.FailEvent(event, failed_jobs, config=None)

Bases: object

A FailEvent consists of one or more FailJobs.

An event is a gerrit event.

bug_list()

A pretty printed bug list.

bug_urls(bugs=None)

bug_urls_map()

Produce sorted list of which jobs failed due to which bugs.

build_short_uuids()

change = None

comment = None

failed_job_names()

failed_jobs = []

get_all_bugs()

is_fully_classified()

is_included_job()

name()

project = None

queue()

rev = None

url = None

class elastic_recheck.elasticRecheck.FailJob(name, url)

Bases: object

A single failed job.

A job is a zuul job.

bugs = []

build_short_uuid = None

name = None

url = None

exception elastic_recheck.elasticRecheck.FilesNotReady

Bases: exceptions.Exception

exception elastic_recheck.elasticRecheck.ResultTimedOut

Bases: exceptions.Exception

class elastic_recheck.elasticRecheck.Stream(user, host, key, config=None, thread=True)

Bases: object

Gerrit Stream.

Monitors gerrit stream looking for tempest-devstack failures.

get_failed_tempest()

leave_comment(event, msgs, debug=False)

log = <logging.Logger object at 0x7fdf1209bdd0>

static parse_jenkins_failure(event, ci_username='jenkins')

Is this comment a jenkins failure comment.

elastic_recheck.elasticRecheck.check_failed_test_ids_for_job(build_uuid, test_ids, session)

elastic_recheck.elasticRecheck.format_timedelta(td)

Format a timedelta value on seconds boundary.

elastic_recheck.elasticRecheck.required_files(job)