Get async celery results from subtasks

get_results.py

from tasks import task1

from celery.task import TaskSet
from celery.result import AsyncResult, ResultSet 


def get_results(queries):
    query_procs = task1.delay(queries).get().join()

    results = []
    for query_proc in query_procs:
        results.extend(query_proc.join())
    return results

get_results(['a','b','c'])

tasks.py

from celery.task import task, TaskSet

@task
def task1(queries):
    return TaskSet(task2.subtask((query, )) for query in queries).apply_async()
     
@task
def task2(query):
   return TaskSet(task3.subtask() for _ in xrange(20).apply_async()

@task
def task3()
    time.sleep(2)
    return 'done'