Function insert_pending_statements 

pub(super) async fn insert_pending_statements(
    client: &Client,
    statements: &[PendingStatement],
) -> Result<(), ConnectionError>

Insert pending statements for deferred execution (e.g., sinks).