diff --git a/lms/djangoapps/commerce/utils.py b/lms/djangoapps/commerce/utils.py
index 789d45b5ca..6ecc96f460 100644
--- a/lms/djangoapps/commerce/utils.py
+++ b/lms/djangoapps/commerce/utils.py
@@ -278,6 +278,32 @@ def refund_seat(course_enrollment, change_mode=False):
     return refund_ids
 
 
+@pluggable_override('OVERRIDE_GET_PROGRAM_PRICE_INFO')
+def get_program_price_info(api_user, params):
+    """
+    Get the program price info from the ecommerce service.
+
+    Args:
+        api_user: The user to use to make the request.
+        params: The params to use to make the request.
+
+    Returns:
+       JSON: {
+                'total_incl_tax_excl_discounts': basket.total_incl_tax_excl_discounts,
+                'total_incl_tax': basket.total_incl_tax,
+                'currency': basket.currency
+            }
+    """
+    if not api_user.is_authenticated:
+        api_user = get_user_model().objects.get(username=settings.ECOMMERCE_SERVICE_WORKER_USERNAME)
+
+    api_client = get_ecommerce_api_client(api_user)
+    api_url = urljoin(f"{get_ecommerce_api_base_url()}/", "baskets/calculate/")
+
+    response = api_client.get(api_url, params=params)
+    return response
+
+
 def auto_enroll(course_enrollment):
     """
     Helper method to update an enrollment to a default course mode.
diff --git a/openedx/core/djangoapps/programs/utils.py b/openedx/core/djangoapps/programs/utils.py
index 95044a6fae..6d168640c1 100644
--- a/openedx/core/djangoapps/programs/utils.py
+++ b/openedx/core/djangoapps/programs/utils.py
@@ -9,7 +9,6 @@ from urllib.parse import urljoin, urlparse, urlunparse
 
 from dateutil.parser import parse
 from django.conf import settings
-from django.contrib.auth import get_user_model
 from django.contrib.sites.models import Site
 from django.core.cache import cache
 from django.urls import reverse
@@ -27,7 +26,7 @@ from common.djangoapps.util.date_utils import strftime_localized
 from lms.djangoapps.certificates import api as certificate_api
 from lms.djangoapps.certificates.data import CertificateStatuses
 from lms.djangoapps.certificates.models import GeneratedCertificate
-from lms.djangoapps.commerce.utils import EcommerceService
+from lms.djangoapps.commerce.utils import EcommerceService, get_program_price_info
 from openedx.core.djangoapps.catalog.api import get_programs_by_type
 from openedx.core.djangoapps.catalog.constants import PathwayType
 from openedx.core.djangoapps.catalog.utils import (
@@ -35,7 +34,6 @@ from openedx.core.djangoapps.catalog.utils import (
     get_pathways,
     get_programs,
 )
-from openedx.core.djangoapps.commerce.utils import get_ecommerce_api_base_url, get_ecommerce_api_client
 from openedx.core.djangoapps.content.course_overviews.models import CourseOverview
 from openedx.core.djangoapps.credentials.utils import get_credentials, get_credentials_records_url
 from openedx.core.djangoapps.enrollments.api import get_enrollments
@@ -739,16 +737,7 @@ class ProgramDataExtender:
 
         if skus:
             try:
-                api_user = self.user
-                is_anonymous = False
-                if not self.user.is_authenticated:
-                    user = get_user_model()
-                    service_user = user.objects.get(username=settings.ECOMMERCE_SERVICE_WORKER_USERNAME)
-                    api_user = service_user
-                    is_anonymous = True
-
-                api_client = get_ecommerce_api_client(api_user)
-                api_url = urljoin(f"{get_ecommerce_api_base_url()}/", "baskets/calculate/")
+                is_anonymous = not self.user.is_authenticated
 
                 # The user specific program price is slow to calculate, so use switch to force the
                 # anonymous price for all users. See LEARNER-5555 for more details.
@@ -763,7 +752,8 @@ class ProgramDataExtender:
                         params = dict(sku=skus, username=self.user.username, bundle=bundle_uuid)
                     else:
                         params = dict(sku=skus, username=self.user.username)
-                response = api_client.get(api_url, params=params)
+
+                response = get_program_price_info(self.user, params)
                 response.raise_for_status()
                 discount_data = response.json()
                 program_discounted_price = discount_data["total_incl_tax"]