Function upgrade_data_lake_schema_v4 

pub async fn upgrade_data_lake_schema_v4(
    tr: &mut Transaction<'_, Postgres>,
) -> Result<(), Error>

Upgrades the data lake schema to version 4. Adds the format column to streams so OTLP and native blocks can be distinguished.