@Override
	public DeploymentUnitStatus getDeploymentStatus(String s) {
		String path = Paths.build(Paths.JOB_DEPLOYMENTS, s, Paths.STATUS);
		byte[] statusBytes = null;

		try {
			statusBytes = zkConnection.getClient().getData().forPath(path);
		}
		catch (Exception e) {
			// missing node means this job has not been deployed
			ZooKeeperUtils.wrapAndThrowIgnoring(e, KeeperException.NoNodeException.class);
		}

		return (statusBytes == null)
				? new DeploymentUnitStatus(DeploymentUnitStatus.State.undeployed)
				: new DeploymentUnitStatus(ZooKeeperUtils.bytesToMap(statusBytes));
	}
Job instance repository. It should only return values for Jobs that are deployed.

@author Mark Fisher
@author David Turanski
@author Gunnar Hillert
spring-xd-dirt/src/main/java/org/springframework/xd/dirt/stream/zookeeper/ZooKeeperJobRepository.java