Skip to content

Commit d6afc2a

Browse files
committed
remove sleep (#2831)
* remove sleep * remove sleep (local platform) * fix test (cherry picked from commit e7534d8)
1 parent 6605a3d commit d6afc2a

File tree

2 files changed

+1
-3
lines changed

2 files changed

+1
-3
lines changed

autosubmit/platforms/paramiko_platform.py

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -839,7 +839,6 @@ def check_job(self, job, default_status=Status.COMPLETED, retries=5, submit_hold
839839
f'check_job() The job id ({job_id}) is not an integer neither a string.')
840840
job.new_status = job_status
841841
sleep_time = 5
842-
sleep(2)
843842
self.send_command(self.get_check_job_cmd(job_id))
844843
while self.get_ssh_output().strip(" ") == "" and retries > 0:
845844
retries = retries - 1
@@ -957,7 +956,6 @@ def check_all_jobs(self, job_list: list[list['Job']], as_conf, retries=5):
957956
job_list_cmd = self.parse_job_list(job_list)
958957
cmd = self.get_check_all_jobs_cmd(job_list_cmd)
959958
sleep_time = 5
960-
sleep(sleep_time)
961959
slurm_error = False
962960
e_msg = ""
963961
try:

test/integration/test_utils/misc.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,7 @@ def wait_locker(file_lock: Path, expect_locked: bool, timeout: int, interval=0.0
6868
if expect_locked:
6969
# Check if the file is locked by attempting to acquire it non-blocking
7070
try:
71-
with Lock(str(file_lock)):
71+
with Lock(str(file_lock), timeout=0):
7272
# Lock acquired, so it's NOT locked — keep waiting
7373
pass
7474
except AlreadyLocked:

0 commit comments

Comments
 (0)