def cl = compileToDirectoryAndLoad("CustomTestWorker", """
import ${RequestHandler.name}
class CustomTestWorker implements RequestHandler<Long, Object> {
    Object run(Long request) { return new CustomResult() }
}

class CustomResult implements Serializable {
    String toString() { return "custom-result" }
}
""")

        when:
        def builder = workerFactory.multiRequestWorker(cl)
        def worker = builder.build()

        def cl = compileToDirectoryAndLoad("CustomTestWorker", """
import ${RequestHandler.name}
class CustomTestWorker implements RequestHandler<Long, Object> {
    Object run(Long request) { return new CustomResult() }
}

class CustomResult implements Serializable {
    String toString() { return "custom-result" }
}
""")

        when:
        def builder = workerFactory.singleRequestWorker(cl)
        def worker = builder.build()

    fi
  done

  # shellcheck disable=SC2086
  # Disabling to allow for expansion here
  # Try a non-default chunk size
  customResult=$(kubectl describe ${resource} --show-events=false --chunk-size=10 -v=6 ${args} "${kube_flags[@]}" 2>&1 >/dev/null)
  if grep -q "${resource}?limit=10" <<< "${customResult}"; then
    echo "query for ${resource} had user-specified limit param"
  else
    echo "${bold}${red}"
    echo "FAIL!"