External-Mirrors/awx
2
0
Fork 0
mirror of https://github.com/ansible/awx.git synced 2026-02-15 10:10:01 -03:30
Code Issues Packages Projects Releases Wiki Activity

some celery-watcher tweaks

Browse Source 
* give celery more time to reply over AMQP (the default timeout is 1s)
* record datestamps in celery watcher logs for debugging purposes
This commit is contained in:
Ryan Petrello
2018-07-26 16:16:49 -04:00
parent 3caeb91419
commit 9b1961f60d
1 changed files with 11 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
awx/main/management/commands/watch_celery.py
View File

@@ -1,3 +1,4 @@
import datetime
import os
import signal
import subprocess
@@ -33,19 +34,25 @@ class Command(BaseCommand):
INTERVAL = 60
def _log(self, msg):
sys.stderr.write(datetime.datetime.utcnow().isoformat())
sys.stderr.write(' ')
sys.stderr.write(msg)
sys.stderr.write('\n')
def handle(self, **options):
app = Celery('awx')
app.config_from_object('django.conf:settings')
while True:
try:
pongs = app.control.ping(['celery@{}'.format(settings.CLUSTER_HOST_ID)])
pongs = app.control.ping(['celery@{}'.format(settings.CLUSTER_HOST_ID)], timeout=30)
except Exception:
pongs = []
if not pongs:
sys.stderr.write('celery is not responsive to ping over local AMQP\n')
self._log('celery is not responsive to ping over local AMQP')
pid = self.getpid()
if pid:
sys.stderr.write('sending SIGHUP to {}\n'.format(pid))
self._log('sending SIGHUP to {}'.format(pid))
os.kill(pid, signal.SIGHUP)
time.sleep(self.INTERVAL)
@@ -56,4 +63,4 @@ class Command(BaseCommand):
try:
return int(subprocess.check_output(cmd, shell=True))
except Exception:
sys.stderr.write('could not detect celery pid\n')
self._log('could not detect celery pid')