diff --git a/hedroid/worker/zk_droid.py b/hedroid/worker/zk_droid.py index 9eb5a65..aaaff6f 100644 --- a/hedroid/worker/zk_droid.py +++ b/hedroid/worker/zk_droid.py @@ -1,4 +1,5 @@ import json +import sys from kazoo.client import KazooClient, KazooState from kazoo.recipe.watchers import DataWatch @@ -26,6 +27,7 @@ def conn_listener(state): logger.debug('connected...') elif state == KazooState.LOST: logger.debug('connection lost...') + sys.exit() elif state == KazooState.SUSPENDED: logger.debug('connection suspended...')