dlemphers

try:
    self.config.readfp(open(config_file_path))
except IOError as (errno, strerror):
    logging.warning('I/O error({0}): {1}'.format(errno, strerror))
    logging.warning('Please check that {0} exists'.format(config_file_path))

lrvick

from tasks import task1

def get_results(queries):
    query_procs = task1.delay(queries).get().join()
    results = []
    for query_proc in query_procs:
        # while the following iterate() is happening, the other query_procs are ignored.
        # ideas on iterating over all of them at once?
        for result in query_proc.iterate(): 
            yield result