improve_location_with_search.py 文件源码

def async_determine_rd_coordinates():
    """
    Worker task which gets
    search parameters of the queue
    and executes a SearchTask
    """

    while not SEARCHES_QUEUE.empty():
        args = SEARCHES_QUEUE.get()
        task = SearchTask(*args)
        try:
            task.determine_rd_coordinates()
        except Exception as exp:
            # when tasks fails.. continue..
            log.error('\n\n\n')
            log.error(exp)
            log.error('\n\n\n')