Method __init__

python/pathway/internals/schema.py:288–315

(
        self,
        name: str,
        bases: tuple[type],
        namespace: dict[str, Any],
        append_only: bool | None = None,
        id_dtype: dt.DType = dt.ANY_POINTER,
        id_append_only: bool | None = None,
        **kwargs,
    )

    @trace.trace_user_frame
    def __init__(
        self,
        name: str,
        bases: tuple[type],
        namespace: dict[str, Any],
        append_only: bool | None = None,
        id_dtype: dt.DType = dt.ANY_POINTER,
        id_append_only: bool | None = None,
        **kwargs,
    ) -> None:
        super().__init__(name, bases, namespace, **kwargs)
        schema_properties = SchemaProperties(append_only=append_only)
        self.__columns__ = _create_column_definitions(self, bases, schema_properties)
        pk_dtypes = [col.dtype for col in self.__columns__.values() if col.primary_key]
        if len(pk_dtypes) > 0:
            derived_type = dt.Pointer(*pk_dtypes)
            assert id_dtype in [derived_type, dt.ANY_POINTER]
            id_dtype = derived_type
        self.__universe_properties__ = _universe_properties(
            list(self.__columns__.values()),
            schema_properties,
            dtype=id_dtype,
            append_only=id_append_only,
        )
        self.__dtypes__ = {
            name: column.dtype for name, column in self.__columns__.items()
        }
        self.__types__ = {k: v.typehint for k, v in self.__dtypes__.items()}

    def __call__(self) -> NoReturn:
        raise TypeError(