Skip to main content

check_sinks_exist

mz_deploy::client::introspection

Function check_sinks_exist 

Source 
pub(super) async fn check_sinks_exist(
    client: &Client,
    sinks: &BTreeSet<ObjectId>,
) -> Result<BTreeSet<ObjectId>, ConnectionError>
Expand description

Check which sinks from the given set exist in the database.

Returns a BTreeSet of ObjectIds for sinks that already exist. Used during apply to skip creating sinks that already exist (like tables).