Update eve_proxy taks for Django 1.4

This commit is contained in:
2012-05-20 12:21:10 +01:00
parent 605a063e80
commit 27abcf8661

View File

@@ -1,16 +1,19 @@
from django.conf import settings
import logging import logging
from datetime import datetime, timedelta from datetime import datetime, timedelta
from django.conf import settings
from django.utils.timezone import now
from celery.task import task from celery.task import task
from eve_proxy.models import CachedDocument, ApiAccessLog from eve_proxy.models import CachedDocument, ApiAccessLog
@task(ignore_result=True) @task(ignore_result=True)
def clear_stale_cache(cache_extension=0): def clear_stale_cache(cache_extension=0):
log = clear_stale_cache.get_logger() log = clear_stale_cache.get_logger()
time = datetime.utcnow() - timedelta(seconds=cache_extension) time = now() - timedelta(seconds=cache_extension)
objs = CachedDocument.objects.filter(cached_until__lt=time) objs = CachedDocument.objects.filter(cached_until__lt=time)
log.info('Removing %s stale cache documents' % objs.count()) log.info('Removing %s stale cache documents' % objs.count())
objs.delete() objs.delete()
@@ -20,7 +23,7 @@ def clear_stale_cache(cache_extension=0):
def clear_old_logs(): def clear_old_logs():
log = clear_old_logs.get_logger() log = clear_old_logs.get_logger()
time = datetime.utcnow() - timedelta(days=settings.EVE_PROXY_KEEP_LOGS) time = now() - timedelta(days=getattr(settings, 'EVE_PROXY_KEEP_LOGS', 30))
objs = ApiAccessLog.objects.filter(time_access__lt=time) objs = ApiAccessLog.objects.filter(time_access__lt=time)
log.info('Removing %s old access logs' % objs.count()) log.info('Removing %s old access logs' % objs.count())
objs.delete() objs.delete()