Method update_types

python/pathway/internals/table.py:2232–2251

Updates types in schema. Has no effect on the runtime.

(self, **kwargs: Any)

    @trace_user_frame
    @check_arg_types
    def update_types(self, **kwargs: Any) -> Table:
        """Updates types in schema. Has no effect on the runtime."""

        for name in kwargs.keys():
            if name not in self.keys():
                raise ValueError(
                    "Table.update_types() argument name has to be an existing table column name."
                )
        new_schema = self.schema.with_types(**kwargs)
        for name in kwargs.keys():
            left = new_schema._dtypes()[name]
            right = self.schema._dtypes()[name]
            if not (
                dt.dtype_issubclass(left, right) or dt.dtype_issubclass(right, left)
            ):
                raise TypeError(
                    f"Cannot change type from {right} to {left}.\n"
                    + "Table.update_types() should be used only for type narrowing or type extending."
                )
        return self._with_schema(new_schema)

    @trace_user_frame
    @check_arg_types