nikdoof/test-auth
1
0
Fork 0
mirror of https://github.com/nikdoof/test-auth.git synced 2025-12-14 14:52:15 +00:00
Code Issues Packages Projects Releases Wiki Activity

Remove returning results from import_eveapi, as this is causing excess stored results on RabbitMQ

Browse Source
This commit is contained in:
Andrew Williams
2010-12-01 09:29:00 +00:00
parent 047954e8fe
commit cab224c224
2 changed files with 5 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
eve_api/tasks.py
View File

@@ -28,7 +28,7 @@ def queue_apikey_updates(update_delay=86400, batch_size=50):
import_apikey.delay(api_key=acc.api_key, api_userid=acc.api_user_id) import_apikey.delay(api_key=acc.api_key, api_userid=acc.api_user_id)
@task() @task(ignore_result=True)
def import_apikey(api_userid, api_key, user=None, force_cache=False): def import_apikey(api_userid, api_key, user=None, force_cache=False):
log = import_apikey.get_logger('import_apikey') log = import_apikey.get_logger('import_apikey')
@@ -59,8 +59,6 @@ def import_apikey(api_userid, api_key, user=None, force_cache=False):
if acc.user: if acc.user:
update_user_access.delay(user=acc.user.id) update_user_access.delay(user=acc.user.id)
return acc
@task(ignore_result=True) @task(ignore_result=True)
def import_alliance_details(): def import_alliance_details():

7
sso/views.py
View File

@@ -108,10 +108,11 @@ def eveapi_refresh(request, userid=0):
if request.is_ajax(): if request.is_ajax():
try: try:
acc = task.wait(30) task.wait(30)
return HttpResponse(serializers.serialize('json', [acc]), mimetype='application/javascript')
except celery.exceptions.TimeoutError: except celery.exceptions.TimeoutError:
return HttpResponse(serializers.serialize('json', []), mimetype='application/javascript') pass
acc = EVEAccount.objects.get(id=userid)
return HttpResponse(serializers.serialize('json', [acc]), mimetype='application/javascript')
else: else:
messages.add_message(request, messages.INFO,"Key %s has been queued to be refreshed from the API" % acc.api_user_id) messages.add_message(request, messages.INFO,"Key %s has been queued to be refreshed from the API" % acc.api_user_id)