def connect_to_zk(servers, **kwargs):
	conn = zc.zk.ZooKeeper(servers, **kwargs)
	conn.watches.lock = threading.RLock()
	return conn
Marks execution as abandoned if it is still incomplete. Abandoning an
dataset/ETHPy150Open Knewton/pettingzoo-python/pettingzoo/utils.py/connect_to_zk--crossover with--dataset/ETHPy150Open StackStorm/st2/st2common/st2common/services/executions.py/abandon_execution_if_incomplete