diff --git a/elastic4s-domain/src/main/scala/com/sksamuel/elastic4s/requests/task/GetTaskResponse.scala b/elastic4s-domain/src/main/scala/com/sksamuel/elastic4s/requests/task/GetTaskResponse.scala
index 26a5b09ac..8bb610292 100644
--- a/elastic4s-domain/src/main/scala/com/sksamuel/elastic4s/requests/task/GetTaskResponse.scala
+++ b/elastic4s-domain/src/main/scala/com/sksamuel/elastic4s/requests/task/GetTaskResponse.scala
@@ -1,3 +1,8 @@
 package com.sksamuel.elastic4s.requests.task
 
-case class GetTaskResponse(completed: Boolean, task: Task, error: Option[TaskError])
+case class GetTaskResponse(
+    completed: Boolean,
+    task: Task,
+    error: Option[TaskError],
+    response: Option[TaskResponse]
+)
diff --git a/elastic4s-domain/src/main/scala/com/sksamuel/elastic4s/requests/task/TaskFailure.scala b/elastic4s-domain/src/main/scala/com/sksamuel/elastic4s/requests/task/TaskFailure.scala
new file mode 100644
index 000000000..7137be868
--- /dev/null
+++ b/elastic4s-domain/src/main/scala/com/sksamuel/elastic4s/requests/task/TaskFailure.scala
@@ -0,0 +1,6 @@
+package com.sksamuel.elastic4s.requests.task
+
+import com.sksamuel.elastic4s.ErrorCause
+
+// https://github.com/elastic/elasticsearch-specification/blob/main/specification/_types/Errors.ts
+case class TaskFailure(index: String, id: String, cause: ErrorCause, status: Int)
diff --git a/elastic4s-domain/src/main/scala/com/sksamuel/elastic4s/requests/task/TaskResponse.scala b/elastic4s-domain/src/main/scala/com/sksamuel/elastic4s/requests/task/TaskResponse.scala
new file mode 100644
index 000000000..fa8731d13
--- /dev/null
+++ b/elastic4s-domain/src/main/scala/com/sksamuel/elastic4s/requests/task/TaskResponse.scala
@@ -0,0 +1,28 @@
+package com.sksamuel.elastic4s.requests.task
+
+import com.fasterxml.jackson.annotation.JsonProperty
+
+import scala.concurrent.duration.{DurationLong, FiniteDuration}
+
+case class TaskResponse(
+    took: Option[Long] = None,
+    @JsonProperty("timed_out") timedOut: Option[Boolean] = None,
+    total: Option[Long] = None,
+    updated: Option[Long] = None,
+    created: Option[Long] = None,
+    deleted: Option[Long] = None,
+    batches: Option[Long] = None,
+    @JsonProperty("version_conflicts") versionConflicts: Option[Long] = None,
+    noops: Option[Long] = None,
+    retries: Option[Retries] = None,
+    throttled: Option[String] = None,
+    @JsonProperty("throttled_millis") throttledMillis: Option[Long] = None,
+    @JsonProperty("requests_per_second") requestsPerSecond: Option[Float] = None,
+    @JsonProperty("throttled_until") throttledUntil: Option[String] = None,
+    @JsonProperty("throttled_until_millis") throttledUntilMillis: Option[Long] = None,
+    task: Option[String] = None,
+    failures: Option[Seq[TaskFailure]] = None
+) {
+  def throttledTime: Option[FiniteDuration]      = throttledMillis.map(_.millis)
+  def throttledUntilTime: Option[FiniteDuration] = throttledUntilMillis.map(_.millis)
+}