Skip to content
This repository has been archived by the owner on Mar 15, 2018. It is now read-only.

Commit

Permalink
Accept arbitrary keywords from celery like task_name=
Browse files Browse the repository at this point in the history
  • Loading branch information
kumar303 committed Jan 9, 2012
1 parent 5001e8d commit 3d4cc7b
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions apps/stats/tasks.py
Expand Up @@ -189,7 +189,7 @@ def _get_metrics_jobs(date=None):


@task
def index_update_counts(ids):
def index_update_counts(ids, **kw):
es = elasticutils.get_es()
qs = list(UpdateCount.objects.filter(id__in=ids))
if qs:
Expand All @@ -206,7 +206,7 @@ def index_update_counts(ids):


@task
def index_download_counts(ids):
def index_download_counts(ids, **kw):
es = elasticutils.get_es()
qs = DownloadCount.objects.filter(id__in=ids)
if qs:
Expand Down

0 comments on commit 3d4cc7b

Please sign in to comment.