def convert_params()

in src/pydolphinscheduler/core/parameter.py [0:0]

• 14 lines of code
• 6 McCabe index (conditional complexity)

    def convert_params(params, direction):
        """Convert params to format local_params.

        :param params: dict[str, Any], the input_params or output_params of Task.
        :param direction: [Direction.IN | Direction.OUT], direction of parameter.
        """
        parameters = []
        params = params or {}
        if not isinstance(params, dict):
            raise PyDSParamException(
                "Parameter `params` must be a dict, but get %s", type(params)
            )
        for key, value in params.items():
            if not isinstance(value, BaseDataType):
                data_type_cls = ParameterHelper.infer_parameter_type(value)
                value = data_type_cls(value)

            parameter = Parameter(key, direction, value.data_type, value.value)
            parameters.append(parameter)
        return [p.data for p in parameters]