fn build_persist_sink(
    builder: PersistSinkConnectionBuilder,
    _id: GlobalId
) -> Result<SinkConnection, CoordError>