Mentions légales du service

Skip to content
Snippets Groups Projects

Resolve "Soiled dirty mud -> procset"

Merged MOMMESSIN Clement requested to merge 4-procest-rules into master
8 files
+ 49
72
Compare changes
  • Side-by-side
  • Inline
Files
8
+ 1
34
@@ -120,27 +120,7 @@ class Batsim(object):
@@ -120,27 +120,7 @@ class Batsim(object):
}
}
})
})
def start_jobs_continuous(self, allocs):
''' THIS FUNCTION IS DEPRECATED '''
"""
allocs should have the following format:
[ (job, (first res, last res)), (job, (first res, last res)), ...]
"""
if len(allocs) == 0:
return
for (job, (first_res, last_res)) in allocs:
self._events_to_send.append({
"timestamp": self.time(),
"type": "EXECUTE_JOB",
"data": {
"job_id": job.id,
"alloc": "{}-{}".format(first_res, last_res)
}
}
)
self.nb_jobs_scheduled += 1
def start_jobs(self, jobs, res):
def start_jobs(self, jobs, res):
""" args:res: is list of int (resources ids) """
""" args:res: is list of int (resources ids) """
for job in jobs:
for job in jobs:
@@ -280,19 +260,6 @@ class Batsim(object):
@@ -280,19 +260,6 @@ class Batsim(object):
}
}
})
})
def start_jobs_interval_set_strings(self, jobs, res):
""" args:res: is a jobID:interval_set_string dict """
for job in jobs:
self._events_to_send.append({
"timestamp": self.time(),
"type": "EXECUTE_JOB",
"data": {
"job_id": job.id,
"alloc": res[job.id]
}
}
)
self.nb_jobs_scheduled += 1
def get_job(self, event):
def get_job(self, event):
if self.redis_enabled:
if self.redis_enabled:
Loading