diff --git a/lib/workload_service/aggregates/task_id.ex b/lib/workload_service/aggregates/task_id.ex
index d7eb328..aacf480 100644
--- a/lib/workload_service/aggregates/task_id.ex
+++ b/lib/workload_service/aggregates/task_id.ex
@@ -43,6 +43,10 @@ defmodule WorkloadService.Aggregates.TaskId do
   end
 
   defimpl Commanded.Serialization.JsonDecoder do
+    def decode(%{org_id: org_id, type: type, task_id: task_id}) do
+      WorkloadService.Aggregates.TaskId.new(org_id, type, task_id)
+    end
+
     def decode(id), do: id
   end
 end