Method _convert_inputs

sdk/python/src/dagger/mod/_module.py:512–570

Convert arguments from lower level primitives to the expected types.

(
        self,
        fn: Function,
        inputs: Mapping[APIName, Any],
    )

            raise InvalidInputError(msg, extra=extra) from e

    async def _convert_inputs(
        self,
        fn: Function,
        inputs: Mapping[APIName, Any],
    ) -> Mapping[PythonName, Any]:
        """Convert arguments from lower level primitives to the expected types."""
        kwargs = {}

        # Convert arguments to the expected type.
        for python_name, param in fn.parameters.items():
            if param.name not in inputs:
                if not param.is_optional:
                    msg = f"Missing required function argument '{python_name}'"
                    raise InvalidInputError(msg)

                if param.has_default:
                    continue

            # If the argument is optional and has no default, it's a nullable type.
            # According to GraphQL spec, null is a valid value in case it's omitted.
            value = inputs.get(param.name)
            type_ = param.resolved_type

            try:
                kwargs[python_name] = await self.structure(value, type_)
            except Exception as e:
                log_exception_only(
                    e,
                    "Failed to convert from primitive input value for argument '%s'",
                    param.name,
                )
                msg = transform_error(
                    e,
                    (
                        "Failed to convert from primitive input value for argument "
                        f"'{param.name}'"
                    ),
                    origin=fn.wrapped,
                    typ=type_,
                )
                # Same as before, the API can't reasonably hold a value that
                # contradicts its type.
                msg += (
                    "\n"
                    "This could be an error in the Python SDK. "
                    "If so, please file a bug report."
                )
                extra = {
                    "function_name": fn.original_name,
                    "parameter_name": python_name,
                    "expected_type": type_,
                    "actual_type": type(value),
                }
                raise InvalidInputError(msg, extra=extra) from e

        if logger.isEnabledFor(logging.DEBUG):
            logger.debug("structured args => %s", repr(kwargs))