Merge branch 'amqp-switch'

This commit is contained in:
Boris Bobrov
2017-06-10 01:25:24 +03:00
4 changed files with 12 additions and 6 deletions

View File

@@ -153,8 +153,7 @@ CELERY_RESULT_BACKEND = string(default="database")
CELERY_RESULT_DBURI = string(default="sqlite:///%(here)s/celery.db")
# default kombu stuff
BROKER_TRANSPORT = string(default="sqlalchemy")
BROKER_URL = string(default="sqlite:///%(here)s/kombu.db")
BROKER_URL = string(default="amqp://")
# known booleans
CELERY_RESULT_PERSISTENT = boolean()

View File

@@ -69,6 +69,9 @@ class ProcessMedia(celery.Task):
"""
Pass this entry off for processing.
"""
name = 'process_media'
def run(self, media_id, feed_url, reprocess_action, reprocess_info=None):
"""
Pass the media entry off to the appropriate processing function