fix: 修复 celery 丢失心跳不会重连的问题

2 years ago · ee1ec6aeee
parent 783bddf2c7
commit ee1ec6aeee
1 changed files with 3 additions and 1 deletions
--- a/apps/common/management/commands/services/services/celery_base.py
+++ b/apps/common/management/commands/services/services/celery_base.py
@ -30,7 +30,9 @@ class CeleryBaseService(BaseService):
            '-l', 'INFO',
            '-c', str(self.num),
            '-Q', self.queue,
-            '-n', f'{self.queue}@{server_hostname}'
+            '--heartbeat-interval', '10',
+            '-n', f'{self.queue}@{server_hostname}',
+            '--without-mingle',
        ]
        return cmd