Skip to content

Instantly share code, notes, and snippets.

@jpic
Created September 8, 2011 09:28
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save jpic/1203016 to your computer and use it in GitHub Desktop.
Save jpic/1203016 to your computer and use it in GitHub Desktop.
@task(ignore_result=True)
def lineup_popover_render_and_cache_all():
for id in Lineup.objects.values_list('id', flat=True):
lineup_popover_render_and_cache.delay(id)
@task(ignore_result=True)
def lineup_popover_render_and_cache(lineup_id):
lineup = Lineup.objects.get(pk=lineup_id)
# blablabla
task(ignore_result=True)
def refresh_homepage_data():
homepage_data = {
'city_list': [],
'country_list': [],
#blablabla
[2011-09-07 17:54:12,574: INFO/MainProcess] Task fest.update_index[700ca060-a805-4ce4-82cb-c64b3eeec8c4] succeeded in 0.148859977722s: None
[2011-09-07 17:54:12,638: INFO/MainProcess] Got task from broker: fest.lineup_popover_render_and_cache[5b1290a1-f5b2-4fdb-807a-4df25c185f8b]
[2011-09-07 17:54:12,647: INFO/MainProcess] Got task from broker: fest.lineup_popover_render_and_cache[7c30a4a7-5658-47ec-90a5-89db97577c7d]
[2011-09-07 17:54:12,648: INFO/MainProcess] Task fest.lineup_popover_render_and_cache[5b1290a1-f5b2-4fdb-807a-4df25c185f8b] succeeded in 0.00844693183899s: None
[2011-09-07 17:54:12,663: INFO/MainProcess] Task fest.lineup_popover_render_and_cache[7c30a4a7-5658-47ec-90a5-89db97577c7d] succeeded in 0.00787591934204s: None
[2011-09-08 00:00:00,198: ERROR/MainProcess] Unknown task ignored: Task of kind 'tasks.lineup_popover_render_and_cache_all' is not registered, please make sure it's imported. Body->"{'retries': 0, 'task': 'tasks.lineup_popover_render_and_cache_all', 'args': [], 'expires': None, 'eta': None, 'kwargs': {}, 'id': 'ca6e9f7f-8b7c-45bb-85a0-164d9d8ddfb7'}"
Traceback (most recent call last):
File "/home/srv/festicket.com/fk_env/lib/python2.7/site-packages/celery/worker/consumer.py", line 368, in receive_message
eventer=self.event_dispatcher)
File "/home/srv/festicket.com/fk_env/lib/python2.7/site-packages/celery/worker/job.py", line 306, in from_message
**kw)
File "/home/srv/festicket.com/fk_env/lib/python2.7/site-packages/celery/worker/job.py", line 275, in __init__
self.task = tasks[self.task_name]
File "/home/srv/festicket.com/fk_env/lib/python2.7/site-packages/celery/registry.py", line 59, in __getitem__
raise self.NotRegistered(key)
NotRegistered: 'tasks.lineup_popover_render_and_cache_all'
[2011-09-08 00:00:00,209: ERROR/MainProcess] Unknown task ignored: Task of kind 'refresh_homepage_data' is not registered, please make sure it's imported. Body->"{'retries': 0, 'task': 'refresh_homepage_data', 'args': [], 'expires': None, 'eta': None, 'kwargs': {}, 'id': 'b47b6da3-4afe-4400-a013-4b1e2b3c262d'}"
Traceback (most recent call last):
File "/home/srv/festicket.com/fk_env/lib/python2.7/site-packages/celery/worker/consumer.py", line 368, in receive_message
eventer=self.event_dispatcher)
File "/home/srv/festicket.com/fk_env/lib/python2.7/site-packages/celery/worker/job.py", line 306, in from_message
**kw)
File "/home/srv/festicket.com/fk_env/lib/python2.7/site-packages/celery/worker/job.py", line 275, in __init__
self.task = tasks[self.task_name]
File "/home/srv/festicket.com/fk_env/lib/python2.7/site-packages/celery/registry.py", line 59, in __getitem__
raise self.NotRegistered(key)
NotRegistered: 'refresh_homepage_data'
[2011-09-08 04:00:00,117: INFO/MainProcess] Got task from broker: celery.backend_cleanup[5fefabc3-8e85-414d-b321-0b1b5dc386be] expires:[2011-09-08 16:00:00.100555]
[2011-09-08 04:00:00,182: INFO/MainProcess] Task celery.backend_cleanup[5fefabc3-8e85-414d-b321-0b1b5dc386be] succeeded in 0.0160229206085s: None
BROKER_BACKEND = "djkombu.transport.DatabaseTransport"
from datetime import timedelta
CELERYBEAT_SCHEDULE = {
"lineup_popover": {
"task": "tasks.lineup_popover_render_and_cache_all",
"schedule": timedelta(seconds=24),
},
"refresh_homepage_data": {
"task": "refresh_homepage_data",
"schedule": timedelta(hours=24),
},
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment