Timed out. search by Google
/usr/local/lib/python3.7/unittest/case.py in testPartExecutor (arguments ▶)
- @contextlib.contextmanager
- def testPartExecutor(self, test_case, isTest=False):
- old_success = self.success
- self.success = True
- try:
- yield
- except KeyboardInterrupt:
- raise
- except SkipTest as e:
- self.success = False
/usr/local/lib/python3.7/unittest/case.py in run (arguments ▶)
- with outcome.testPartExecutor(self):
- self.setUp()
- if outcome.success:
- outcome.expecting_failure = expecting_failure
- with outcome.testPartExecutor(self, isTest=True):
- testMethod()
- outcome.expecting_failure = False
- with outcome.testPartExecutor(self):
- self.tearDown()
/root/c2tests/.venv/lib/python3.7/site-packages/c2tests/vpc/acls.py in test_multi_acl_rules (arguments ▶)
- for i, rule in enumerate(rules):
- if i != excluded_rule:
- self.vpcconn.create_network_acl_entry(**rule)
- self.assertFalse(
- utils.ping_between_instances(instance0, instance1, public_ip=True))
- for i, rule in enumerate(rules):
- if i != excluded_rule:
- self.vpcconn.delete_network_acl_entry(
/root/c2tests/.venv/lib/python3.7/site-packages/c2tests/utils.py in ping_between_instances (arguments ▶)
- for instance in [first_instance[1], second_instance[1]]:
- instance.update()
- common.parallelize(check_ssh,
- [first_instance, second_instance],
- threads=2, check_errors=True)
- remote_args = "/bin/ping -c {0} -w {0} -q {1} > /dev/null; echo $?"
- target_ip = second_instance[1].ip_address if public_ip\
/root/c2tests/.venv/lib/python3.7/site-packages/c2tests/common.py in parallelize (arguments ▶)
- for thread in thread_pool:
- join_thread(thread)
- if check_errors:
- for result in results:
- if isinstance(result[1], Exception):
- raise result[1]
- results.sort(key=lambda result: result[0])
- return [result[1] for result in results]
/root/c2tests/.venv/lib/python3.7/site-packages/c2tests/common.py in worker (arguments ▶)
- task_id, element = q.get(False)
- except queue.Empty:
- break
- try:
- result = func(element)
- except Exception as e:
- if log_errors:
- logger.exception("Parallelize of %s for %s failed.", func, element)
- result = e
/root/c2tests/.venv/lib/python3.7/site-packages/c2tests/utils.py in check_ssh (arguments ▶)
- def check_ssh(instance):
- """Helper for parallel using of 'long_ssh_test'."""
- return long_ssh_test(*instance)
- RULES = [
- {
/root/c2tests/.venv/lib/python3.7/site-packages/c2tests/utils.py in long_ssh_test (arguments ▶)
- def long_ssh_test(keypath, instance):
- """Getting instance id frome metadata server w/retries"""
- wait_long(lambda: ssh_test(instance.ip_address, keypath) == instance.id)
- def check_ssh(instance):
- """Helper for parallel using of 'long_ssh_test'."""
/root/c2tests/.venv/lib/python3.7/site-packages/c2tests/utils.py in wait_long (arguments ▶)
- def wait_long(func, *args, **kwargs):
- """Fail unless func return success within the long timeout"""
- return wait(5 * constants.MINUTE_SECONDS, func, *args, **kwargs)
- def wait_long_enough(func, *args, **kwargs):
- """Fail unless func return success within the enough long timeout."""
/root/c2tests/.venv/lib/python3.7/site-packages/c2tests/utils.py in wait (arguments ▶)
- result = func(*args, **kwargs)
- if result:
- return result
- time.sleep(min(timeout, 0.1))
- raise exceptions.TimeoutException()
- def wait_short(func, *args, **kwargs):
- """Fail unless func return success within the timeout"""