Changeset View

Standalone View

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