Hotfix support for django_db for celery backend (specially for django_celery_results)

Author: aidin-leo

celery_progress/backend.py

@@ -2,9 +2,9 @@
 from abc import ABCMeta, abstractmethod
 from decimal import Decimal
 
-from celery.result import EagerResult, allow_join_result
+from asgiref.sync import sync_to_async
 from celery.backends.base import DisabledBackend
-
+from celery.result import EagerResult, allow_join_result
 
 PROGRESS_STATE = 'PROGRESS'
 
@@ -57,6 +57,7 @@ def __init__(self, result):
         """
         self.result = result
 
+    @sync_to_async
     def get_info(self):
         response = {'state': self.result.state}
         if self.result.state in ['SUCCESS', 'FAILURE']:

celery_progress/websockets/consumers.py

@@ -31,7 +31,7 @@ async def receive(self, text_data):
                 self.task_id,
                 {
                     'type': 'update_task_progress',
-                    'data': Progress(AsyncResult(self.task_id)).get_info()
+                    'data': await Progress(AsyncResult(self.task_id)).get_info()
                 }
             )