diff --git a/contentcuration/automation/migrations/0001_initial.py b/contentcuration/automation/migrations/0001_initial.py
index 6152c0f4b2..fd5d3ad213 100644
--- a/contentcuration/automation/migrations/0001_initial.py
+++ b/contentcuration/automation/migrations/0001_initial.py
@@ -1,4 +1,4 @@
-# Generated by Django 3.2.24 on 2024-08-05 21:23
+# Generated by Django 3.2.24 on 2025-03-26 11:12
 import uuid
 
 import django.db.models.deletion
@@ -7,26 +7,36 @@
 
 
 class Migration(migrations.Migration):
+
     initial = True
 
     dependencies = [
-        ('kolibri_public', '0003_alter_file_preset'),
+        ('kolibri_public', '0005_alter_localfile_extension'),
+        ('contentcuration', '0151_embeddings_embeddingscontentnode'),
     ]
 
     operations = [
         migrations.CreateModel(
             name='RecommendationsCache',
             fields=[
-                ('id', models.UUIDField(default=uuid.uuid4, editable=False, primary_key=True,
-                                        serialize=False)),
+                ('id', models.UUIDField(default=uuid.uuid4, editable=False, primary_key=True, serialize=False)),
                 ('request_hash', models.CharField(max_length=32, null=True)),
-                ('rank', models.FloatField(default=0.0, null=True)),
+                ('topic_id', models.UUIDField(blank=True, null=True)),
+                ('rank', models.IntegerField(default=0, null=True)),
                 ('override_threshold', models.BooleanField(default=False)),
                 ('timestamp', models.DateTimeField(auto_now_add=True)),
-                ('contentnode', models.ForeignKey(blank=True, null=True,
-                                                  on_delete=django.db.models.deletion.CASCADE,
-                                                  related_name='recommendations',
-                                                  to='kolibri_public.contentnode')),
+                ('channel', models.ForeignKey(
+                    blank=True,
+                    null=True,
+                    on_delete=django.db.models.deletion.CASCADE,
+                    related_name='channel_recommendations',
+                    to='contentcuration.channel')),
+                ('contentnode', models.ForeignKey(
+                    blank=True,
+                    null=True,
+                    on_delete=django.db.models.deletion.CASCADE,
+                    related_name='contentnode_recommendations',
+                    to='kolibri_public.contentnode')),
             ],
         ),
         migrations.AddIndex(
diff --git a/contentcuration/automation/models.py b/contentcuration/automation/models.py
index 7000ddf420..0d92dfd977 100644
--- a/contentcuration/automation/models.py
+++ b/contentcuration/automation/models.py
@@ -3,6 +3,8 @@
 from django.db import models
 from kolibri_public.models import ContentNode
 
+from contentcuration.models import Channel
+
 
 REQUEST_HASH_INDEX_NAME = "request_hash_idx"
 CONTENTNODE_INDEX_NAME = "contentnode_idx"
@@ -11,14 +13,22 @@
 class RecommendationsCache(models.Model):
     id = models.UUIDField(primary_key=True, default=uuid.uuid4, editable=False)
     request_hash = models.CharField(max_length=32, null=True)
+    topic_id = models.UUIDField(null=True, blank=True)
     contentnode = models.ForeignKey(
         ContentNode,
         null=True,
         blank=True,
-        related_name='recommendations',
+        related_name='contentnode_recommendations',
+        on_delete=models.CASCADE,
+    )
+    channel = models.ForeignKey(
+        Channel,
+        null=True,
+        blank=True,
+        related_name='channel_recommendations',
         on_delete=models.CASCADE,
     )
-    rank = models.FloatField(default=0.0, null=True)
+    rank = models.IntegerField(default=0, null=True)
     override_threshold = models.BooleanField(default=False)
     timestamp = models.DateTimeField(auto_now_add=True)
 
diff --git a/contentcuration/automation/tests/test_recommendations_cache_model.py b/contentcuration/automation/tests/test_recommendations_cache_model.py
index 9cb2e96c9a..01024c3ee0 100644
--- a/contentcuration/automation/tests/test_recommendations_cache_model.py
+++ b/contentcuration/automation/tests/test_recommendations_cache_model.py
@@ -4,30 +4,41 @@
 from django.db import IntegrityError
 from kolibri_public.models import ContentNode
 
+from contentcuration.models import Channel
 from contentcuration.tests.base import StudioTestCase
 
 
 class TestRecommendationsCache(StudioTestCase):
 
     def setUp(self):
+        self.topic_id = uuid.uuid4()
         self.content_node = ContentNode.objects.create(
             id=uuid.uuid4(),
             title='Test Content Node',
             content_id=uuid.uuid4(),
             channel_id=uuid.uuid4(),
         )
+        self.channel = Channel.objects.create(
+            id=uuid.uuid4(),
+            name='Test Channel',
+            actor_id=1,
+        )
         self.cache = RecommendationsCache.objects.create(
             request_hash='test_hash',
+            topic_id=self.topic_id,
             contentnode=self.content_node,
-            rank=1.0,
+            channel=self.channel,
+            rank=1,
             override_threshold=False
         )
 
     def test_cache_creation(self):
         self.assertIsInstance(self.cache, RecommendationsCache)
         self.assertEqual(self.cache.request_hash, 'test_hash')
+        self.assertEqual(self.cache.topic_id, self.topic_id)
         self.assertEqual(self.cache.contentnode, self.content_node)
-        self.assertEqual(self.cache.rank, 1.0)
+        self.assertEqual(self.cache.channel, self.channel)
+        self.assertEqual(self.cache.rank, 1)
         self.assertFalse(self.cache.override_threshold)
 
     def test_cache_retrieval(self):
@@ -38,8 +49,10 @@ def test_cache_uniqueness(self):
         with self.assertRaises(IntegrityError):
             RecommendationsCache.objects.create(
                 request_hash='test_hash',
+                topic_id=self.topic_id,
                 contentnode=self.content_node,
-                rank=2.0,
+                channel=self.channel,
+                rank=2,
                 override_threshold=True
             )
 
diff --git a/contentcuration/automation/utils/appnexus/base.py b/contentcuration/automation/utils/appnexus/base.py
index 626bca1d58..616c057c93 100644
--- a/contentcuration/automation/utils/appnexus/base.py
+++ b/contentcuration/automation/utils/appnexus/base.py
@@ -5,7 +5,7 @@
 
 import requests
 from requests.adapters import HTTPAdapter
-from requests.packages.urllib3.util.retry import Retry
+from urllib3 import Retry
 
 from . import errors
 
@@ -77,7 +77,7 @@ def __new__(cls, *args, **kwargs):
 
     def __init__(
         self,
-        url_prefix="",
+        url_prefix="stable",
     ):
         self.url_prefix = url_prefix
         if not self.session:
@@ -161,17 +161,19 @@ def connect(self, **kwargs):
         """ Establishes a connection to the backend service. """
         try:
             request = BackendRequest(method="GET", path=self.connect_endpoint, **kwargs)
-            self._make_request(request)
-            return True
+            api_response = self._make_request(request)
+            response_data = api_response.json()
+            status = response_data.get("status", None)
+            return status == "OK"
         except Exception:
             return False
 
     def make_request(self, request):
         """ Make a request to the backend service. """
         try:
-            response = self._make_request(request)
-            response_body = dict(data=response.json())
-            return BackendResponse(**response_body)
+            api_response = self._make_request(request)
+            response_data = api_response.json()
+            return BackendResponse(data=response_data)
         except ValueError as e:
             logging.exception(e)
             raise errors.InvalidResponse("Invalid response from backend")
diff --git a/contentcuration/contentcuration/dev_settings.py b/contentcuration/contentcuration/dev_settings.py
index 439bdef8af..d81d23a993 100644
--- a/contentcuration/contentcuration/dev_settings.py
+++ b/contentcuration/contentcuration/dev_settings.py
@@ -5,4 +5,4 @@
 
 ROOT_URLCONF = "contentcuration.dev_urls"
 
-INSTALLED_APPS += ("drf_yasg", "automation")
+INSTALLED_APPS += ("drf_yasg",)
diff --git a/contentcuration/contentcuration/frontend/RecommendedResourceCard/components/RecommendedResourceCard.vue b/contentcuration/contentcuration/frontend/RecommendedResourceCard/components/RecommendedResourceCard.vue
index fc69859fc5..719b0e9bed 100644
--- a/contentcuration/contentcuration/frontend/RecommendedResourceCard/components/RecommendedResourceCard.vue
+++ b/contentcuration/contentcuration/frontend/RecommendedResourceCard/components/RecommendedResourceCard.vue
@@ -1,40 +1,46 @@
 <template>
 
   <KCard
-    class="recommended-resource-card"
-    :to="to"
-    :title="title"
-    orientation="horizontal"
-    :headingLevel="headingLevel"
+    :title="node.title"
+    :headingLevel="2"
     thumbnailScaleType="contain"
     thumbnailDisplay="small"
     thumbnailAlign="right"
-    :thumbnailSrc="thumbnailSrc"
-    :style="{ margin: '16px 0 16px 0' }"
+    :thumbnailSrc="node.thumbnail_src"
+    @click="onClick"
   >
-    <template #aboveTitle>
-      <div>
-        <KIcon
-          icon="practiceSolid"
-        />
-        <span>Practice</span>
-      </div>
+    <template #select>
+      <Checkbox
+        :key="`checkbox-${node.id}`"
+        :inputValue="isSelected(node)"
+        @input="toggleSelected(node)"
+      >
+        <span class="visuallyhidden">{{ $tr('selectCard', { title: node.title }) }}</span>
+      </Checkbox>
     </template>
-    <template #title>
+    <template #aboveTitle>
+      <ContentNodeLearningActivityIcon
+        :learningActivities="learningActivities"
+        showEachActivityIcon
+        includeText
+        small
+      />
     </template>
     <template #belowTitle>
-      <div class="bellow-title-style">
-        <p>
-          below title slot section for the KCard component:
-          below title slot section for the KCard component
-        </p>
+      <div>
+        <KTextTruncator
+          :text="channelName"
+          :maxLines="2"
+        />
       </div>
     </template>
     <template #footer>
-      <div class="align-right-style">
-        <KIconButton icon="openNewTab" class="card-icon-size" />
-        <KIconButton icon="thumbDown" class="card-icon-size" />
-      </div>
+      <KFixedGrid :numCols="2">
+        <KFixedGridItem alignment="right">
+          <KIconButton icon="openNewTab" />
+          <KIconButton icon="thumbDown" />
+        </KFixedGridItem>
+      </KFixedGrid>
     </template>
   </KCard>
 
@@ -43,37 +49,69 @@
 
 <script>
 
+  import find from 'lodash/find';
+  import LearningActivities from 'kolibri-constants/labels/LearningActivities';
+  import { mapState } from 'vuex';
+  import { ContentKindLearningActivityDefaults } from 'shared/leUtils/ContentKinds';
+  import Checkbox from 'shared/views/form/Checkbox';
+  import ContentNodeLearningActivityIcon from 'shared/views/ContentNodeLearningActivityIcon';
+
   export default {
     name: 'RecommendedResourceCard',
+    components: {
+      Checkbox,
+      ContentNodeLearningActivityIcon,
+    },
     props: {
-      to: {
+      node: {
         type: Object,
         required: true,
       },
-      title: {
-        type: String,
-        default: null,
+    },
+    computed: {
+      ...mapState('importFromChannels', ['selected']),
+      channelName() {
+        return this.node.title;
+      },
+      learningActivities() {
+        if (this.node.learning_activities && Object.keys(this.node.learning_activities).length) {
+          return this.node.learning_activities;
+        }
+        return {
+          [ContentKindLearningActivityDefaults[this.node.kind] || LearningActivities.EXPLORE]: true,
+        };
       },
-      headingLevel: {
-        type: Number,
-        required: true,
+      isSelected() {
+        return function(node) {
+          return Boolean(find(this.selected, { id: node.id }));
+        };
       },
-      thumbnailSrc: {
-        type: String,
-        default: null,
+    },
+    methods: {
+      toggleSelected(node) {
+        this.$emit('change_selected', { nodes: [node], isSelected: !this.isSelected(node) });
+      },
+      onClick() {
+        this.$emit('preview', this.node);
       },
     },
+    $trs: {
+      selectCard: 'Select { title }',
+    },
   };
 
 </script>
 
 
 <style>
-  .align-right-style{
-      display: flex;
-      justify-content: flex-end;
-  }
-  .recommended-resource-card {
-    max-width:400px
+  .visuallyhidden {
+    position: absolute;
+    width: 1px;
+    height: 1px;
+    padding: 0;
+    margin: -1px;
+    overflow: hidden;
+    clip: rect(0 0 0 0);
+    border: 0;
   }
 </style>
diff --git a/contentcuration/contentcuration/frontend/channelEdit/views/ImportFromChannels/ChannelList.vue b/contentcuration/contentcuration/frontend/channelEdit/views/ImportFromChannels/ChannelList.vue
index 6741ffc6c2..d9b0669abd 100644
--- a/contentcuration/contentcuration/frontend/channelEdit/views/ImportFromChannels/ChannelList.vue
+++ b/contentcuration/contentcuration/frontend/channelEdit/views/ImportFromChannels/ChannelList.vue
@@ -6,10 +6,10 @@
       <DropdownWrapper
         component="VFlex"
         sm6
-        md5
-        lg4
-        xl3
-        class="pr-4"
+        md6
+        lg6
+        xl6
+        class="pr-3"
       >
         <template #default="{ attach, menuProps }">
           <VSelect
@@ -23,7 +23,7 @@
           />
         </template>
       </DropdownWrapper>
-      <VFlex sm6 md5 lg4 xl3 class="pr-5">
+      <VFlex sm6 md6 lg6 xl6>
         <LanguageDropdown v-model="languageFilter" />
       </VFlex>
     </VLayout>
diff --git a/contentcuration/contentcuration/frontend/channelEdit/views/ImportFromChannels/ImportFromChannelsModal.vue b/contentcuration/contentcuration/frontend/channelEdit/views/ImportFromChannels/ImportFromChannelsModal.vue
index e085b6fe7d..25e18174a0 100644
--- a/contentcuration/contentcuration/frontend/channelEdit/views/ImportFromChannels/ImportFromChannelsModal.vue
+++ b/contentcuration/contentcuration/frontend/channelEdit/views/ImportFromChannels/ImportFromChannelsModal.vue
@@ -277,7 +277,10 @@
 <style lang="less" scoped>
 
   .modal-container.fluid {
-    max-width: 1200px;
+    display: flex;
+    align-items: center;
+    justify-content: center;
+    max-width: 100%;
   }
 
 </style>
diff --git a/contentcuration/contentcuration/frontend/channelEdit/views/ImportFromChannels/SearchFilters.vue b/contentcuration/contentcuration/frontend/channelEdit/views/ImportFromChannels/SearchFilters.vue
index 128e990ecb..43e6e4d2f2 100644
--- a/contentcuration/contentcuration/frontend/channelEdit/views/ImportFromChannels/SearchFilters.vue
+++ b/contentcuration/contentcuration/frontend/channelEdit/views/ImportFromChannels/SearchFilters.vue
@@ -3,7 +3,7 @@
   <VNavigationDrawer
     permanent
     floating
-    class="import-search-filters px-2"
+    class="import-search-filters"
   >
     <!-- Channel -->
     <p class="font-weight-bold grey--text mb-1">
diff --git a/contentcuration/contentcuration/frontend/channelEdit/views/ImportFromChannels/SearchOrBrowseWindow.vue b/contentcuration/contentcuration/frontend/channelEdit/views/ImportFromChannels/SearchOrBrowseWindow.vue
index 55f348f138..2c7ba983e3 100644
--- a/contentcuration/contentcuration/frontend/channelEdit/views/ImportFromChannels/SearchOrBrowseWindow.vue
+++ b/contentcuration/contentcuration/frontend/channelEdit/views/ImportFromChannels/SearchOrBrowseWindow.vue
@@ -2,80 +2,160 @@
 
   <ImportFromChannelsModal>
     <template #default="{ preview }">
-      <VSheet>
-        <div v-if="!isBrowsing" class="my-2 px-2">
-          <ActionLink
-            :text="$tr('backToBrowseAction')"
-            @click="handleBackToBrowse"
-          />
-        </div>
-        <!-- Search bar -->
-        <VLayout row wrap class="mt-4 px-2">
-          <VFlex style="max-width: 700px">
-            <VForm ref="search" @submit.prevent="handleSearchTerm">
-              <VTextField
-                v-model="searchTerm"
-                class="searchtext"
-                color="primary"
-                :label="$tr('searchLabel')"
-                box
-                clearable
-                hideDetails
-                @click:clear="handleBackToBrowse"
-              >
-                <template #prepend-inner>
-                  <Icon icon="search" />
-                </template>
-                <template #append-outer>
-                  <VBtn
-                    class="px-4 search-btn"
-                    color="primary"
-                    type="submit"
-                    :disabled="!searchIsValid"
-                    depressed
-                    large
-                  >
-                    {{ $tr('searchAction') }}
-                  </VBtn>
-                </template>
-              </VTextField>
-            </VForm>
-          </VFlex>
-        </VLayout>
 
-        <div class="my-2 px-2">
-          <ActionLink
-            class="mb-3"
-            :text="$tr('savedSearchesLabel')"
-            :disabled="!savedSearchesExist"
-            @click="showSavedSearches = true"
+      <KGrid :class="$computedClass(browseWindowStyle)">
+
+        <!-- Back to browse button -->
+        <KGridItem
+          :layout12="{ span: 12 }"
+          :layout8="{ span: 8 }"
+          :layout4="{ span: 4 }"
+        >
+          <div v-if="!isBrowsing" class="my-2">
+            <ActionLink
+              :text="$tr('backToBrowseAction')"
+              @click="handleBackToBrowse"
+            />
+          </div>
+        </KGridItem>
+
+        <!-- Main panel >= 800px -->
+        <KGridItem
+          :layout12="{ span: isAIFeatureEnabled && layoutFitsTwoColumns ? 8 : 12 }"
+          :layout8="{ span: 8 }"
+          :layout4="{ span: 4 }"
+        >
+          <!-- Search bar -->
+          <VForm ref="search" @submit.prevent="handleSearchTerm">
+            <VTextField
+              v-model="searchTerm"
+              class="searchtext"
+              color="primary"
+              :label="$tr('searchLabel')"
+              box
+              clearable
+              hideDetails
+            >
+              <template #prepend-inner>
+                <Icon icon="search" />
+              </template>
+              <template #append-outer>
+                <VBtn
+                  class="px-4 search-btn"
+                  color="primary"
+                  type="submit"
+                  :disabled="!searchIsValid"
+                  depressed
+                  large
+                >
+                  {{ $tr('searchAction') }}
+                </VBtn>
+              </template>
+            </VTextField>
+          </VForm>
+
+          <div v-if="!isBrowsing" class="my-2 px-2">
+            <ActionLink
+              class="mb-3"
+              :text="$tr('savedSearchesLabel')"
+              :disabled="!savedSearchesExist"
+              @click="showSavedSearches = true"
+            />
+          </div>
+          <!-- Search or Topics Browsing -->
+          <ChannelList
+            v-if="isBrowsing && !$route.params.channelId"
+            @update-language="updateLanguageQuery"
           />
-        </div>
+          <ContentTreeList
+            v-else-if="isBrowsing"
+            ref="contentTreeList"
+            :topicNode="topicNode"
+            :selected.sync="selected"
+            :topicId="topicId"
+            @preview="preview($event)"
+            @change_selected="handleChangeSelected"
+            @copy_to_clipboard="handleCopyToClipboard"
+          />
+          <SearchResultsList
+            v-else
+            :selected.sync="selected"
+            @preview="preview($event)"
+            @change_selected="handleChangeSelected"
+            @copy_to_clipboard="handleCopyToClipboard"
+          />
+        </KGridItem>
 
-        <!-- Search or Topics Browsing -->
-        <ChannelList
-          v-if="isBrowsing && !$route.params.channelId"
-          @update-language="updateLanguageQuery"
-        />
-        <ContentTreeList
-          v-else-if="isBrowsing"
-          ref="contentTreeList"
-          :topicNode="topicNode"
-          :selected.sync="selected"
-          :topicId="$route.params.nodeId"
-          @preview="preview($event)"
-          @change_selected="handleChangeSelected"
-          @copy_to_clipboard="handleCopyToClipboard"
-        />
-        <SearchResultsList
-          v-else
-          :selected.sync="selected"
-          @preview="preview($event)"
-          @change_selected="handleChangeSelected"
-          @copy_to_clipboard="handleCopyToClipboard"
-        />
-      </VSheet>
+        <!-- Recommended resources panel >= 400px -->
+        <KGridItem
+          v-if="isAIFeatureEnabled"
+          :layout12="{ span: layoutFitsTwoColumns ? 4 : 12 }"
+          :layout8="{ span: 8 }"
+          :layout4="{ span: 4 }"
+        >
+          <h3 class="pb-2 pt-0 px-2">
+            {{ recommendationsSectionTitle }}
+          </h3>
+          <div class="my-3 px-2">
+            <ActionLink
+              :text="aboutRecommendationsText$()"
+              @click="handleAboutRecommendations"
+            />
+          </div>
+
+          <div class="ml-1">
+            <KCardGrid layout="1-1-1">
+              <RecommendedResourceCard
+                v-for="recommendation in displayedRecommendations"
+                :key="recommendation.id"
+                :node="recommendation"
+                @change_selected="handleChangeSelected"
+                @preview="preview($event)"
+              />
+            </KCardGrid>
+          </div>
+          <div v-if="recommendationsLoading" class="recommendations-loader">
+            <KCircularLoader :shouldShow="recommendationsLoading" />
+          </div>
+          <div v-else-if="!recommendationsLoading">
+            <p v-if="loadMoreRecommendationsText.description" class="pb-0 pt-4 px-2">
+              {{ loadMoreRecommendationsText.description }}
+            </p>
+            <div v-if="loadMoreRecommendationsText.link" class="my-3 px-2">
+              <ActionLink
+                :text="loadMoreRecommendationsText.link"
+                @click="handleViewMoreRecommendations"
+              />
+            </div>
+          </div>
+          <div v-else-if="recommendationsLoadingError">
+            <p class="pb-0 pt-4 px-2">
+              {{ loadMoreRecommendationsText.description }}
+            </p>
+            <div class="my-3 px-2">
+              <ActionLink
+                :text="loadMoreRecommendationsText.link"
+                @click="handleViewMoreRecommendations"
+              />
+            </div>
+          </div>
+        </KGridItem>
+      </KGrid>
       <SavedSearchesModal v-model="showSavedSearches" />
+      <!-- About Recommendations Modal -->
+      <KModal
+        v-if="showAboutRecommendations"
+        :title="aboutRecommendationsText$()"
+        :cancelText="closeAction$()"
+        @cancel="closeAboutRecommendations"
+      >
+        <p class="pb-2">
+          {{ aboutRecommendationsDescription$() }}
+        </p>
+        <p>
+          {{ aboutRecommendationsFeedbackDescription$() }}
+        </p>
+      </KModal>
     </template>
   </ImportFromChannelsModal>
 
@@ -85,13 +165,18 @@
 <script>
 
   import { mapActions, mapGetters, mapMutations, mapState } from 'vuex';
+  import { computed } from '@vue/composition-api';
+  import useKResponsiveWindow from 'kolibri-design-system/lib/composables/useKResponsiveWindow';
   import { RouteNames } from '../../constants';
+  import RecommendedResourceCard from '../../../RecommendedResourceCard/components/RecommendedResourceCard';
   import ChannelList from './ChannelList';
   import ContentTreeList from './ContentTreeList';
   import SearchResultsList from './SearchResultsList';
   import SavedSearchesModal from './SavedSearchesModal';
   import ImportFromChannelsModal from './ImportFromChannelsModal';
   import { withChangeTracker } from 'shared/data/changes';
+  import { formatUUID4 } from 'shared/data/resources';
+  import { searchRecommendationsStrings } from 'shared/strings/searchRecommendationsStrings';
 
   export default {
     name: 'SearchOrBrowseWindow',
@@ -101,6 +186,45 @@
       SearchResultsList,
       ChannelList,
       SavedSearchesModal,
+      RecommendedResourceCard,
+    },
+    setup() {
+      const { windowWidth } = useKResponsiveWindow();
+
+      const {
+        closeAction$,
+        tryAgainLink$,
+        viewMoreLink$,
+        noDirectMatchesMessage$,
+        showOtherResourcesLink$,
+        aboutRecommendationsText$,
+        showOtherResourcesMessage$,
+        showOtherRecommendationsLink$,
+        resourcesMightBeRelevantTitle$,
+        problemShowingResourcesMessage$,
+        aboutRecommendationsDescription$,
+        aboutRecommendationsFeedbackDescription$,
+      } = searchRecommendationsStrings;
+
+      const layoutFitsTwoColumns = computed(function() {
+        return windowWidth.value >= 960;
+      });
+
+      return {
+        closeAction$,
+        tryAgainLink$,
+        viewMoreLink$,
+        noDirectMatchesMessage$,
+        showOtherResourcesLink$,
+        aboutRecommendationsText$,
+        showOtherResourcesMessage$,
+        showOtherRecommendationsLink$,
+        resourcesMightBeRelevantTitle$,
+        problemShowingResourcesMessage$,
+        aboutRecommendationsDescription$,
+        aboutRecommendationsFeedbackDescription$,
+        layoutFitsTwoColumns,
+      };
     },
     data() {
       return {
@@ -109,10 +233,26 @@
         copyNode: null,
         languageFromChannelList: null,
         showSavedSearches: false,
+        importDestinationAncestors: [],
+        showAboutRecommendations: false,
+        recommendations: [],
+        otherRecommendations: [],
+        displayedRecommendations: [],
+        recommendationsLoading: false,
+        recommendationsLoadingError: false,
+        recommendationsPageSize: 10,
+        recommendationsCurrentIndex: 0,
+        recommendationsBelowThreshold: false,
+        showNoDirectMatches: false,
+        showShowOtherResources: false,
+        showViewMoreRecommendations: false,
+        otherRecommendationsLoaded: false,
       };
     },
     computed: {
+      ...mapGetters('currentChannel', ['currentChannel']),
       ...mapGetters('importFromChannels', ['savedSearchesExist']),
+      ...mapGetters(['isAIFeatureEnabled']),
       ...mapState('importFromChannels', ['selected']),
       isBrowsing() {
         return this.$route.name === RouteNames.IMPORT_FROM_CHANNELS_BROWSE;
@@ -135,6 +275,99 @@
           this.searchTerm.trim() !== this.$route.params.searchTerm
         );
       },
+      loadMoreRecommendationsText() {
+        let link = null;
+        let description = null;
+
+        if (!this.recommendationsLoadingError) {
+          if (this.showNoDirectMatches) {
+            link = this.showOtherRecommendationsLink$();
+            description = this.noDirectMatchesMessage$();
+          } else if (this.showViewMoreRecommendations) {
+            link = this.viewMoreLink$();
+            description = null;
+          } else if (this.showShowOtherResources) {
+            link = this.showOtherResourcesLink$();
+            description = this.showOtherResourcesMessage$();
+          }
+        } else {
+          link = this.tryAgainLink$();
+          description = this.problemShowingResourcesMessage$();
+        }
+
+        return {
+          link,
+          description,
+        };
+      },
+      shouldLoadOtherRecommendations() {
+        return (
+          (this.showNoDirectMatches || this.showShowOtherResources) &&
+          !this.otherRecommendationsLoaded
+        );
+      },
+      moreRecommendationsAvailable() {
+        const displayCount = this.displayedRecommendations.length;
+        const totalCount = this.recommendations.length + this.otherRecommendations.length;
+        return displayCount < totalCount;
+      },
+      browseWindowStyle() {
+        return {
+          maxWidth: this.isAIFeatureEnabled ? '1200px' : '800px',
+        };
+      },
+      topicId() {
+        return this.importDestinationFolder?.id;
+      },
+      recommendationsSectionTitle() {
+        return this.resourcesMightBeRelevantTitle$({
+          topic: this.importDestinationTitle,
+        });
+      },
+      topicAncestors() {
+        const ancestors = this.importDestinationAncestors.slice(0, -1);
+        return ancestors.map((ancestor, index) => {
+          return {
+            id: formatUUID4(ancestor.id),
+            title: ancestor.title,
+            description: ancestor.description,
+            language: this.recommendationsLanguage,
+            level: index,
+          };
+        });
+      },
+      embedTopicRequest() {
+        return {
+          topics: [
+            {
+              id: formatUUID4(this.importDestinationFolder.id),
+              title: this.importDestinationFolder.title,
+              description: this.importDestinationFolder.description,
+              language: this.recommendationsLanguage,
+              ancestors: this.topicAncestors,
+            },
+          ],
+          metadata: {
+            channel_id: formatUUID4(this.importDestinationFolder.channel_id),
+          },
+        };
+      },
+      importDestinationFolder() {
+        return this.importDestinationAncestors.slice(-1)[0];
+      },
+      importDestinationTitle() {
+        return this.importDestinationFolder?.title || '';
+      },
+      recommendationsLanguage() {
+        // Find the closest non-(null/empty) language in the ancestral tree
+        for (let i = this.importDestinationAncestors.length - 1; i >= 0; i--) {
+          const ancestor = this.importDestinationAncestors[i];
+          if (ancestor.language) {
+            return ancestor.language;
+          }
+        }
+        return this.currentChannel?.language || '';
+      },
     },
     beforeRouteEnter(to, from, next) {
       next(vm => {
@@ -154,8 +387,17 @@
       }
       next();
     },
+    mounted() {
+      this.searchTerm = this.$route.params.searchTerm || '';
+      this.loadAncestors({ id: this.$route.params.destNodeId }).then(ancestors => {
+        this.importDestinationAncestors = ancestors;
+        this.loadRecommendations(this.recommendationsBelowThreshold);
+      });
+    },
     methods: {
       ...mapActions('clipboard', ['copy']),
+      ...mapActions('contentNode', ['loadAncestors', 'loadPublicContentNode']),
+      ...mapActions('importFromChannels', ['fetchRecommendations']),
       ...mapMutations('importFromChannels', {
         selectNodes: 'SELECT_NODES',
         deselectNodes: 'DESELECT_NODES',
@@ -213,6 +455,98 @@
             throw error;
           });
       }),
+      handleAboutRecommendations() {
+        this.showAboutRecommendations = true;
+      },
+      closeAboutRecommendations() {
+        this.showAboutRecommendations = false;
+      },
+      handleViewMoreRecommendations() {
+        if (!this.recommendationsLoadingError) {
+          const pageSize = this.recommendationsPageSize;
+          const currentIndex = this.recommendationsCurrentIndex;
+          const nextIndex = currentIndex + pageSize;
+          if (this.showViewMoreRecommendations) {
+            this.displayedRecommendations = this.recommendations.slice(0, nextIndex);
+            this.recommendationsCurrentIndex = nextIndex;
+            this.showViewMoreRecommendations = this.moreRecommendationsAvailable;
+            this.showShowOtherResources = !this.showViewMoreRecommendations;
+          } else if (this.shouldLoadOtherRecommendations) {
+            this.loadRecommendations(true);
+          } else {
+            const limit = nextIndex - this.recommendations.length;
+            this.updateDisplayedRecommendations(limit);
+            this.recommendationsCurrentIndex = nextIndex;
+
+            const moreAvailable = this.moreRecommendationsAvailable;
+            this.showNoDirectMatches = this.showNoDirectMatches && moreAvailable;
+            this.showShowOtherResources = this.showShowOtherResources && moreAvailable;
+          }
+        } else {
+          this.loadRecommendations(this.recommendationsBelowThreshold);
+        }
+      },
+      async loadRecommendations(belowThreshold) {
+        if (this.isAIFeatureEnabled) {
+          this.recommendationsLoading = true;
+          this.recommendationsLoadingError = false;
+          try {
+            const data = {
+              ...this.embedTopicRequest,
+              override_threshold: belowThreshold,
+            };
+            const recommendations = await this.fetchRecommendations(data);
+            const recommendedNodes = await this.fetchRecommendedNodes(recommendations);
+            const pageSize = this.recommendationsPageSize;
+            const currentIndex = this.recommendationsCurrentIndex;
+
+            if (belowThreshold) {
+              const nodeIds = new Set(this.recommendations.map(node => node.id));
+              this.otherRecommendations = recommendedNodes.filter(node => !nodeIds.has(node.id));
+              this.updateDisplayedRecommendations(pageSize);
+              this.recommendationsCurrentIndex = currentIndex + pageSize;
+
+              const moreAvailable = this.moreRecommendationsAvailable;
+              this.showNoDirectMatches = this.showNoDirectMatches && moreAvailable;
+              this.showShowOtherResources = this.showShowOtherResources && moreAvailable;
+              this.otherRecommendationsLoaded = true;
+            } else {
+              this.recommendations = recommendedNodes;
+              this.displayedRecommendations = this.recommendations.slice(0, pageSize);
+              this.recommendationsCurrentIndex = pageSize;
+
+              const count = this.recommendations.length;
+              this.showNoDirectMatches = count === 0;
+              this.showViewMoreRecommendations = this.moreRecommendationsAvailable;
+              this.showShowOtherResources = !this.showViewMoreRecommendations;
+            }
+            this.recommendationsBelowThreshold = belowThreshold;
+            this.recommendationsLoading = false;
+          } catch (error) {
+            this.recommendationsLoading = false;
+            this.recommendationsLoadingError = true;
+          }
+        }
+      },
+      async fetchRecommendedNodes(recommendations) {
+        return await Promise.all(
+          recommendations.map(async recommendation => {
+            // loadPublicContentNode is cached, so multiple calls shouldn't be an issue.
+            return await this.loadPublicContentNode({
+              id: recommendation.id,
+              nodeId: recommendation.node_id,
+              rootId: recommendation.main_tree_id,
+              parent: recommendation.parent_id,
+            });
+          })
+        );
+      },
+      updateDisplayedRecommendations(limit) {
+        this.displayedRecommendations = [
+          ...this.recommendations,
+          ...this.otherRecommendations.slice(0, limit),
+        ];
+      },
     },
     $trs: {
       backToBrowseAction: 'Back to browse',
@@ -233,7 +567,7 @@
 <style lang="less" scoped>
 
   .v-form {
-    max-width: 900px;
+    max-width: 100%;
   }
 
   .searchtext /deep/ .v-input__append-outer {
@@ -253,4 +587,8 @@
     z-index: 3;
   }
 
+  .recommendations-loader {
+    margin-top: 24px;
+  }
+
 </style>
diff --git a/contentcuration/contentcuration/frontend/channelEdit/vuex/importFromChannels/actions.js b/contentcuration/contentcuration/frontend/channelEdit/vuex/importFromChannels/actions.js
index f7d7c9f212..363b80277b 100644
--- a/contentcuration/contentcuration/frontend/channelEdit/vuex/importFromChannels/actions.js
+++ b/contentcuration/contentcuration/frontend/channelEdit/vuex/importFromChannels/actions.js
@@ -4,7 +4,7 @@ import client from 'shared/client';
 import urls from 'shared/urls';
 import { ChannelListTypes } from 'shared/constants';
 
-import { Channel, SavedSearch } from 'shared/data/resources';
+import { Channel, Recommendation, SavedSearch } from 'shared/data/resources';
 
 export async function fetchResourceSearchResults(context, params) {
   params = { ...params };
@@ -111,3 +111,7 @@ export function deleteSearch({ commit }, searchId) {
     return searchId;
   });
 }
+
+export function fetchRecommendations(context, params) {
+  return Recommendation.fetchCollection(params);
+}
diff --git a/contentcuration/contentcuration/frontend/shared/data/resources.js b/contentcuration/contentcuration/frontend/shared/data/resources.js
index 3c0c74fbea..57491f0422 100644
--- a/contentcuration/contentcuration/frontend/shared/data/resources.js
+++ b/contentcuration/contentcuration/frontend/shared/data/resources.js
@@ -93,6 +93,20 @@ export function uuid4() {
   return uuidv4().replace(/-/g, '');
 }
 
+export function formatUUID4(uuid) {
+  if (!uuid || typeof uuid !== 'string') {
+    return uuid;
+  }
+  const cleanId = uuid.replace(/-/g, '');
+  if (cleanId.length !== 32) {
+    return uuid;
+  }
+  return `${cleanId.slice(0, 8)}-${cleanId.slice(8, 12)}-${cleanId.slice(12, 16)}-${cleanId.slice(
+    16,
+    20
+  )}-${cleanId.slice(20)}`;
+}
+
 /*
  * Code to allow multiple inheritance in JS
  * modified from https://hacks.mozilla.org/2015/08/es6-in-depth-subclassing/
@@ -2288,3 +2302,12 @@ export const Task = new IndexedDBResource({
     });
   },
 });
+
+export const Recommendation = new APIResource({
+  urlName: 'recommendations',
+  fetchCollection(params) {
+    return client.post(window.Urls.recommendations(), params).then(response => {
+      return response.data || [];
+    });
+  },
+});
diff --git a/contentcuration/contentcuration/frontend/shared/i18n/index.js b/contentcuration/contentcuration/frontend/shared/i18n/index.js
index f6a2ebf17f..d391bd97b8 100644
--- a/contentcuration/contentcuration/frontend/shared/i18n/index.js
+++ b/contentcuration/contentcuration/frontend/shared/i18n/index.js
@@ -129,13 +129,16 @@ class Translator {
    * @param {object} defaultMessages - an object mapping message ids to default messages.
    */
   constructor(nameSpace, defaultMessages) {
-    this.nameSpace = nameSpace;
-    this.defaultMessages = defaultMessages;
+    this._nameSpace = nameSpace;
+    this._defaultMessages = defaultMessages;
+    for (const key in defaultMessages) {
+      this[`${key}$`] = this.$tr.bind(this, key);
+    }
   }
   $tr(messageId, args) {
     return $trWrapper(
-      this.nameSpace,
-      this.defaultMessages,
+      this._nameSpace,
+      this._defaultMessages,
       Vue.prototype.$formatMessage,
       messageId,
       args
diff --git a/contentcuration/contentcuration/frontend/shared/mixins.js b/contentcuration/contentcuration/frontend/shared/mixins.js
index 58cc27b727..75dbf5ec7e 100644
--- a/contentcuration/contentcuration/frontend/shared/mixins.js
+++ b/contentcuration/contentcuration/frontend/shared/mixins.js
@@ -713,8 +713,8 @@ export const metadataTranslationMixin = {
       } else if (nonconformingKeys[camelKey]) {
         key = nonconformingKeys[camelKey];
       } else if (
-        !metadataStrings.defaultMessages[key] &&
-        metadataStrings.defaultMessages[camelKey]
+        !metadataStrings._defaultMessages[key] &&
+        metadataStrings._defaultMessages[camelKey]
       ) {
         key = camelKey;
       }
diff --git a/contentcuration/contentcuration/frontend/shared/strings/searchRecommendationsStrings.js b/contentcuration/contentcuration/frontend/shared/strings/searchRecommendationsStrings.js
new file mode 100644
index 0000000000..85614f7dd8
--- /dev/null
+++ b/contentcuration/contentcuration/frontend/shared/strings/searchRecommendationsStrings.js
@@ -0,0 +1,158 @@
+import { createTranslator } from 'shared/i18n';
+
+export const searchRecommendationsStrings = createTranslator('SearchRecommendationsStrings', {
+  aboutRecommendationsText: {
+    message: 'About Recommendations',
+    context: 'A title that introduces how the recommendation system works',
+  },
+  aboutRecommendationsDescription: {
+    message:
+      'Our recommendation system learns from the titles and descriptions of what you already have in your channel, and uses that to show you other potentially relevant resources across the Kolibri Library.',
+    context: 'A description that explains how the recommendation system works',
+  },
+  aboutRecommendationsFeedbackDescription: {
+    message:
+      'Interacting with these recommendations, whether by using them or marking them as not relevant, will help us improve the quality of the recommendations you see.',
+    context:
+      'A description that explains how the user can help improve the quality of the recommendations',
+  },
+  goToLocationText: {
+    message: 'Go to location',
+    context: 'A label for an action that takes the user to a specific location',
+  },
+  resourcesMightBeRelevantTitle: {
+    message: "These resources might be relevant to '{ topic }'",
+    context:
+      'A title for a list of resources that might be relevant to the user for a currently viewed channel',
+  },
+  viewMoreLink: {
+    message: 'View more',
+    context: 'A label for a link that takes the user to a page with more information',
+  },
+  resourcesInChannelMightBeRelevantTitle: {
+    message: "These resources in { channelName } might be relevant to '{ topic }'",
+    context:
+      'A title for a list of resources that might be relevant to the user for a currently viewed channel based on a specific topic',
+  },
+  showOtherResourcesLink: {
+    message: 'Show other resources anyway',
+    context: 'A label for a link that shows the user other resources that might not be relevant',
+  },
+  showOtherResourcesMessage: {
+    message: "We can show you other resources, but they might not be what you're looking for",
+    context:
+      'A message that explains to the user that there are other resources available, but they might not be relevant to their search',
+  },
+  tryAgainLink: {
+    message: 'Try again',
+    context:
+      'A label for a link that allows the user to try loading recommended resources again after an error',
+  },
+  problemShowingResourcesMessage: {
+    message: 'There was a problem showing these resources',
+    context:
+      'A message that explains to the user that an error was encountered while loading recommended resources',
+  },
+  noDirectMatchesMessage: {
+    message:
+      'No direct matches found, but there are other resources that might be helpful for your curriculum',
+    context:
+      'A message that explains to the user that there are no direct matches to their search, but there are other resources that might be helpful',
+  },
+  showOtherRecommendationsLink: {
+    message: 'Show other recommendations',
+    context: 'A label for a link that shows the user other recommendations',
+  },
+  markAsNotRelevantTooltip: {
+    message: 'Mark as not relevant',
+    context: 'A tooltip that explains to the user that they can mark a resource as not relevant',
+  },
+  feedbackConfirmationMessage: {
+    message: 'Thank you! Your feedback will help us improve your recommendations',
+    context: 'A message that thanks the user for their feedback on the provided recommendations',
+  },
+  giveFeedbackText: {
+    message: 'Give feedback',
+    context: 'A label that describes the act of providing feedback on a recommended resource',
+  },
+  undoAction: {
+    message: 'Undo',
+    context: 'A label for an action that allows the user to undo a previous action',
+  },
+  closeAction: {
+    message: 'Close',
+    context: 'A label for an action that closes a dialog or window',
+  },
+  cancelAction: {
+    message: 'Cancel',
+    context: 'A label for an action that cancels a previous action',
+  },
+  submitAction: {
+    message: 'Submit',
+    context: 'A label for an action that submits a request',
+  },
+  feedbackSubmittedMessage: {
+    message: 'Feedback submitted',
+    context: "A message that confirms that the user's feedback has been submitted successfully",
+  },
+  notRelevantAction: {
+    message: 'Not relevant',
+    context: 'A label for an action that marks a resource as not relevant',
+  },
+  giveFeedbackDescription: {
+    message:
+      'Help us understand why this resource is not relevant for you right now. Check all that apply:',
+    context:
+      'A description that asks the user to provide feedback on why a resource is not relevant',
+  },
+  notSuitableForCurriculumLabel: {
+    message: 'Not suitable for the curriculum I am using',
+    context:
+      "A label to a feedback option that explains that the resource is not suitable for the user's curriculum",
+  },
+  notRelatedToSubjectLabel: {
+    message: 'Not related to the subject or knowledge area I am trying to find resources for',
+    context:
+      "A label to a feedback option that explains that the resource is not related to the user's subject or knowledge area",
+  },
+  notSuitableForCulturalBackgroundLabel: {
+    message: 'Not suitable for the cultural backgrounds and experiences of learners',
+    context:
+      'A label to a feedback option that explains that the resource is not suitable for the cultural backgrounds and experiences of learners',
+  },
+  notSpecificLearningActivityLabel: {
+    message:
+      "Not the type of specific learning activity I'm looking for (e.g. reading text-based material, watching a video, interactive questions, etc.)",
+    context:
+      'A label to a feedback option that explains that the resource is not the type of specific learning activity the user is looking for',
+  },
+  tooAdvancedForLearnersLabel: {
+    message: "Too advanced for the knowledge level of learners I'm looking for",
+    context:
+      'A label to a feedback option that explains that the resource is too advanced for the knowledge level of learners',
+  },
+  tooBasicForLearnersLabel: {
+    message: "Too basic for the knowledge level of learners I'm looking for",
+    context:
+      'A label to a feedback option that explains that the resource is too basic for the knowledge level of learners',
+  },
+  resourceNotWellMadeLabel: {
+    message: "The resource doesn't look or sound well-made enough for use",
+    context: 'A label to a feedback option that explains that the resource is not well-made',
+  },
+  alreadyUsedResourceLabel: {
+    message: 'I already used this resource in my channel',
+    context:
+      'A label to a feedback option that explains that the user has already used the resource in their channel',
+  },
+  otherLabel: {
+    message: 'Other',
+    context:
+      'A label to a feedback option that explains that the resource is not relevant for another reason',
+  },
+  enterFeedbackLabel: {
+    message: 'Enter your feedback',
+    context:
+      'A label to an input that asks the user to enter their specific reason for marking a resource as not relevant',
+  },
+});
diff --git a/contentcuration/contentcuration/not_production_settings.py b/contentcuration/contentcuration/not_production_settings.py
index e98410433d..8d3bcd3e12 100644
--- a/contentcuration/contentcuration/not_production_settings.py
+++ b/contentcuration/contentcuration/not_production_settings.py
@@ -19,3 +19,6 @@
 )
 
 AWS_AUTO_CREATE_BUCKET = True
+
+# Use local instance for curriculum automation for development
+CURRICULUM_AUTOMATION_API_URL = "http://localhost:8000"
diff --git a/contentcuration/contentcuration/settings.py b/contentcuration/contentcuration/settings.py
index ef4930fa08..05acbf02e5 100644
--- a/contentcuration/contentcuration/settings.py
+++ b/contentcuration/contentcuration/settings.py
@@ -443,3 +443,6 @@ def gettext(s):
 DEFAULT_AUTO_FIELD = "django.db.models.AutoField"
 
 LANGUAGE_COOKIE_AGE = 3600 * 24 * 14
+
+# Curriculum Automation Settings
+CURRICULUM_AUTOMATION_API_URL = os.getenv("CURRICULUM_AUTOMATION_API_URL")
diff --git a/contentcuration/contentcuration/tests/base.py b/contentcuration/contentcuration/tests/base.py
index 3820d308e7..c9ccdecded 100644
--- a/contentcuration/contentcuration/tests/base.py
+++ b/contentcuration/contentcuration/tests/base.py
@@ -120,6 +120,9 @@ class StudioAPITestCase(APITestCase, BucketTestMixin):
     def setUpClass(cls):
         super(StudioAPITestCase, cls).setUpClass()
         call_command("loadconstants")
+        cls.admin_user = User.objects.create_superuser(
+            "big_shot", "bigshot@reallybigcompany.com", "password"
+        )
 
     def setUp(self):
         if not self.persist_bucket:
diff --git a/contentcuration/contentcuration/tests/utils/test_recommendations.py b/contentcuration/contentcuration/tests/utils/test_recommendations.py
index 92c730cded..d286525160 100644
--- a/contentcuration/contentcuration/tests/utils/test_recommendations.py
+++ b/contentcuration/contentcuration/tests/utils/test_recommendations.py
@@ -9,6 +9,7 @@
 from mock import MagicMock
 from mock import patch
 
+from contentcuration.models import Channel
 from contentcuration.models import ContentNode
 from contentcuration.tests import testdata
 from contentcuration.tests.base import StudioTestCase
@@ -28,21 +29,43 @@ def test_backend_initialization(self):
 
 class RecommendationsAdapterTestCase(StudioTestCase):
 
+    @classmethod
+    def setUpClass(cls):
+        super(RecommendationsAdapterTestCase, cls).setUpClass()
+
+        cls.channel_1 = Channel.objects.create(
+            id='1234567890abcdef1234567890abcdef',
+            name='Channel 1',
+            actor_id=cls.admin_user.id
+        )
+        cls.channel_2 = Channel.objects.create(
+            id='abcdef1234567890abcdef1234567890',
+            name='Channel 2',
+            actor_id=cls.admin_user.id
+        )
+
     @classmethod
     def setUpTestData(cls):
         cls.adapter = RecommendationsAdapter(MagicMock())
-        cls.topic = {
-            'id': 'topic_id',
-            'title': 'topic_title',
-            'description': 'topic_description',
-            'language': 'en',
-            'ancestors': [
+        cls.request_data = {
+            'topics': [
                 {
-                    'id': 'ancestor_id',
-                    'title': 'ancestor_title',
-                    'description': 'ancestor_description',
+                    'id': 'topic_id',
+                    'title': 'topic_title',
+                    'description': 'topic_description',
+                    'language': 'en',
+                    'ancestors': [
+                        {
+                            'id': 'ancestor_id',
+                            'title': 'ancestor_title',
+                            'description': 'ancestor_description',
+                        }
+                    ]
                 }
-            ]
+            ],
+            'metadata': {
+                'channel_id': '00000000000000000000000000000010'
+            }
         }
         cls.channel_id = 'test_channel_id'
         cls.resources = [MagicMock(spec=ContentNode)]
@@ -52,33 +75,38 @@ def setUpTestData(cls):
             url='http://test.com',
             path='/test/path',
             params={'override_threshold': False},
-            json=cls.topic
+            json=cls.request_data
         )
-        cls.api_response = BackendResponse(data=[
-            {'contentnode_id': '1234567890abcdef1234567890abcdef', 'rank': 0.9},
-            {'contentnode_id': 'abcdef1234567890abcdef1234567890', 'rank': 0.8},
-            {'contentnode_id': '00000000000000000000000000000003', 'rank': 0.8},
-            {'contentnode_id': '00000000000000000000000000000005', 'rank': 0.8},
-        ])
-
-        cls.public_content_node_1 = PublicContentNode.objects.create(
-            id=uuid.UUID('1234567890abcdef1234567890abcdef'),
+        cls.api_response = BackendResponse(data={
+            'topics': [
+                {'id': 'abcdef1234567890abcdef1234567890', 'recommendations': [
+                    {
+                        'id': 'abcdef1234567890abcdef1234567890',
+                        'channel_id': 'abcdef1234567890abcdef1234567890',
+                        'rank': 8
+                    }
+                ]},
+                {'id': '1234567890abcdef1234567890abcdef', 'recommendations': [
+                    {
+                        'id': '1234567890abcdef1234567890abcdef',
+                        'channel_id': '1234567890abcdef1234567890abcdef',
+                        'rank': 9
+                    }
+                ]}
+            ]
+        })
+
+        PublicContentNode.objects.create(
+            id='1234567890abcdef1234567890abcdef',
             title='Public Content Node 1',
-            content_id=uuid.uuid4(),
-            channel_id=uuid.UUID('ddec09d74e834241a580c480ee37879c'),
+            content_id=uuid.uuid4().hex,
+            channel_id='ddec09d74e834241a580c480ee37879c',
         )
-        cls.public_content_node_2 = PublicContentNode.objects.create(
-            id=uuid.UUID('abcdef1234567890abcdef1234567890'),
+        PublicContentNode.objects.create(
+            id='abcdef1234567890abcdef1234567890',
             title='Public Content Node 2',
-            content_id=uuid.uuid4(),
-            channel_id=uuid.UUID('84fcaec1e0514b62899d7f436384c401'),
-        )
-
-        cls.cache = RecommendationsCache.objects.create(
-            request_hash=cls.adapter._generate_request_hash(cls.request),
-            contentnode=cls.public_content_node_1,
-            rank=1.0,
-            override_threshold=False
+            content_id=uuid.uuid4().hex,
+            channel_id='84fcaec1e0514b62899d7f436384c401',
         )
 
     def assert_backend_call(self, mock_response_exists, response_exists_value, connect_value,
@@ -133,14 +161,13 @@ def test_generate_embeddings_failure(self, mock_response_exists):
         self.assertIsNotNone(response.error)
 
     def test_response_exists(self):
-        response = self.adapter.response_exists(self.request)
-        public_content_node_id = str(self.public_content_node_1.id).replace('-', '')
+        cached = self.adapter.cache_embeddings_request(self.request, self.api_response)
+        self.assertTrue(cached)
 
+        response = self.adapter.response_exists(self.request)
         self.assertIsNotNone(response)
         self.assertIsInstance(response, EmbeddingsResponse)
-        self.assertEqual(len(response.data), 1)
-        self.assertEqual(response.data[0]['contentnode_id'], public_content_node_id)
-        self.assertEqual(response.data[0]['rank'], 1.0)
+        self.assertDictEqual(response.data, self.api_response.data)
 
     def test_response_does_not_exist(self):
         new_request = EmbedTopicsRequest(
@@ -148,7 +175,7 @@ def test_response_does_not_exist(self):
             url='http://test.com',
             path='/test/path',
             params={'override_threshold': True},
-            json={'topic': 'new_test_topic'}
+            json=[{'id': 'topic_id', 'title': 'topic_title', 'description': 'topic_description'}]
         )
         response = self.adapter.response_exists(new_request)
         self.assertIsNone(response)
@@ -156,36 +183,67 @@ def test_response_does_not_exist(self):
     def cache_request_test_helper(self, request_json, response_data, expected_count):
         new_request = copy.deepcopy(self.request)
         new_request.json = request_json
-        response_copy = copy.deepcopy(self.api_response)
-        response_copy.data = response_data
 
-        result = self.adapter.cache_embeddings_request(new_request, response_copy)
+        result = self.adapter.cache_embeddings_request(new_request, response_data)
         self.assertTrue(result)
 
         cached_items = RecommendationsCache.objects.filter(
             request_hash=self.adapter._generate_request_hash(new_request)
         )
-        print(list(cached_items.values('request_hash', 'contentnode', 'rank', 'override_threshold')))
         self.assertEqual(cached_items.count(), expected_count)
 
     def test_cache_embeddings_request_success(self):
-        self.cache_request_test_helper({'topic': 'new_test_topic_1'}, self.api_response.data, 2)
+        request_json = {
+            'topics': [
+                {'id': 'topic_id', 'title': 'topic_title', 'description': 'topic_description'}
+            ],
+            'metadata': {}
+        }
+        self.cache_request_test_helper(request_json, self.api_response, 2)
 
     def test_cache_embeddings_request_empty_data(self):
-        self.cache_request_test_helper({'topic': 'new_test_topic_2'}, [], 0)
+        request_json = {
+            'topics': [
+                {'id': 'topic_id', 'title': 'topic_title', 'description': 'topic_description'}
+            ],
+            'metadata': {}
+        }
+        self.cache_request_test_helper(request_json, {}, 0)
 
     def test_cache_embeddings_request_ignore_duplicates(self):
-        duplicate_data = [
-            {'contentnode_id': '1234567890abcdef1234567890abcdef', 'rank': 0.9},
-            {'contentnode_id': '1234567890abcdef1234567890abcdef', 'rank': 0.9}
-        ]
-        self.cache_request_test_helper({'topic': 'new_test_topic_3'}, duplicate_data, 1)
+        request_json = {
+            'topics': [
+                {'id': 'topic_id', 'title': 'topic_title', 'description': 'topic_description'}
+            ],
+            'metadata': {}
+        }
+        duplicate_data = BackendResponse(data={
+            'topics': [
+                {'id': '1234567890abcdef1234567890abcdef', 'recommendations': [
+                    {
+                        'id': '1234567890abcdef1234567890abcdef',
+                        'channel_id': '1234567890abcdef1234567890abcdef',
+                        'rank': 1
+                    }
+                ]},
+                {'id': '1234567890abcdef1234567890abcdef', 'recommendations': [
+                    {
+                        'id': '1234567890abcdef1234567890abcdef',
+                        'channel_id': '1234567890abcdef1234567890abcdef',
+                        'rank': 2
+                    }
+                ]}
+            ]
+        })
+        self.cache_request_test_helper(request_json, duplicate_data, 1)
 
     def test_cache_embeddings_request_invalid_data(self):
-        invalid_data = [
-            {'contentnode_id': '1234567890abcdef1234567890abcdee', 'rank': 0.6}
-        ]
-        self.cache_request_test_helper({'topic': 'new_test_topic_4'}, invalid_data, 0)
+        invalid_data = BackendResponse(data={
+            'response': [
+                {'node_id': '1234567890abcdef1234567890abcdee', 'rank': 0.6}
+            ]
+        })
+        self.cache_request_test_helper([{'topic': 'new_test_topic_4'}], invalid_data, 0)
 
     @patch('contentcuration.utils.recommendations.RecommendationsAdapter.cache_embeddings_request')
     @patch('contentcuration.utils.recommendations.RecommendationsAdapter.generate_embeddings')
@@ -198,27 +256,47 @@ def test_get_recommendations_success(self, mock_embed_topics_request, mock_respo
         channel.save()
 
         public_node_1 = PublicContentNode.objects.create(
-            id=uuid.UUID('00000000000000000000000000000003'),
+            id='00000000000000000000000000000003',
             title='Video 1',
-            content_id=uuid.uuid4(),
-            channel_id=uuid.UUID(channel.id),
+            content_id=uuid.uuid4().hex,
+            channel_id=channel.id,
         )
         public_node_2 = PublicContentNode.objects.create(
-            id=uuid.UUID('00000000000000000000000000000005'),
+            id='00000000000000000000000000000005',
             title='Exercise 1',
-            content_id=uuid.uuid4(),
-            channel_id=uuid.UUID(channel.id),
+            content_id=uuid.uuid4().hex,
+            channel_id=channel.id,
         )
 
+        response_data = {
+            'topics': [
+                {'id': '00000000000000000000000000000003', 'recommendations': [
+                    {
+                        'id': '00000000000000000000000000000003',
+                        'channel_id': '00000000000000000000000000000003',
+                        'rank': 10
+                    }
+                ]},
+                {'id': '00000000000000000000000000000005', 'recommendations': [
+                    {
+                        'id': '00000000000000000000000000000005',
+                        'channel_id': '00000000000000000000000000000005',
+                        'rank': 11
+                    }
+                ]}
+            ]
+        }
+
         mock_response_exists.return_value = None
         mock_response = MagicMock(spec=EmbeddingsResponse)
-        mock_response.data = copy.deepcopy(self.api_response.data)
+        mock_response.data = response_data
         mock_response.error = None
+        mock_response.get = lambda key, default=None: getattr(mock_response, key, default)
         mock_generate_embeddings.return_value = mock_response
 
-        response = self.adapter.get_recommendations(self.topic)
+        response = self.adapter.get_recommendations(self.request_data)
         results = list(response.results)
-        expected_node_ids = [public_node_1.id.hex, public_node_2.id.hex]
+        expected_node_ids = [public_node_1.id, public_node_2.id]
         actual_node_ids = [result["node_id"] for result in results]
 
         mock_response_exists.assert_called_once()
@@ -227,22 +305,22 @@ def test_get_recommendations_success(self, mock_embed_topics_request, mock_respo
         self.assertListEqual(expected_node_ids, actual_node_ids)
         self.assertEqual(len(results), 2)
 
-    @patch('contentcuration.utils.recommendations.RecommendationsAdapter._extract_data')
+    @patch('contentcuration.utils.recommendations.RecommendationsAdapter._flatten_response')
     @patch('contentcuration.utils.recommendations.RecommendationsAdapter.response_exists')
     @patch('contentcuration.utils.recommendations.EmbedTopicsRequest')
     def test_get_recommendations_failure(self, mock_embed_topics_request, mock_response_exists,
-                                         mock_extract_data):
+                                         mock_flatten_response):
         mock_request_instance = MagicMock(spec=EmbedTopicsRequest)
         mock_embed_topics_request.return_value = mock_request_instance
 
         self.assert_backend_call(mock_response_exists, None, False, None,
-                                 self.adapter.get_recommendations, self.topic)
+                                 self.adapter.get_recommendations, self.request_data)
 
-    @patch('contentcuration.utils.recommendations.RecommendationsAdapter._extract_data')
+    @patch('contentcuration.utils.recommendations.RecommendationsAdapter._flatten_response')
     @patch('contentcuration.utils.recommendations.RecommendationsAdapter.response_exists')
     @patch('contentcuration.utils.recommendations.EmbedContentRequest')
     def test_embed_content_success(self, mock_embed_topics_request, mock_response_exists,
-                                   mock_extract_data):
+                                   mock_flatten_response):
         mock_response = MagicMock(spec=EmbeddingsResponse)
         mock_response.error = None
         response = self.assert_backend_call(mock_response_exists, None, True, mock_response,
diff --git a/contentcuration/contentcuration/tests/viewsets/test_recommendations.py b/contentcuration/contentcuration/tests/viewsets/test_recommendations.py
new file mode 100644
index 0000000000..e23b4ad17a
--- /dev/null
+++ b/contentcuration/contentcuration/tests/viewsets/test_recommendations.py
@@ -0,0 +1,126 @@
+from django.urls import reverse
+from mock import patch
+
+from contentcuration.tests.base import StudioAPITestCase
+
+
+class CRUDTestCase(StudioAPITestCase):
+
+    @property
+    def topics(self):
+        return {
+            "topics": [
+                {
+                    "id": "00000000000000000000000000000001",
+                    "title": "Target topic",
+                    "description": "Target description",
+                    "language": "en",
+                    "ancestors": [
+                        {
+                            "id": "00000000000000000000000000000001",
+                            "title": "Parent topic",
+                            "description": "Parent description",
+                            "language": "en",
+                            "level": 1,
+                        }
+                    ],
+                }
+            ],
+            "metadata": {
+                "channel_id": "000",
+                "channel_title": "Channel title",
+                "some_additional_field": "some_random_value",
+            },
+        }
+
+    @property
+    def recommendations_list(self):
+        return [
+            {
+                "id": "00000000000000000000000000000001",
+                "node_id": "00000000000000000000000000000002",
+                "main_tree_id": "1",
+                "parent_id": "00000000000000000000000000000003",
+            },
+            {
+                "id": "00000000000000000000000000000004",
+                "node_id": "00000000000000000000000000000005",
+                "main_tree_id": "2",
+                "parent_id": "00000000000000000000000000000006",
+            }
+        ]
+
+    def setUp(self):
+        super(CRUDTestCase, self).setUp()
+
+    @patch("contentcuration.utils.automation_manager.AutomationManager.load_recommendations")
+    def test_recommend_success(self, mock_load_recommendations):
+        self.client.force_authenticate(user=self.admin_user)
+        mock_load_recommendations.return_value = self.recommendations_list
+
+        response = self.client.post(reverse("recommendations"), data=self.topics,
+                                    format="json")
+
+        self.assertEqual(response.status_code, 200, response.content)
+        self.assertEqual(response.json(), self.recommendations_list)
+
+    def test_recommend_invalid_data_empty_data(self):
+        self.client.force_authenticate(user=self.admin_user)
+
+        invalid_data = {}
+        response = self.client.post(reverse("recommendations"), data=invalid_data,
+                                    format="json")
+        self.assertEqual(response.status_code, 400)
+        self.assertIn("topics", response.json()['error'])
+
+    def test_recommend_invalid_data_wrong_topic_data(self):
+        self.client.force_authenticate(user=self.admin_user)
+
+        invalid_data = {'topics': [{'ramdon_field': "random_value"}]}
+        response = self.client.post(reverse("recommendations"), data=invalid_data,
+                                    format="json")
+        self.assertEqual(response.status_code, 400)
+        self.assertIn("ramdon_field", response.json()['error'])
+
+    @patch("contentcuration.utils.automation_manager.AutomationManager.load_recommendations")
+    def test_recommendation_invalid_data_formats(self, mock_load_recommendations):
+        self.client.force_authenticate(user=self.admin_user)
+
+        error_message = "Invalid topic format"
+        mock_load_recommendations.side_effect = ValueError(error_message)
+
+        response = self.client.post(reverse("recommendations"), data=self.topics,
+                                    format="json")
+
+        self.assertEqual(response.status_code, 400)
+        self.assertEqual(response.json(), {"error": error_message})
+        mock_load_recommendations.assert_called_once()
+
+    @patch("contentcuration.utils.automation_manager.AutomationManager.load_recommendations")
+    def test_recommendation_service_unavailable(self, mock_load_recommendations):
+        self.client.force_authenticate(user=self.admin_user)
+
+        error_message = "Connection error"
+        mock_load_recommendations.side_effect = ConnectionError(error_message)
+
+        response = self.client.post(reverse("recommendations"), data=self.topics,
+                                    format="json")
+
+        self.assertEqual(response.status_code, 503)
+        self.assertEqual(response.json(),
+                         {"error": f"Recommendation service unavailable: {error_message}"})
+        mock_load_recommendations.assert_called_once()
+
+    @patch("contentcuration.utils.automation_manager.AutomationManager.load_recommendations")
+    def test_recommendation_generic_error(self, mock_load_recommendations):
+        self.client.force_authenticate(user=self.admin_user)
+
+        error_message = "Unexpected internal error"
+        mock_load_recommendations.side_effect = RuntimeError(error_message)
+        response = self.client.post(reverse("recommendations"), data=self.topics,
+                                    format="json")
+
+        self.assertEqual(response.status_code, 500)
+        self.assertEqual(response.content.decode(),
+                         f"Unable to load recommendations: {error_message}")
+        mock_load_recommendations.assert_called_once()
diff --git a/contentcuration/contentcuration/urls.py b/contentcuration/contentcuration/urls.py
index 8047ca0bf4..b4764e23ed 100644
--- a/contentcuration/contentcuration/urls.py
+++ b/contentcuration/contentcuration/urls.py
@@ -42,6 +42,7 @@
 from contentcuration.viewsets.feedback import FlagFeedbackEventViewSet
 from contentcuration.viewsets.file import FileViewSet
 from contentcuration.viewsets.invitation import InvitationViewSet
+from contentcuration.viewsets.recommendation import RecommendationView
 from contentcuration.viewsets.sync.endpoint import SyncView
 from contentcuration.viewsets.user import AdminUserViewSet
 from contentcuration.viewsets.user import ChannelUserViewSet
@@ -82,6 +83,7 @@ def get_redirect_url(self, *args, **kwargs):
     re_path(r'^api/probers/task_queue_status', views.task_queue_status, name='task_queue_status'),
     re_path(r'^api/probers/unapplied_changes_status', views.unapplied_changes_status, name='unapplied_changes_status'),
     re_path(r'^api/sync/$', SyncView.as_view(), name="sync"),
+    re_path(r'^api/recommendations/$', RecommendationView.as_view(), name="recommendations"),
 ]
 
 # if activated, turn on django prometheus urls
diff --git a/contentcuration/contentcuration/utils/automation_manager.py b/contentcuration/contentcuration/utils/automation_manager.py
index fbc76a0b5e..cda43aeb37 100644
--- a/contentcuration/contentcuration/utils/automation_manager.py
+++ b/contentcuration/contentcuration/utils/automation_manager.py
@@ -27,14 +27,18 @@ def generate_embeddings(self, channel_id: str, nodes: List[Union[ContentNode, Pu
         """
         return self.adapter.embed_content(channel_id, nodes)
 
-    def load_recommendations(self, topic: Dict[str, Any], override_threshold=False):
+    def load_recommendations(self, request_data: Dict[str, Any], override_threshold=False):
         """
-        Loads recommendations for the given topic.
+        Loads recommendations for the given topic(s).
 
-        :param topic: A dictionary containing the topic for which to get recommendations.
+        :param request_data: Topic information necessary for recommendations retrieval. See
+        https://github.com/learningequality/le-utils/blob/main/spec/schema-embed_topics_request.json
         :param override_threshold: A boolean flag to override the recommendation threshold.
 
-        :return: A list of recommendations for the given topic.
+        :return: A dictionary containing a list of recommendations for the given topic(s).
         """
-        self.adapter.get_recommendations(topic=topic, override_threshold=override_threshold)
-        return []
+        recommendations = []
+        response = self.adapter.get_recommendations(request_data, override_threshold)
+        if hasattr(response, "results") and isinstance(response.results, list):
+            recommendations = response.results
+        return recommendations
diff --git a/contentcuration/contentcuration/utils/recommendations.py b/contentcuration/contentcuration/utils/recommendations.py
index 20c6cb05f2..ed70b7b98c 100644
--- a/contentcuration/contentcuration/utils/recommendations.py
+++ b/contentcuration/contentcuration/utils/recommendations.py
@@ -14,6 +14,7 @@
 from automation.utils.appnexus.base import BackendFactory
 from automation.utils.appnexus.base import BackendRequest
 from automation.utils.appnexus.base import BackendResponse
+from django.conf import settings
 from django.db.models import Exists
 from django.db.models import F
 from django.db.models import OuterRef
@@ -72,8 +73,10 @@ def __init__(self, **kwargs):
 
 class RecommendationsBackendFactory(BackendFactory):
     def create_backend(self) -> Backend:
-        # Return backend based on some setting.
-        return super().create_backend()
+        backend = Recommendations()
+        backend.base_url = settings.CURRICULUM_AUTOMATION_API_URL
+        backend.connect_endpoint = "/connect"
+        return backend
 
 
 class RecommendationsAdapter(Adapter):
@@ -93,6 +96,9 @@ def generate_embeddings(self, request: EmbeddingsRequest) -> EmbeddingsResponse:
             response = self.backend.make_request(request)
         except Exception as e:
             logging.exception(e)
+            if isinstance(e, errors.ConnectionError):
+                # Force connect check in next generate embeddings call
+                self.backend._connected = False
             response = EmbeddingsResponse(error=e)
 
         return response
@@ -111,9 +117,9 @@ def response_exists(self, request) -> Union[EmbeddingsResponse, None]:
             data = list(RecommendationsCache.objects
                         .filter(request_hash=request_hash, override_threshold=override_threshold)
                         .order_by('override_threshold', 'rank')
-                        .values('contentnode_id', 'rank'))
+                        .values('topic_id', 'rank', 'channel_id', node_id=F('contentnode_id')))
             if len(data) > 0:
-                return EmbeddingsResponse(data=data)
+                return EmbeddingsResponse(data=self._unflatten_response(data))
             else:
                 return None
         except Exception as e:
@@ -154,14 +160,16 @@ def cache_embeddings_request(self, request: BackendRequest, response: BackendRes
         """
 
         try:
-            nodes = self._extract_data(response)
-            valid_nodes = self._validate_nodes(nodes)
+            recommended_nodes = self._flatten_response(response)
+            valid_nodes = self._validate_nodes(recommended_nodes)
             request_hash = self._generate_request_hash(request)
             override_threshold = self._extract_override_threshold(request)
             new_cache = [
                 RecommendationsCache(
                     request_hash=request_hash,
-                    contentnode_id=node['contentnode_id'],
+                    topic_id=node['topic_id'],
+                    contentnode_id=node['node_id'],
+                    channel_id=node['channel_id'],
                     rank=node['rank'],
                     override_threshold=override_threshold,
                 ) for node in valid_nodes
@@ -182,12 +190,12 @@ def _extract_override_threshold(self, request) -> bool:
         """
         return request.params.get('override_threshold', False) if request.params else False
 
-    def get_recommendations(self, topic: Dict[str, Any],
+    def get_recommendations(self, request_data: Dict[str, Any],
                             override_threshold=False) -> RecommendationsResponse:
         """
-        Get recommendations for the given topic.
+        Get recommendations for the given topic(s).
 
-        :param topic: A dictionary containing the topic for which to get recommendations. See
+        :param request_data: Topic information necessary for recommendations retrieval. See
         https://github.com/learningequality/le-utils/blob/main/spec/schema-embed_topics_request.json
         :param override_threshold: A boolean flag to override the recommendation threshold.
         :return: The recommendations for the given topic. :rtype: RecommendationsResponse
@@ -195,8 +203,10 @@ def get_recommendations(self, topic: Dict[str, Any],
 
         recommendations = []
         request = EmbedTopicsRequest(
+            method='POST',
+            path='/recommend',
             params={'override_threshold': override_threshold},
-            json=topic,
+            json=request_data,
         )
 
         cached_response = self.response_exists(request)
@@ -204,14 +214,19 @@ def get_recommendations(self, topic: Dict[str, Any],
             response = cached_response
         else:
             response = self.generate_embeddings(request=request)
-            if not response.error:
+            if not getattr(response, 'error', None):
                 self.cache_embeddings_request(request, response)
-
-        nodes = self._extract_data(response)
-        if len(nodes) > 0:
-            node_ids = self._extract_node_ids(nodes)
+            else:
+                exception = getattr(response, 'error')
+                if isinstance(exception, Exception):
+                    raise exception
+                else:
+                    raise Exception(f"Error generating recommendations: {exception}")
+
+        recommended_nodes = self._flatten_response(response)
+        if len(recommended_nodes) > 0:
+            node_ids = self._extract_node_ids(recommended_nodes)
             cast_node_ids = [uuid.UUID(node_id) for node_id in node_ids]
-
             channel_cte = With(
                 Channel.objects.annotate(
                     channel_id=self._cast_to_uuid(F('id'))
@@ -240,28 +255,118 @@ def get_recommendations(self, topic: Dict[str, Any],
                 'parent_id',
             )
 
-        return RecommendationsResponse(results=recommendations)
+            # Add the corresponding channel_id to the recommendations
+            node_to_channel = {node['node_id']: node['channel_id'] for node in recommended_nodes}
+            for recommendation in recommendations:
+                recommendation['channel_id'] = node_to_channel.get(recommendation['node_id'])
 
-    def _extract_data(self, response: BackendResponse) -> List[Dict[str, Any]]:
-        """
-        Extracts the data from the given response.
+        return RecommendationsResponse(results=list(recommendations))
 
-        The response is of the form:
+    def _flatten_response(self, response: BackendResponse) -> List[Dict[str, Any]]:
+        """
+        Flattens the nested structure of recommendations.
 
+        The input format is of the form below. Some fields are marked optional as they are returned
+        by the API but are not required to make recommendations:
         {
-            "data": [
+            "topics": [
                 {
-                    "contentnode_id": "<some node id>",
-                    "rank": 0.7
+                    "id": <topic_id>,
+                    "recommendations": [
+                        {
+                            "id": <node_id>,
+                            "channel_id": <channel_id>,
+                            "title": "", (Optional)
+                            "description": "", (Optional)
+                            "similarity": <similarity>, (Optional)
+                            "rank": <rank>
+                        }
+                    ]
                 }
             ]
         }
 
-        :param response: A response from which to extract the data.
-        :return: The extracted data.
+        The output format is a flat list of dictionaries with keys:
+        - topic_id
+        - node_id
+        - channel_id
+        - rank
+
+        :param response: The recommendations response to be flattened.
+        :return: The flattened list of recommendations by topic.
         :rtype: List[Dict[str, Any]]
         """
-        return response.data if response.data else []
+        flattened_response = []
+        if hasattr(response, 'data') and isinstance(response.data, dict):
+            topics = response.data.get('topics', [])
+            for topic in topics:
+                topic_id = topic.get('id')
+                recommendations = topic.get('recommendations', [])
+                for recommendation in recommendations:
+                    flattened_response.append({
+                        'topic_id': topic_id,
+                        'node_id': recommendation.get('id'),
+                        'channel_id': recommendation.get('channel_id'),
+                        'rank': recommendation.get('rank'),
+                    })
+
+        return flattened_response
+
+    def _unflatten_response(self, flattened_data: List[Dict[str, Any]]) -> Dict[str, Any]:
+        """
+        Transforms a flat list of recommendations back into the nested structure.
+
+        Input format is a list of dictionaries with keys:
+        - topic_id
+        - node_id
+        - channel_id
+        - rank
+
+        Output format matches the original API response. Some fields are marked optional as they
+        are not required to make recommendations so are omitted in the final response:
+        {
+          "topics": [
+            {
+              "id": <topic_id>,
+              "recommendations": [
+                {
+                  "id": <node_id>,
+                  "channel_id": <channel_id>,
+                  "title": "", (Optional)
+                  "description": "", (Optional)
+                  "similarity": <similarity>, (Optional)
+                  "rank": <rank>
+                }
+              ]
+            }
+          ]
+        }
+
+        :param flattened_data: The flat list of recommendations.
+        :return: The nested structure of topics with their recommendations.
+        :rtype: Dict[str, Any]
+        """
+        topics_dict = {}
+
+        for item in flattened_data:
+            topic_id = item.get('topic_id')
+
+            if topic_id not in topics_dict:
+                topics_dict[topic_id] = {
+                    "id": topic_id.hex if isinstance(topic_id, uuid.UUID) else topic_id,
+                    "recommendations": []
+                }
+
+            node_id = item.get('node_id')
+            channel_id = item.get('channel_id')
+            topics_dict[topic_id]["recommendations"].append({
+                "id": node_id.hex if isinstance(node_id, uuid.UUID) else node_id,
+                "channel_id": channel_id.hex if isinstance(channel_id, uuid.UUID) else channel_id,
+                "rank": item.get('rank')
+            })
+        return {
+            "topics": list(topics_dict.values())
+        }
 
     def _validate_nodes(self, nodes: List[Dict[str, Any]]) -> List[Dict[str, Any]]:
         """
@@ -274,7 +379,7 @@ def _validate_nodes(self, nodes: List[Dict[str, Any]]) -> List[Dict[str, Any]]:
         node_ids = self._extract_node_ids(nodes)
         existing_node_ids = set(
             PublicContentNode.objects.filter(id__in=node_ids).values_list('id', flat=True))
-        return [node for node in nodes if node['contentnode_id'] in existing_node_ids]
+        return [node for node in nodes if node.get('node_id') in existing_node_ids]
 
     def _extract_node_ids(self, nodes: List[Dict[str, Any]]) -> List[str]:
         """
@@ -284,7 +389,7 @@ def _extract_node_ids(self, nodes: List[Dict[str, Any]]) -> List[str]:
         :return: A list of node IDs.
         :rtype: List[str]
         """
-        return [node['contentnode_id'] for node in nodes]
+        return [node.get('node_id') for node in nodes]
 
     def _cast_to_uuid(self, field):
         """
@@ -326,6 +431,9 @@ def embed_content(self, channel_id: str,
                 self.backend.make_request(request)
             except Exception as e:
                 logging.exception(e)
+                if isinstance(e, errors.ConnectionError):
+                    # Force connect check in next embed content call
+                    self.backend._connected = False
 
         return True
 
@@ -413,9 +521,14 @@ def _format_file_data(self, file) -> Dict[str, Any]:
 
 
 class Recommendations(Backend):
+    def __init__(self):
+        super().__init__()
+        self._connected = False
 
     def connect(self) -> bool:
-        return super().connect()
+        if not self._connected:
+            self._connected = super().connect()
+        return self._connected
 
     def make_request(self, request) -> Union[EmbeddingsResponse, RecommendationsResponse]:
         return super().make_request(request)
diff --git a/contentcuration/contentcuration/viewsets/recommendation.py b/contentcuration/contentcuration/viewsets/recommendation.py
new file mode 100644
index 0000000000..eb2fef8a35
--- /dev/null
+++ b/contentcuration/contentcuration/viewsets/recommendation.py
@@ -0,0 +1,41 @@
+from http import HTTPStatus
+
+import jsonschema
+from django.http import HttpResponseServerError
+from django.http import JsonResponse
+from le_utils.validators import embed_topics_request
+from rest_framework.permissions import IsAuthenticated
+from rest_framework.views import APIView
+
+from contentcuration.utils.automation_manager import AutomationManager
+from contentcuration.viewsets.user import IsAIFeatureEnabledForUser
+
+
+class RecommendationView(APIView):
+
+    permission_classes = [
+        IsAuthenticated,
+        IsAIFeatureEnabledForUser,
+    ]
+    manager = AutomationManager()
+
+    def post(self, request):
+        try:
+            request_data = request.data
+            # Remove and store override_threshold as it isn't defined in the schema
+            override_threshold = request_data.pop('override_threshold', False)
+
+            embed_topics_request.validate(request_data)
+        except jsonschema.ValidationError as e:
+            return JsonResponse({"error": f"Required fields missing: {str(e)}"}, status=HTTPStatus.BAD_REQUEST)
+
+        try:
+            recommendations = self.manager.load_recommendations(request_data, override_threshold)
+            return JsonResponse(data=recommendations, safe=False)
+        except (ValueError, TypeError) as e:
+            return JsonResponse({"error": str(e)}, status=HTTPStatus.BAD_REQUEST)
+        except ConnectionError as e:
+            return JsonResponse({"error": f"Recommendation service unavailable: {str(e)}"},
+                                status=HTTPStatus.SERVICE_UNAVAILABLE)
+        except Exception as e:
+            return HttpResponseServerError(f"Unable to load recommendations: {str(e)}")
diff --git a/contentcuration/contentcuration/viewsets/user.py b/contentcuration/contentcuration/viewsets/user.py
index 766e3097a0..b0e27a7048 100644
--- a/contentcuration/contentcuration/viewsets/user.py
+++ b/contentcuration/contentcuration/viewsets/user.py
@@ -52,6 +52,27 @@ def has_permission(self, request, view):
             return False
 
 
+class IsAIFeatureEnabledForUser(BasePermission):
+    """
+    Permission to check if the AI feature is enabled for a user.
+    """
+
+    def _can_user_access_feature(self, request):
+        try:
+            if request.user.is_admin:
+                return True
+            else:
+                return request.user.check_feature_flag('ai_feature')
+        except AttributeError:
+            return False
+
+    def has_permission(self, request, view):
+        return self._can_user_access_feature(request)
+
+    def has_object_permission(self, request, view, obj):
+        return self._can_user_access_feature(request)
+
+
 class UserListPagination(ValuesViewsetPageNumberPagination):
     page_size = None
     page_size_query_param = "page_size"
diff --git a/package.json b/package.json
index c5a758f5b7..af78c6a7ca 100644
--- a/package.json
+++ b/package.json
@@ -74,7 +74,7 @@
     "jspdf": "https://github.com/parallax/jsPDF.git#b7a1d8239c596292ce86dafa77f05987bcfa2e6e",
     "jszip": "^3.10.1",
     "kolibri-constants": "^0.2.0",
-    "kolibri-design-system": "^5.0.0-rc10",
+    "kolibri-design-system": "5.0.0-rc10",
     "lodash": "^4.17.21",
     "material-icons": "0.3.1",
     "mutex-js": "^1.1.5",
diff --git a/yarn.lock b/yarn.lock
index d35f4db204..d5c0d97d0d 100644
--- a/yarn.lock
+++ b/yarn.lock
@@ -9399,7 +9399,7 @@ kolibri-constants@^0.2.0:
   resolved "https://registry.yarnpkg.com/kolibri-constants/-/kolibri-constants-0.2.5.tgz#2b9df4c477119d0ade2d66bf8aef8a4172f0418f"
   integrity sha512-ZoFZ83xgteZhFZtYjiOmITcZeSF+X42i12TOo87zmcdA78jj0dZbPYB+ttO855UxoKY8h4HHeDVZIUkE5TGa5g==
 
-kolibri-design-system@^5.0.0-rc10:
+kolibri-design-system@5.0.0-rc10:
   version "5.0.0-rc10"
   resolved "https://registry.yarnpkg.com/kolibri-design-system/-/kolibri-design-system-5.0.0-rc10.tgz#8c92a1b097878a2a8e2f67cda76771914f77b7b8"
   integrity sha512-Dkk5D5PunIm+qPsIMmgo06rjA0BkPZOOpeABuPgZmtpXcFwhpAP07VrLs0LhvFBdSFri3aJDXj/kj7HskXLhWg==
@@ -12733,7 +12733,16 @@ string-trim-spaces-only@^3.1.0:
   dependencies:
     "@babel/runtime" "^7.14.0"
 
-"string-width-cjs@npm:string-width@^4.2.0", "string-width@^1.0.2 || 2 || 3 || 4", string-width@^4.1.0, string-width@^4.2.0, string-width@^4.2.3:
+"string-width-cjs@npm:string-width@^4.2.0":
+  version "4.2.3"
+  resolved "https://registry.yarnpkg.com/string-width/-/string-width-4.2.3.tgz#269c7117d27b05ad2e536830a8ec895ef9c6d010"
+  integrity sha512-wKyQRQpjJ0sIp62ErSZdGsjMJWsap5oRNihHhu6G7JVO/9jIB6UyevL+tXuOqrng8j/cxKTWyWUwvSTriiZz/g==
+  dependencies:
+    emoji-regex "^8.0.0"
+    is-fullwidth-code-point "^3.0.0"
+    strip-ansi "^6.0.1"
+
+"string-width@^1.0.2 || 2 || 3 || 4", string-width@^4.1.0, string-width@^4.2.0, string-width@^4.2.3:
   version "4.2.3"
   resolved "https://registry.yarnpkg.com/string-width/-/string-width-4.2.3.tgz#269c7117d27b05ad2e536830a8ec895ef9c6d010"
   integrity sha512-wKyQRQpjJ0sIp62ErSZdGsjMJWsap5oRNihHhu6G7JVO/9jIB6UyevL+tXuOqrng8j/cxKTWyWUwvSTriiZz/g==
@@ -12879,7 +12888,14 @@ stringify-object@^3.3.0:
     is-obj "^1.0.1"
     is-regexp "^1.0.0"
 
-"strip-ansi-cjs@npm:strip-ansi@^6.0.1", strip-ansi@6.0.1, strip-ansi@^6.0.0, strip-ansi@^6.0.1:
+"strip-ansi-cjs@npm:strip-ansi@^6.0.1":
+  version "6.0.1"
+  resolved "https://registry.yarnpkg.com/strip-ansi/-/strip-ansi-6.0.1.tgz#9e26c63d30f53443e9489495b2105d37b67a85d9"
+  integrity sha512-Y38VPSHcqkFrCpFnQ9vuSXmquuv5oXOKpGeT6aGrr3o3Gc9AlVa6JBfUSOCnbxGGZF+/0ooI7KrPuUSztUdU5A==
+  dependencies:
+    ansi-regex "^5.0.1"
+
+strip-ansi@6.0.1, strip-ansi@^6.0.0, strip-ansi@^6.0.1:
   version "6.0.1"
   resolved "https://registry.yarnpkg.com/strip-ansi/-/strip-ansi-6.0.1.tgz#9e26c63d30f53443e9489495b2105d37b67a85d9"
   integrity sha512-Y38VPSHcqkFrCpFnQ9vuSXmquuv5oXOKpGeT6aGrr3o3Gc9AlVa6JBfUSOCnbxGGZF+/0ooI7KrPuUSztUdU5A==
@@ -14613,7 +14629,7 @@ workbox-window@7.0.0, workbox-window@^7.0.0:
     "@types/trusted-types" "^2.0.2"
     workbox-core "7.0.0"
 
-"wrap-ansi-cjs@npm:wrap-ansi@^7.0.0", wrap-ansi@^7.0.0:
+"wrap-ansi-cjs@npm:wrap-ansi@^7.0.0":
   version "7.0.0"
   resolved "https://registry.yarnpkg.com/wrap-ansi/-/wrap-ansi-7.0.0.tgz#67e145cff510a6a6984bdf1152911d69d2eb9e43"
   integrity sha512-YVGIj2kamLSTxw6NsZjoBxfSwsn0ycdesmc4p+Q21c5zPuZ1pl+NfxVdxPtdHvmNVOQ6XSYG4AUtyt/Fi7D16Q==
@@ -14631,6 +14647,15 @@ wrap-ansi@^6.2.0:
     string-width "^4.1.0"
     strip-ansi "^6.0.0"
 
+wrap-ansi@^7.0.0:
+  version "7.0.0"
+  resolved "https://registry.yarnpkg.com/wrap-ansi/-/wrap-ansi-7.0.0.tgz#67e145cff510a6a6984bdf1152911d69d2eb9e43"
+  integrity sha512-YVGIj2kamLSTxw6NsZjoBxfSwsn0ycdesmc4p+Q21c5zPuZ1pl+NfxVdxPtdHvmNVOQ6XSYG4AUtyt/Fi7D16Q==
+  dependencies:
+    ansi-styles "^4.0.0"
+    string-width "^4.1.0"
+    strip-ansi "^6.0.0"
+
 wrap-ansi@^8.1.0:
   version "8.1.0"
   resolved "https://registry.yarnpkg.com/wrap-ansi/-/wrap-ansi-8.1.0.tgz#56dc22368ee570face1b49819975d9b9a5ead214"