Function _schema_builder

python/pathway/internals/schema.py:646–663

(
    _name: str,
    _dict: dict[str, Any],
    *,
    properties: SchemaProperties = SchemaProperties(),
    id_dtype: dt.DType = dt.ANY_POINTER,
    id_append_only: bool | None = None,
)

def _schema_builder(
    _name: str,
    _dict: dict[str, Any],
    *,
    properties: SchemaProperties = SchemaProperties(),
    id_dtype: dt.DType = dt.ANY_POINTER,
    id_append_only: bool | None = None,
) -> type[Schema]:
    schema = SchemaMetaclass(
        _name,
        (Schema,),
        _dict,
        append_only=properties.append_only,
        id_dtype=id_dtype,
        id_append_only=id_append_only,
    )
    assert issubclass(schema, Schema)
    return schema


def is_subschema(left: type[Schema], right: type[Schema]):