aboutsummaryrefslogtreecommitdiffstats
path: root/mediagoblin/plugins/api
diff options
context:
space:
mode:
authorSebastian Spaeth <Sebastian@SSpaeth.de>2013-01-15 14:41:30 +0100
committerSebastian Spaeth <Sebastian@SSpaeth.de>2013-01-15 14:53:08 +0100
commit2cfffd5ed8c054bb60c27ede4e69667f97d12b09 (patch)
treee5d699c123410a578feebd6f314405530a88da96 /mediagoblin/plugins/api
parent65969d3fb799765854ac5f57f85842c6ab523b21 (diff)
downloadmediagoblin-2cfffd5ed8c054bb60c27ede4e69667f97d12b09.tar.lz
mediagoblin-2cfffd5ed8c054bb60c27ede4e69667f97d12b09.tar.xz
mediagoblin-2cfffd5ed8c054bb60c27ede4e69667f97d12b09.zip
Make PuSHing the Pubhubsubbub server an async task (#436, #585)
Notifying the PuSH servers had 3 problems.  1) it was done immediately after sending of the processing task to celery. So if celery was run in a separate process we would notify the PuSH servers before the new media was processed/ visible. (#436) 2) Notification code was called in submit/views.py, so submitting via the API never resulted in notifications. (#585) 3) If Notifying the PuSH server failed, we would never retry. The solution was to make the PuSH notification an asynchronous subtask. This way: 1) it will only be called once async processing has finished, 2) it is in the main processing code path, so even API calls will result in notifications, and 3) We retry 3 times in case of failure before giving up. If the server is in a separate process, we will wait 3x 2 minutes before retrying the notification. The only downside is that the celery server needs to have access to the internet to ping the PuSH server. If that is a problem, we need to make the task belong to a special group of celery servers that has access to the internet. As a side effect, I believe I removed the limitation that prevented us from upgrading celery. Signed-off-by: Sebastian Spaeth <Sebastian@SSpaeth.de>
Diffstat (limited to 'mediagoblin/plugins/api')
-rw-r--r--mediagoblin/plugins/api/views.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/mediagoblin/plugins/api/views.py b/mediagoblin/plugins/api/views.py
index 6aa4ef9f..7383e20d 100644
--- a/mediagoblin/plugins/api/views.py
+++ b/mediagoblin/plugins/api/views.py
@@ -86,7 +86,7 @@ def post_entry(request):
#
# (... don't change entry after this point to avoid race
# conditions with changes to the document via processing code)
- run_process_media(entry)
+ run_process_media(entry, request)
return json_response(get_entry_serializable(entry, request.urlgen))