Skip to content
Snippets Groups Projects
Commit b28f71da authored by Ada Böhm's avatar Ada Böhm
Browse files

FIX: Reconnect test fixed

parent bff925b6
No related branches found
No related tags found
No related merge requests found
...@@ -135,11 +135,13 @@ class LoomEnv(Env): ...@@ -135,11 +135,13 @@ class LoomEnv(Env):
self.check_stats() self.check_stats()
return self._client return self._client
def submit(self, results, report=None): def submit(self, results, report=None, check_timeout=None):
if report: if report:
report = os.path.join(LOOM_TEST_BUILD_DIR, report) report = os.path.join(LOOM_TEST_BUILD_DIR, report)
result = self.client.submit(results, report) result = self.client.submit(results, report)
self.check_stats() self.check_stats()
if check_timeout:
time.sleep(check_timeout)
self.check_final_state() self.check_final_state()
return result return result
......
...@@ -57,7 +57,7 @@ print(client.submit((a, b, c, d))) ...@@ -57,7 +57,7 @@ print(client.submit((a, b, c, d)))
b = tasks.const("xyz") b = tasks.const("xyz")
c = tasks.const("123") c = tasks.const("123")
d = tasks.merge((a, b, c)) d = tasks.merge((a, b, c))
result = loom_env.submit(d) result = loom_env.submit(d, check_timeout=0.9)
assert result == b"abcxyz123" assert result == b"abcxyz123"
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment