@Override
    public void execute() throws KeeperException, InterruptedException, IOException {
        if (event == null) {
            deployJob();
        } else if (event.getPath().equals(ZookeeperStrings.jobDescPath(jobId))) {
            deployJob();
        } else if (event.getPath().equals(ZookeeperStrings.jobStatusPath(jobId))) {
            checkStatus();
        }
    }