code: private InputStream getSourceContent(final String spaceId,
                                           final String contentId)
          throws TaskExecutionFailedException {
          try {
              return new Retrier().execute(new Retriable() {
                  @Override
                  public InputStream retry() throws Exception {
                      // Retrieve from source
                      return sourceStore.getContent(spaceId, contentId).getContentStream();
                  }
              });
          } catch (Exception e) {
              String msg = "Error attempting to get source content: " + e.getMessage();
              throw new DuplicationTaskExecutionFailedException(buildFailureMessage(msg), e);
          }
      }
docs: /*
  Gets content item from source storage provider