@@ -1958,23 +1958,19 @@ run_routing_decision_pipeline(Ctx0, VS, St) ->
19581958 % % NOTE Since this is routing step then current attempt is not yet
19591959 % % accounted for in `St`.
19601960 NewIter = get_iter (St ) + 1 ,
1961- {TokenFilterFn , ChooseRouteFn } = cascade_pipeline_fns (St ),
19621961 hg_routing_ctx :pipeline (
19631962 Ctx0 ,
19641963 [
19651964 fun (Ctx ) -> filter_attempted_routes (Ctx , St ) end ,
1966- TokenFilterFn ,
1965+ fun ( Ctx ) -> filter_routes_by_recurrent_tokens ( Ctx , St ) end ,
19671966 fun (Ctx ) -> filter_routes_with_limit_hold (Ctx , VS , NewIter , St ) end ,
19681967 fun (Ctx ) -> filter_routes_by_limit_overflow (Ctx , VS , NewIter , St ) end ,
19691968 fun (Ctx ) -> hg_routing :filter_by_blacklist (Ctx , build_blacklist_context (St )) end ,
19701969 fun hg_routing :filter_by_critical_provider_status /1 ,
1971- ChooseRouteFn
1970+ fun hg_routing : choose_route_with_ctx / 1
19721971 ]
19731972 ).
19741973
1975- cascade_pipeline_fns (St ) ->
1976- {fun (Ctx ) -> filter_routes_by_recurrent_tokens (Ctx , St ) end , fun hg_routing :choose_route_with_ctx /1 }.
1977-
19781974produce_routing_events (#{error := Error } = Ctx , Revision , St ) when Error =/= undefined ->
19791975 % % TODO Pass failure subcode from error. Say, if last candidates were
19801976 % % rejected because of provider gone critical, then use subcode to highlight
0 commit comments