Did I find the right examples for you? yes no

All Samples(10)  |  Call(8)  |  Derive(0)  |  Import(2)

src/g/a/gaffer-0.5.2/gaffer/lookupd/registry.py   gaffer(Download)
 
from ..events import EventEmitter
from ..util import parse_job_name
 
 
    def add_job(self, job_name):
        sessionid, name = parse_job_name(job_name)
 
        if sessionid in self.sessions:
            session = self.sessions[sessionid]
    def remove_job(self, job_name):
        """ remove the job registered for this node """
        sessionid, name = parse_job_name(job_name)
        if sessionid not in self.sessions:
            return
    def get_job(self, job_name):
        sessionid, name = parse_job_name(job_name)
 
        try:
            session = self.sessions[sessionid]
    def find_job(self, job_name):
        """ find a job in the registry, return a list of all remote job
        possible for this ``sessionid.name`` """
        sessionid, name = parse_job_name(job_name)
        with self._lock:

src/g/a/gaffer-HEAD/gaffer/lookupd/registry.py   gaffer(Download)
 
from ..events import EventEmitter
from ..util import parse_job_name
 
 
    def add_job(self, job_name):
        sessionid, name = parse_job_name(job_name)
 
        if sessionid in self.sessions:
            session = self.sessions[sessionid]
    def remove_job(self, job_name):
        """ remove the job registered for this node """
        sessionid, name = parse_job_name(job_name)
        if sessionid not in self.sessions:
            return
    def get_job(self, job_name):
        sessionid, name = parse_job_name(job_name)
 
        try:
            session = self.sessions[sessionid]
    def find_job(self, job_name):
        """ find a job in the registry, return a list of all remote job
        possible for this ``sessionid.name`` """
        sessionid, name = parse_job_name(job_name)
        with self._lock: