Changeset View
Changeset View
Standalone View
Standalone View
test/functional/test_runner.py
Show First 20 Lines • Show All 430 Lines • ▼ Show 20 Lines | def handle_update_messages(): | ||||
# We printed a status message, need to kick to the next line | # We printed a status message, need to kick to the next line | ||||
# before printing more. | # before printing more. | ||||
if printed_status: | if printed_status: | ||||
print() | print() | ||||
printed_status = False | printed_status = False | ||||
handle_message(message, running_jobs) | handle_message(message, running_jobs) | ||||
update_queue.task_done() | update_queue.task_done() | ||||
except Empty as e: | except Empty: | ||||
if not on_ci(): | if not on_ci(): | ||||
print("Running jobs: {}".format(", ".join([j[1] for j in running_jobs])), end="\r") | print("Running jobs: {}".format(", ".join([j[1] for j in running_jobs])), end="\r") | ||||
sys.stdout.flush() | sys.stdout.flush() | ||||
printed_status = True | printed_status = True | ||||
def handle_test_cases(): | def handle_test_cases(): | ||||
""" | """ | ||||
job_runner represents a single thread that is part of a worker pool. | job_runner represents a single thread that is part of a worker pool. | ||||
▲ Show 20 Lines • Show All 303 Lines • Show Last 20 Lines |