Function recompute_preconditions 

pub async fn recompute_preconditions(
    conn: &mut PgConnection,
    scope: &RegistrationScope,
    limit: i64,
) -> ModelResult<i64>

Applies at most limit moves to the scoped rows and returns how many moved.

A row a worker claimed between the snapshot and the write is left where it is: its state is that phase’s to own now, and the next iteration decides again from whatever it committed. Writing anyway could put an in-flight import back into a state a second import claims.