Browse Source

Prefork: Fixes SCHED_STRATEGY key error in inspect stats. Closes #3621

Ask Solem 8 years ago
parent
commit
49506f6173
1 changed files with 3 additions and 1 deletions
  1. 3 1
      celery/concurrency/asynpool.py

+ 3 - 1
celery/concurrency/asynpool.py

@@ -1096,7 +1096,9 @@ class AsynPool(_pool.Pool):
             'avg': per(total / len(self.write_stats) if total else 0, total),
             'all': ', '.join(per(v, total) for v in vals),
             'raw': ', '.join(map(str, vals)),
-            'strategy': SCHED_STRATEGY_TO_NAME[self.sched_strategy],
+            'strategy': SCHED_STRATEGY_TO_NAME.get(
+                self.sched_strategy, self.sched_strategy,
+            ),
             'inqueues': {
                 'total': len(self._all_inqueues),
                 'active': len(self._active_writes),