@Override
    public void execute() throws KeeperException, InterruptedException {
        if (event == null || event.getPath().equals(ZookeeperStrings.jobVerticesPath(jobId))) {
            connect();
        } else if (event.getPath().equals(ZookeeperStrings.jobReadyCountdownLatch(jobId))) {
            fire();
        }
    }