Fixed task and datastream workspace ID aliases

Author: Ken Lippold

etl/schemas/task.py

@@ -2,7 +2,7 @@
 from typing import Any, Literal
 from datetime import datetime
 from ninja import Schema, Field, Query
-from pydantic import AliasPath
+from pydantic import AliasPath, AliasChoices
 from api.types import ISODatetime
 from api.schemas import BaseGetResponse, BasePostBody, BasePatchBody, CollectionQueryParameters
 from iam.schemas import WorkspaceSummaryResponse
@@ -157,7 +157,9 @@ class TaskFields(Schema):
 
 class TaskSummaryResponse(BaseGetResponse, TaskFields):
     id: uuid.UUID
-    workspace_id: uuid.UUID = Field(..., validation_alias=AliasPath("job", "workspace_id"))
+    workspace_id: uuid.UUID = Field(
+        ..., validation_alias=AliasChoices("workspaceId", AliasPath("job", "workspace_id"))
+    )
     job_id: uuid.UUID
     orchestration_system_id: uuid.UUID
     schedule: TaskScheduleResponse | None = None

sta/schemas/datastream.py

@@ -1,5 +1,5 @@
 import uuid
-from pydantic import AliasPath
+from pydantic import AliasPath, AliasChoices
 from ninja import Schema, Field, Query
 from typing import Optional, Literal, TYPE_CHECKING
 from api.types import ISODatetime
@@ -166,7 +166,7 @@ class DatastreamSummaryResponse(
 ):
     id: uuid.UUID
     workspace_id: uuid.UUID = Field(
-        ..., validation_alias=AliasPath("thing", "workspace_id")
+        ..., validation_alias=AliasChoices("workspaceId", AliasPath("thing", "workspace_id"))
     )
     datastream_tags: list[TagGetResponse] = Field(..., alias="tags")
     datastream_file_attachments: list[FileAttachmentGetResponse] = Field(