Run landing request state through validator

Author: mvdbeek

lib/galaxy/managers/landing.py

@@ -4,7 +4,10 @@
 )
 from uuid import uuid4
 
-from pydantic import UUID4
+from pydantic import (
+    UUID4,
+    ValidationError,
+)
 from sqlalchemy import select
 
 from galaxy.exceptions import (
@@ -30,6 +33,7 @@
 )
 from galaxy.security.idencoding import IdEncodingHelper
 from galaxy.structured_app import StructuredApp
+from galaxy.tool_util_models.parameters import DataOrCollectionRequestAdapter
 from galaxy.util import safe_str_cmp
 from .context import ProvidesUserContext
 
@@ -73,11 +77,25 @@ def create_workflow_landing_request(self, payload: CreateWorkflowLandingRequestP
             model.workflow_source = payload.workflow_id
         model.uuid = uuid4()
         model.client_secret = payload.client_secret
-        model.request_state = payload.request_state
+        model.request_state = self.validate_workflow_request_state(payload.request_state)
         model.public = payload.public
         self._save(model)
         return self._workflow_response(model)
 
+    def validate_workflow_request_state(self, request_state: Optional[dict]) -> Optional[dict]:
+        # This would ideally be run in the context of a workflow input definition
+        if isinstance(request_state, dict):
+            for key, value in request_state.items():
+                if isinstance(value, dict):
+                    try:
+                        # persist values after model validators and aliases have been applied
+                        request_state[key] = DataOrCollectionRequestAdapter.validate_python(value).model_dump(
+                            by_alias=True, exclude_unset=True, mode="json"
+                        )
+                    except ValidationError:
+                        pass
+        return request_state
+
     def claim_tool_landing_request(
         self, trans: ProvidesUserContext, uuid: UUID4, claim: Optional[ClaimLandingPayload]
     ) -> ToolLandingRequest: