193
193
"propagating the result immediately")),
194
194
log.InfoCode.asynchronous_upload_done)
199
200
def wait_for_and_register_launch():
200
201
check_pending_failure() # raise on fail
201
202
while self.__worker_count >= self.__concurrency or self.__barrier:
202
203
if self.__worker_count == 0: