def fetch_process(job, key):
    """ complete fetch requests in parallel for fetch_handler 
        job:
            job queue containing (callable, kwargs)
        key:
            multiprocessing lock (database access key)
    """
    while not job.empty():
        req = job.get()
        if not req[0](lock=key, **req[1]):
            pass
    return
