diff --git a/crates/router/src/core/payments/routing.rs b/crates/router/src/core/payments/routing.rs index 0a57819816..8f3f40edf0 100644 --- a/crates/router/src/core/payments/routing.rs +++ b/crates/router/src/core/payments/routing.rs @@ -1347,14 +1347,9 @@ pub async fn perform_success_based_routing( .ok_or(errors::RoutingError::SuccessBasedRoutingParamsNotFoundError)?, ); - let tenant_business_profile_id = routing::helpers::generate_tenant_business_profile_id( - &state.tenant.redis_key_prefix, - business_profile.get_id().get_string_repr(), - ); - let success_based_connectors: CalSuccessRateResponse = client .calculate_success_rate( - tenant_business_profile_id, + business_profile.get_id().get_string_repr().into(), success_based_routing_configs, success_based_routing_config_params, routable_connectors, diff --git a/crates/router/src/core/routing.rs b/crates/router/src/core/routing.rs index 5fc54fe96e..717dfd0c6e 100644 --- a/crates/router/src/core/routing.rs +++ b/crates/router/src/core/routing.rs @@ -1397,10 +1397,6 @@ pub async fn success_based_routing_update_configs( router_env::metric_attributes!(("profile_id", profile_id.clone())), ); - let prefix_of_dynamic_routing_keys = helpers::generate_tenant_business_profile_id( - &state.tenant.redis_key_prefix, - profile_id.get_string_repr(), - ); state .grpc_client .dynamic_routing @@ -1409,7 +1405,7 @@ pub async fn success_based_routing_update_configs( .async_map(|sr_client| async { sr_client .invalidate_success_rate_routing_keys( - prefix_of_dynamic_routing_keys, + profile_id.get_string_repr().into(), state.get_grpc_headers(), ) .await diff --git a/crates/router/src/core/routing/helpers.rs b/crates/router/src/core/routing/helpers.rs index 489c3122a8..0d66c3b6f1 100644 --- a/crates/router/src/core/routing/helpers.rs +++ b/crates/router/src/core/routing/helpers.rs @@ -699,11 +699,6 @@ pub async fn push_metrics_with_update_window_for_success_based_routing( .change_context(errors::ApiErrorResponse::InternalServerError) .attach_printable("unable to retrieve success_rate based dynamic routing configs")?; - let tenant_business_profile_id = generate_tenant_business_profile_id( - &state.tenant.redis_key_prefix, - business_profile.get_id().get_string_repr(), - ); - let success_based_routing_config_params = success_based_routing_config_params_interpolator .get_string_val( success_based_routing_configs @@ -715,7 +710,7 @@ pub async fn push_metrics_with_update_window_for_success_based_routing( let success_based_connectors = client .calculate_success_rate( - tenant_business_profile_id.clone(), + business_profile.get_id().get_string_repr().into(), success_based_routing_configs.clone(), success_based_routing_config_params.clone(), routable_connectors.clone(), @@ -841,7 +836,7 @@ pub async fn push_metrics_with_update_window_for_success_based_routing( client .update_success_rate( - tenant_business_profile_id, + business_profile.get_id().get_string_repr().into(), success_based_routing_configs, success_based_routing_config_params, vec![routing_types::RoutableConnectorChoiceWithStatus::new( @@ -936,14 +931,6 @@ fn get_success_based_metrics_outcome_for_payment( } } -/// generates cache key with tenant's redis key prefix and profile_id -pub fn generate_tenant_business_profile_id( - redis_key_prefix: &str, - business_profile_id: &str, -) -> String { - format!("{}:{}", redis_key_prefix, business_profile_id) -} - #[cfg(all(feature = "v1", feature = "dynamic_routing"))] pub async fn disable_dynamic_routing_algorithm( state: &SessionState,