Browse Source

Merge pull request #3168 from SimonPe/SimonPe-rethrow-exception-beat

reraise exception in celery beat.
Ask Solem Hoel 9 năm trước cách đây
mục cha
commit
afa42071cc
1 tập tin đã thay đổi với 1 bổ sung0 xóa
  1. 1 0
      celery/apps/beat.py

+ 1 - 0
celery/apps/beat.py

@@ -116,6 +116,7 @@ class Beat(object):
             logger.critical('beat raised exception %s: %r',
             logger.critical('beat raised exception %s: %r',
                             exc.__class__, exc,
                             exc.__class__, exc,
                             exc_info=True)
                             exc_info=True)
+            raise exc
 
 
     def init_loader(self):
     def init_loader(self):
         # Run the worker init handler.
         # Run the worker init handler.