test.py

import settings, sys
import time
from amcat.tasks import do_scrape, FakeScraper
from celery.result import AsyncResult

res = do_scrape.delay(FakeScraper, 3)

while True:
    if not res.ready():
        time.sleep(.2)
        sys.stdout.write("."); sys.stdout.flush()
        continue
    r = res.get()
    if isinstance(r, AsyncResult):
        print "Intermediate result.... waiting for next phase"
        res = r
    else:
        break

print "\n---->", type(r), `r`, r