Last use removed when 704b51ff5 removed _SubmitManyJobsUnlocked
Signed-off-by: Brian Foley <[email protected]>
---
lib/jqueue/__init__.py | 31 -------------------------------
1 file changed, 31 deletions(-)
diff --git a/lib/jqueue/__init__.py b/lib/jqueue/__init__.py
index a4c25ba..7b42e5e 100644
--- a/lib/jqueue/__init__.py
+++ b/lib/jqueue/__init__.py
@@ -1522,37 +1522,6 @@ class JobQueue(object):
"""
return luxi.Client(address=pathutils.QUERY_SOCKET).SubmitManyJobs(jobs)
- @staticmethod
- def _ResolveJobDependencies(resolve_fn, deps):
- """Resolves relative job IDs in dependencies.
-
- @type resolve_fn: callable
- @param resolve_fn: Function to resolve a relative job ID
- @type deps: list
- @param deps: Dependencies
- @rtype: tuple; (boolean, string or list)
- @return: If successful (first tuple item), the returned list contains
- resolved job IDs along with the requested status; if not successful,
- the second element is an error message
-
- """
- result = []
-
- for (dep_job_id, dep_status) in deps:
- if ht.TRelativeJobId(dep_job_id):
- assert ht.TInt(dep_job_id) and dep_job_id < 0
- try:
- job_id = resolve_fn(dep_job_id)
- except IndexError:
- # Abort
- return (False, "Unable to resolve relative job ID %s" % dep_job_id)
- else:
- job_id = dep_job_id
-
- result.append((job_id, dep_status))
-
- return (True, result)
-
def _GetJobStatusForDependencies(self, job_id):
"""Gets the status of a job for dependencies.
--
2.8.0.rc3.226.g39d4020
