cwtv
/
concierge
3
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix linter errors 🙄

This commit is contained in:
Jan Koppe 2020-04-27 10:10:05 +02:00
parent a9e1e9b1b4
commit f97720ac67
Signed by: thunfisch
GPG Key ID: BE935B0735A2129B
2 changed files with 11 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
kill.py
View File

@ -22,15 +22,15 @@ def main():
body = dict([pair.split(":") for pair in body.split(" ")]) body = dict([pair.split(":") for pair in body.split(" ")])
if body["groupname"] == "concierge": if body["groupname"] == "concierge":
try: try:
pidfile = open('/run/supervisor.pid','r') pidfile = open('/run/supervisor.pid', 'r')
pid = int(pidfile.readline()); pid = int(pidfile.readline())
os.kill(pid, signal.SIGQUIT) os.kill(pid, signal.SIGQUIT)
except Exception as e: except Exception as e:
write_stdout('could not kill supervisor: %s\n' % e.strerror) write_stdout('could not kill supervisor: %s\n' % e.strerror)
write_stdout('RESULT 2\nOK') write_stdout('RESULT 2\nOK')
if __name__ == '__main__': if __name__ == '__main__':
main() main()

7
main.py
View File

@ -28,11 +28,12 @@ interval = 2
# runtime stuff # runtime stuff
claims = [] claims = []
def svd_update(): def svd_update():
try: try:
r = svd.supervisor.reloadConfig() r = svd.supervisor.reloadConfig()
except xmlrpc.client.Fault as e: except xmlrpc.client.Fault as e:
if e.faultCode == 6: # SHUTDOWN_STATE if e.faultCode == 6: # SHUTDOWN_STATE
print('svd shutting down') print('svd shutting down')
return return
else: else:
@ -88,7 +89,7 @@ def stop_task(uuid):
file = '/app/tasks.d/%s.conf' % uuid file = '/app/tasks.d/%s.conf' % uuid
try: try:
os.remove(file) os.remove(file)
except: except: # noqa
print('error deleting task configfile', file) print('error deleting task configfile', file)
# reload supervisord config # reload supervisord config
@ -104,6 +105,7 @@ def release_task(uuid):
stop_task(uuid) stop_task(uuid)
def claim_task(uuid): def claim_task(uuid):
global claims global claims
r = requests.post('%s/claim/%s' % (base_url, uuid)).json() r = requests.post('%s/claim/%s' % (base_url, uuid)).json()
@ -151,7 +153,6 @@ def loop(config):
claim_task(task.get('uuid')) claim_task(task.get('uuid'))
break break
time.sleep(interval) time.sleep(interval)