Changeset View

Standalone View

Show First 20 Lines • Show All 445 Lines • ▼ Show 20 Lines	def handle_update_messages():
if not on_ci():		if not on_ci():
print("Running jobs: {}".format(		print("Running jobs: {}".format(
", ".join([j[1] for j in running_jobs])), end="\r")		", ".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.
It waits for a test, then executes that test.		It waits for a test, then executes that test.
It also reports start and result messages to handle_update_messages		It also reports start and result messages to handle_update_messages
"""		"""
while True:		while True:
test = job_queue.get()		test = job_queue.get()
if test is None:		if test is None:
break		break
# Signal that the test is starting to inform the poor waiting		# Signal that the test is starting to inform the poor waiting
# programmer		# programmer
▲ Show 20 Lines • Show All 306 Lines • Show Last 20 Lines