Skip to content

Commit 1ea5fa7

Browse files
committed
Fixed formatting
1 parent ce312c3 commit 1ea5fa7

1 file changed

Lines changed: 13 additions & 8 deletions

File tree

oar/lib/job_handling.py

Lines changed: 13 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -132,19 +132,24 @@ def get_waiting_jobs(session, queues, reservation="None"):
132132
jid = int(j.id)
133133

134134
juser = j.user
135-
if juser in user_jobs :
136-
user_jobs[juser] += 1
135+
if juser in user_jobs:
136+
user_jobs[juser] += 1
137137
else:
138-
user_jobs[juser] = 1
138+
user_jobs[juser] = 1
139139

140140
# TODO: get this value from config[SCHEDULER_FAIRSHARING_MAX_JOB_PER_USER]
141141
max_jobs_per_user = 5
142-
if user_jobs[juser] >= max_jobs_per_user :
143-
logger.info("Skipping "+ str(jid) + " as max jobs per user limit is reached for "+ juser)
142+
if user_jobs[juser] >= max_jobs_per_user:
143+
logger.info(
144+
"Skipping "
145+
+ str(jid)
146+
+ " as max jobs per user limit is reached for "
147+
+ juser
148+
)
144149
else:
145-
waiting_jobs[jid] = j
146-
waiting_jids.append(jid)
147-
nb_waiting_jobs += 1
150+
waiting_jobs[jid] = j
151+
waiting_jids.append(jid)
152+
nb_waiting_jobs += 1
148153

149154
return (waiting_jobs, waiting_jids, nb_waiting_jobs)
150155

0 commit comments

Comments
 (0)