delay(comment_id=comment.id, remote_addr=remote_addr) return HttpResponseRedirect(post.get_absolute_url()) else: form = CommentForm() 2.1. Tasks 19 Celery Documentation, Release 1.0.6 (stable) context update_page_info(url): page = fetch_page.delay(url).get() info = parse_page.delay(url, page).get() store_page_info.delay(url, info) @task() def fetch_page(url): return myhttplib.get(url) @task() def parse_page(url parse_page(url, page): return myparser.parse_document(page) @task() def store_page_info(url, info): return PageInfo.objects.create(url, info) Good: from functools import curry @task(ignore_result=True)

remote_addr=remote_addr) return HttpResponseRedirect(post.get_absolute_url()) else: form = CommentForm() context = RequestContext(request, {"form": form}) return update_page_info(url): page = fetch_page.delay(url).get() info = parse_page.delay(url, page).get() store_page_info.delay(url, info) @task() def fetch_page(url): return myhttplib.get(url) @task() @task() def parse_page(url, page): return myparser.parse_document(page) @task() def store_page_info(url, info): return PageInfo.objects.create(url, info) Good: from functools import curry @task(ignore_result=True)

update_page_info(url): page = fetch_page.delay(url).get() info = parse_page.delay(url, page).get() store_page_info.delay(url, info) @task def fetch_page(url): return myhttplib.get(url) @task def parse_page(url, page): store_page_info(url, info): return PageInfo.objects.create(url, info) Good: @task(ignore_result=True) def update_page_info(url): # fetch_page -> parse_page -> store_page fetch_page.delay(url, callback=subtask(parse_page Celery Documentation, Release 2.2.10 @task(ignore_result=True) def fetch_page(url, callback=None): page = myhttplib.get(url) if callback: # The callback may have been serialized with JSON, # so best practice

any additional dependencies or initial configuration, other than the URL location of the broker instance you want to use: >>> BROKER_URL = "amqp://guest:guest@localhost:5672//" For a description of broker set the transport, and configure the location of your Redis database: BROKER_URL = "redis://localhost:6379/0" Where the URL is in the format of: redis://userid:password@hostname:port/db_number Results connection string, but with ‘sqla+’ prepended to it: BROKER_URL = "sqla+sqlite:///celerydb.sqlite" This transport uses only the BROKER_URL setting, which have to be an SQLAlchemy database URI. Please

update_page_info(url): page = fetch_page.delay(url).get() info = parse_page.delay(url, page).get() store_page_info.delay(url, info) @task() def fetch_page(url): return myhttplib.get(url) @task() def parse_page(url parse_page(url, page): return myparser.parse_document(page) @task() def store_page_info(url, info): return PageInfo.objects.create(url, info) Good: @task(ignore_result=True) def update_page_info(url): # fetch_page.delay(url, callback=subtask(parse_page, callback=subtask(store_page_info))) 24 Chapter 2. User Guide Celery Documentation, Release 2.1.4 @task(ignore_result=True) def fetch_page(url, callback=None):

update_page_info(url): page = fetch_page.delay(url).get() info = parse_page.delay(url, page).get() store_page_info.delay(url, info) @task() def fetch_page(url): return myhttplib.get(url) @task() @task() def parse_page(url, page): return myparser.parse_document(page) @task() def store_page_info(url, info): return PageInfo.objects.create(url, info) Good: @task(ignore_result=True) def update_page_info(url): update_page_info(url): # fetch_page -> parse_page -> store_page fetch_page.delay(url, callback=subtask(parse_page, callback=subtask(store_page_info))) @task(ignore_result=True)

any additional dependencies or initial configuration, other than the URL location of the broker instance you want to use: >>> BROKER_URL = "amqp://guest:guest@localhost:5672//" For a description of broker set the transport, and configure the location of your Redis database: BROKER_URL = "redis://localhost:6379/0" Where the URL is in the format of: redis://userid:password@hostname:port/db_number Results Django DATABASE_* settings for database configuration values. 1. Set your broker transport: BROKER_URL = "django://" 2. Add djkombu to INSTALLED_APPS: INSTALLED_APPS = ("djkombu", ) 3. Verify your database

any additional dependencies or initial configuration, other than the URL location of the broker instance you want to use: >>> BROKER_URL = "amqp://guest:guest@localhost:5672//" For a description of broker set the transport, and configure the location of your Redis database: BROKER_URL = "redis://localhost:6379/0" Where the URL is in the format of: redis://userid:password@hostname:port/db_number Results Django DATABASE_* settings for database configuration values. 1. Set your broker transport: BROKER_URL = "django://" 2. Add djkombu to INSTALLED_APPS: INSTALLED_APPS = ("djkombu", ) 3. Verify your database

update_page_info(url): page = fetch_page.delay(url).get() info = parse_page.delay(url, page).get() store_page_info.delay(url, info) @task def fetch_page(url): return myhttplib.get(url) @task def parse_page(url, page): store_page_info(url, info): return PageInfo.objects.create(url, info) Good: @task(ignore_result=True) def update_page_info(url): # fetch_page -> parse_page -> store_page fetch_page.delay(url, callback=subtask(parse_page callback=subtask(store_page_info))) @task(ignore_result=True) def fetch_page(url, callback=None): page = myhttplib.get(url) if callback: # The callback may have been serialized with JSON, # so best practice

delay(comment_id=comment.id, remote_addr=remote_addr) return HttpResponseRedirect(post.get_absolute_url()) else: form = CommentForm() context = RequestContext(request, {"form": form}) return render_to_ update_page_info(url): page = fetch_page.delay(url).get() info = parse_page.delay(url, page).get() store_page_info.delay(url, info) @task() def fetch_page(url): return myhttplib.get(url) @task() def parse_page(url parse_page(url, page): return myparser.parse_document(page) @task() def store_page_info(url, info): return PageInfo.objects.create(url, info) Good: 20 Chapter 2. User Guide Celery Documentation, Release