Class-based task

gistfile1.py

class BaseEnrich(object):
    def __init__(self):
        self.guesser = Guesser()

@task(ignore_result=True, base=BaseEnrich)
def enrich(self, data):
    data['guess'] = self.guesser.guess('text')
    return data

@task(ignore_result=True)
def enrich_and_save(tweet_json):
    c = enrich.s(data) | group(persist.s(), index.s())
    c.apply_async()