Function assert_schema_not_none

python/pathway/io/_utils.py:196–209

(
    schema: type[Schema] | None,
    data_format_type: str | None = None,
)

def assert_schema_not_none(
    schema: type[Schema] | None,
    data_format_type: str | None = None,
) -> type[Schema]:
    if schema is None:
        if data_format_type == "dsv":
            raise ValueError(
                "Schema must be specified. "
                "Consider using `pw.schema_from_csv` for generating schema from a CSV file"
            )
        else:
            raise ValueError("Schema must be specified.")
    else:
        return schema


class PlaintextKeySchema(pw.Schema):