Function run 

pub(crate) async fn run(
    pool: &PgPool,
    scope: &RegistrationScope,
) -> CreditRegistrationResult<Counts>

One pass in one phase, so the Workers tab’s row-creation counter accounts for every row the pipeline invented.