fake_slurm = None
compute_nodes = None
all_jobs = None
-unsatisfiable_job_scancelled = os.path.join(tempfile.mkdtemp(), "scancel_called")
+unsatisfiable_job_scancelled = None
def update_script(path, val):
with open(path+"_", "w") as f:
def run_test(name, actions, checks, driver_class, jobs, provider):
code = 0
+ global unsatisfiable_job_scancelled
+ unsatisfiable_job_scancelled = os.path.join(tempfile.mkdtemp(),
+ "scancel_called")
# Delete any stale node records
api = arvados.api('v1')
[
(r".*Daemon started", set_squeue),
(r".*Rate limit exceeded - scheduling retry in 12 seconds", noop),
+ (r".*Rate limit exceeded - scheduling retry in 2 seconds", noop),
(r".*Cloud node (\S+) is now paired with Arvados node (\S+) with hostname (\S+)", noop),
],
{},