progress.pending indicates if a task was started

czue · Sep 7, 2020 · e93b096 · e93b096
1 parent 314e232
commit e93b096
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/celery_progress/backend.py b/celery_progress/backend.py
@@ -42,6 +42,7 @@ def set_progress(self, current, total, description=""):
         self.task.update_state(
             state=PROGRESS_STATE,
             meta={
+                'pending': False,
                 'current': current,
                 'total': total,
                 'percent': percent,
@@ -53,6 +54,7 @@ def stop_task(self, current, total, exc):
         self.task.update_state(
             state='FAILURE',
             meta={
+                'pending': False,
                 'current': current,
                 'total': total,
                 'percent': 100.0,
@@ -88,22 +90,23 @@ def get_info(self):
             return {
                 'complete': False,
                 'success': None,
-                'progress': _get_unknown_progress(),
+                'progress': _get_unknown_progress(self.result.state),
             }
         return self.result.info
 
 
 def _get_completed_progress():
     return {
+        'pending': False,
         'current': 100,
         'total': 100,
         'percent': 100,
     }
 
 
-def _get_unknown_progress():
+def _get_unknown_progress(state):
     return {
-        'pending': True,
+        'pending': state == 'PENDING',
         'current': 0,
         'total': 100,
         'percent': 0,