From c31970ced5079e667823190b819588843b24b96a Mon Sep 17 00:00:00 2001 From: HaimKortovich Date: Fri, 17 Apr 2026 12:15:00 -0500 Subject: [PATCH] decode using commanded --- lib/workload_service/aggregates/task_id.ex | 4 ++++ 1 file changed, 4 insertions(+) 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