// We filter out Nones defensively. There shouldn"t be any, but if a bug causes one,
// Pants might hang indefinitely without this filtering.
work_iter = iter(filter(None, work_chain))
def submit_next():
try:
self.submit_async_work(next(work_iter), workunit_parent=workunit_parent,
After Change
// We filter out Nones defensively. There shouldn"t be any, but if a bug causes one,
// Pants might hang indefinitely without this filtering.
work_iter = (_f for _f in work_chain if _f)
def submit_next():
try:
self.submit_async_work(next(work_iter), workunit_parent=workunit_parent,