X-Git-Url: https://git.decadent.org.uk/gitweb/?a=blobdiff_plain;f=daklib%2Fdbconn.py;h=fab0870e9d1e1a9b8e10d271826fa3a9c77d48d5;hb=1e532dabcf16f870f9815bf9a38a6a7077c79233;hp=65e1410444e16811de335ec25e24ad74434af39a;hpb=581734fc02c573df78d044fa8c68b18fa8c96397;p=dak.git

diff --git a/daklib/dbconn.py b/daklib/dbconn.py
index 65e14104..fab0870e 100755
--- a/daklib/dbconn.py
+++ b/daklib/dbconn.py
@@ -1917,6 +1917,31 @@ def get_policy_queue(queuename, session=None):
 
 __all__.append('get_policy_queue')
 
+@session_wrapper
+def get_policy_queue_from_path(pathname, session=None):
+    """
+    Returns PolicyQueue object for given C{path name}
+
+    @type queuename: string
+    @param queuename: The path
+
+    @type session: Session
+    @param session: Optional SQLA session object (a temporary one will be
+    generated if not supplied)
+
+    @rtype: PolicyQueue
+    @return: PolicyQueue object for the given queue
+    """
+
+    q = session.query(PolicyQueue).filter_by(path=pathname)
+
+    try:
+        return q.one()
+    except NoResultFound:
+        return None
+
+__all__.append('get_policy_queue_from_path')
+
 ################################################################################
 
 class Priority(object):