Accept arbitrary keywords from celery like task_name=

This commit is contained in:
Kumar McMillan 2012-01-09 15:11:30 -06:00
Родитель 5001e8d744
Коммит 3d4cc7b58f
1 изменённых файлов: 2 добавлений и 2 удалений

Просмотреть файл

@ -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:
@ -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: