code: public void saveTaskUpdateForRetry(SingularityTaskHistoryUpdate taskHistoryUpdate) {
      String parentPath = ZKPaths.makePath(SNS_TASK_RETRY_ROOT, taskHistoryUpdate.getTaskId().getRequestId());
      if (!isChildNodeCountSafe(parentPath)) {
        LOG.warn("Too many queued webhooks for path {}, dropping", parentPath);
        return;
      }
      String updatePath = ZKPaths.makePath(SNS_TASK_RETRY_ROOT, taskHistoryUpdate.getTaskId().getRequestId(), getTaskHistoryUpdateId(taskHistoryUpdate));
      save(updatePath, taskHistoryUpdate, taskHistoryUpdateTranscoder);
    }
docs: Methods for use with sns poller