introducing celeryconfig.py

requirements fix

celeryconfig.py

+CELERY_RESULT_BACKEND = 'amqp://'
+CELERY_TASK_RESULT_EXPIRES = 300
+CELERY_TIMEZONE = 'UTC'
+CELERY_ENABLE_UTC = True
+CELERY_ACCEPT_CONTENT = ['pickle', 'json', 'msgpack', 'yaml']
+

requirements/base.txt

-celery
-requests
-filemagic
+amqp==1.4.9
+anyjson==0.3.3
+billiard==3.3.0.23
+celery==3.1.18
+filemagic==1.6
+kombu==3.0.30
+pytz==2021.3
+requests==2.26.0
+

storagecelery.py

@@ -21,11 +21,13 @@ celery = Celery('storagedriver',
                 broker=AMQP_URI,
                 broker=AMQP_URI,
                 include=['storagedriver'])
                 include=['storagedriver'])
 
 
+celery.config_from_object('celeryconfig')
+
 celery.conf.update(
 celery.conf.update(
-    CELERY_RESULT_BACKEND='amqp://',
-    CELERY_TASK_RESULT_EXPIRES=30000,
     CELERY_QUEUES=(
     CELERY_QUEUES=(
         Queue(HOSTNAME, Exchange(
         Queue(HOSTNAME, Exchange(
             'storagedriver', type='direct'), routing_key='storagedriver'),
             'storagedriver', type='direct'), routing_key='storagedriver'),
     )
     )
 )
 )
+
+