Relationships between aggregates

[paulkre]

I have the following two aggregates:

struct User {
    user_id: Uuid,
    identities: HashSet<AggregateId>,
}

struct Identity {
    provider: String,
    remote_id: String,
    user_id: Option<AggregateId>,
}

So, there is essentially a one-to-many relationship between User and Identity. The code to create a new relationship between a User instance and an Identity instance could look something like this:

tokio::join!(
    user_cqrs.execute(&user_id, UserCommand::AddIdentity(identity_id.clone())),
    identity_cqrs.execute(&identity_id, IdentityCommand::UpdateUser(Some(user_id))),
);

It is technically possible that the resulting events of one of the commands fail to be applied or persisted, while the events of the other command are successfully handled. This would result in the application's state being incorrect, as the relationship between the instances would be incomplete. In relational databases, it is common to have the option of grouping multiple mutations into a single transaction. This ensures that the transaction will only be committed if all the mutations are successful. I was wondering if there is a similar concept in CQRS/ES. Or is there maybe a better way to model relationships between aggregates?