diff --git a/src/renderer/extensions/vueNodes/widgets/components/WidgetSelectDropdown.vue b/src/renderer/extensions/vueNodes/widgets/components/WidgetSelectDropdown.vue
index 04040d591b7..eecbe5edd18 100644
--- a/src/renderer/extensions/vueNodes/widgets/components/WidgetSelectDropdown.vue
+++ b/src/renderer/extensions/vueNodes/widgets/components/WidgetSelectDropdown.vue
@@ -1,4 +1,5 @@
 <script setup lang="ts">
+import { useDebounceFn } from '@vueuse/core'
 import { computed, provide, ref, toRef } from 'vue'
 import { useI18n } from 'vue-i18n'
 
@@ -150,6 +151,17 @@ function handleIsOpenUpdate(isOpen: boolean) {
     void outputMediaAssets.refresh()
   }
 }
+
+const handleApproachEnd = useDebounceFn(async () => {
+  if (
+    outputMediaAssets.hasMore.value &&
+    !outputMediaAssets.loading.value &&
+    !outputMediaAssets.isLoadingMore.value
+  ) {
+    await outputMediaAssets.loadMore()
+  }
+}, 300)
+
 const isUploading = ref(false)
 async function updateFiles(files: File[]) {
   isUploading.value = true
@@ -179,10 +191,12 @@ async function updateFiles(files: File[]) {
       :base-model-options
       :is-uploading
       v-bind="combinedProps"
+      :loading-more="outputMediaAssets.isLoadingMore.value"
       class="w-full"
       @update:selected="updateSelectedItems"
       @update:files="updateFiles"
       @update:is-open="handleIsOpenUpdate"
+      @approach-end="handleApproachEnd"
     />
   </WidgetLayoutField>
 </template>
diff --git a/src/renderer/extensions/vueNodes/widgets/components/form/dropdown/FormDropdown.vue b/src/renderer/extensions/vueNodes/widgets/components/form/dropdown/FormDropdown.vue
index 9c07c1f6c98..f318b3c84f4 100644
--- a/src/renderer/extensions/vueNodes/widgets/components/form/dropdown/FormDropdown.vue
+++ b/src/renderer/extensions/vueNodes/widgets/components/form/dropdown/FormDropdown.vue
@@ -37,6 +37,7 @@ interface Props {
   ownershipOptions?: OwnershipFilterOption[]
   showBaseModelFilter?: boolean
   baseModelOptions?: FilterOption[]
+  loadingMore?: boolean
   isSelected?: (
     selected: Set<string>,
     item: FormDropdownItem,
@@ -64,11 +65,16 @@ const {
   ownershipOptions,
   showBaseModelFilter,
   baseModelOptions,
+  loadingMore = false,
   isSelected = (selected, item, _index) => selected.has(item.id),
   searcher = defaultSearcher,
   items
 } = defineProps<Props>()
 
+const emit = defineEmits<{
+  (e: 'approach-end'): void
+}>()
+
 const placeholderText = computed(
   () => placeholder ?? t('widgets.uploadSelect.placeholder')
 )
@@ -316,9 +322,11 @@ function handleSearchEnter() {
         :candidate-label
         :is-selected="internalIsSelected"
         :max-selectable
+        :loading-more="loadingMore"
         @close="closeDropdown"
         @search-enter="handleSearchEnter"
         @item-click="handleSelection"
+        @approach-end="emit('approach-end')"
       />
     </Popover>
   </div>
diff --git a/src/renderer/extensions/vueNodes/widgets/components/form/dropdown/FormDropdownMenu.test.ts b/src/renderer/extensions/vueNodes/widgets/components/form/dropdown/FormDropdownMenu.test.ts
index 5125065aa4b..049a2f7126b 100644
--- a/src/renderer/extensions/vueNodes/widgets/components/form/dropdown/FormDropdownMenu.test.ts
+++ b/src/renderer/extensions/vueNodes/widgets/components/form/dropdown/FormDropdownMenu.test.ts
@@ -1,3 +1,4 @@
+import userEvent from '@testing-library/user-event'
 import { render, screen } from '@testing-library/vue'
 import { describe, expect, it } from 'vitest'
 
@@ -7,8 +8,9 @@ import type { FormDropdownItem, LayoutMode } from './types'
 const VirtualGridStub = {
   name: 'VirtualGrid',
   props: ['items', 'maxColumns', 'itemHeight', 'scrollerHeight'],
+  emits: ['approach-end'],
   template:
-    '<div data-testid="virtual-grid" :data-items="JSON.stringify(items)" :data-max-columns="maxColumns" />'
+    '<div data-testid="virtual-grid" :data-items="JSON.stringify(items)" :data-max-columns="maxColumns" @click="$emit(\'approach-end\')" />'
 }
 
 function createItem(id: string, name: string): FormDropdownItem {
@@ -93,6 +95,31 @@ describe('FormDropdownMenu', () => {
     expect(virtualGrid.getAttribute('data-max-columns')).toBe('1')
   })
 
+  it('forwards approach-end from the virtual grid', async () => {
+    const user = userEvent.setup()
+    const { emitted } = render(FormDropdownMenu, {
+      props: defaultProps,
+      global: globalConfig
+    })
+
+    await user.click(screen.getByTestId('virtual-grid'))
+
+    expect(emitted()['approach-end']).toHaveLength(1)
+  })
+
+  it('shows the loading-more row only while loadingMore is set', async () => {
+    const { rerender } = render(FormDropdownMenu, {
+      props: { ...defaultProps, loadingMore: true },
+      global: globalConfig
+    })
+
+    expect(screen.getByTestId('form-dropdown-loading-more')).toBeTruthy()
+
+    await rerender({ ...defaultProps, loadingMore: false })
+
+    expect(screen.queryByTestId('form-dropdown-loading-more')).toBeNull()
+  })
+
   it('has data-capture-wheel="true" on the root element', () => {
     render(FormDropdownMenu, {
       props: defaultProps,
diff --git a/src/renderer/extensions/vueNodes/widgets/components/form/dropdown/FormDropdownMenu.vue b/src/renderer/extensions/vueNodes/widgets/components/form/dropdown/FormDropdownMenu.vue
index 77bbf01a6f0..a01cff9e531 100644
--- a/src/renderer/extensions/vueNodes/widgets/components/form/dropdown/FormDropdownMenu.vue
+++ b/src/renderer/extensions/vueNodes/widgets/components/form/dropdown/FormDropdownMenu.vue
@@ -27,6 +27,7 @@ interface Props {
   baseModelOptions?: FilterOption[]
   candidateIndex?: number
   candidateLabel?: string
+  loadingMore?: boolean
 }
 
 const {
@@ -39,11 +40,13 @@ const {
   showBaseModelFilter,
   baseModelOptions,
   candidateIndex = -1,
-  candidateLabel
+  candidateLabel,
+  loadingMore = false
 } = defineProps<Props>()
 const emit = defineEmits<{
   (e: 'item-click', item: FormDropdownItem, index: number): void
   (e: 'search-enter'): void
+  (e: 'approach-end'): void
 }>()
 
 const filterSelected = defineModel<string>('filterSelected')
@@ -158,6 +161,7 @@ const onWheel = (event: WheelEvent) => {
       :default-item-width="layoutConfig.itemWidth"
       :buffer-rows="2"
       class="mt-2 min-h-0 flex-1"
+      @approach-end="emit('approach-end')"
     >
       <template #item="{ item, index }">
         <FormDropdownMenuItem
@@ -172,5 +176,15 @@ const onWheel = (event: WheelEvent) => {
         />
       </template>
     </VirtualGrid>
+    <div
+      v-if="loadingMore"
+      class="flex items-center justify-center py-2"
+      data-testid="form-dropdown-loading-more"
+    >
+      <i
+        :aria-label="$t('g.loading')"
+        class="icon-[lucide--loader] size-6 animate-spin text-muted-foreground"
+      />
+    </div>
   </div>
 </template>
diff --git a/src/stores/assetsStore.test.ts b/src/stores/assetsStore.test.ts
index dacaadfdc93..98806b3330b 100644
--- a/src/stores/assetsStore.test.ts
+++ b/src/stores/assetsStore.test.ts
@@ -5,7 +5,10 @@ import { nextTick, watch } from 'vue'
 
 import { useAssetsStore } from '@/stores/assetsStore'
 import { api } from '@/scripts/api'
-import type { AssetItem } from '@/platform/assets/schemas/assetSchema'
+import type {
+  AssetItem,
+  AssetResponse
+} from '@/platform/assets/schemas/assetSchema'
 import type { JobListItem } from '@/platform/remote/comfyui/jobs/jobTypes'
 import { assetService } from '@/platform/assets/services/assetService'
 
@@ -25,6 +28,7 @@ vi.mock('@/scripts/api', () => ({
 vi.mock('@/platform/assets/services/assetService', () => ({
   assetService: {
     getAssetsByTag: vi.fn(),
+    getAssetsPageByTag: vi.fn(),
     getAllAssetsByTag: vi.fn(),
     getAssetsForNodeType: vi.fn(),
     invalidateInputAssetsIncludingPublic: vi.fn(),
@@ -1517,49 +1521,143 @@ describe('assetsStore - Flat Output Assets (cloud-only)', () => {
     tags: ['output']
   })
 
+  const makePage = (
+    assets: AssetItem[],
+    {
+      hasMore = false,
+      nextCursor
+    }: { hasMore?: boolean; nextCursor?: string } = {}
+  ): AssetResponse => ({
+    assets,
+    total: assets.length,
+    has_more: hasMore,
+    ...(nextCursor === undefined ? {} : { next_cursor: nextCursor })
+  })
+
   beforeEach(() => {
     setActivePinia(createTestingPinia({ stubActions: false }))
-    vi.clearAllMocks()
+    vi.resetAllMocks()
   })
 
-  it('fetches outputs via getAssetsByTag with the output tag and page size', async () => {
-    vi.mocked(assetService.getAssetsByTag).mockResolvedValueOnce([
-      makeAsset('a1', 'image1.png', 'hash1.png'),
-      makeAsset('a2', 'image2.png', 'hash2.png')
-    ])
+  it('fetches the first page via getAssetsPageByTag with the output tag and page size', async () => {
+    vi.mocked(assetService.getAssetsPageByTag).mockResolvedValueOnce(
+      makePage([
+        makeAsset('a1', 'image1.png', 'hash1.png'),
+        makeAsset('a2', 'image2.png', 'hash2.png')
+      ])
+    )
 
     const store = useAssetsStore()
     await store.updateFlatOutputs()
 
-    expect(assetService.getAssetsByTag).toHaveBeenCalledWith(
+    expect(assetService.getAssetsPageByTag).toHaveBeenCalledWith(
       'output',
       true,
-      expect.objectContaining({ limit: FLAT_OUTPUT_PAGE_SIZE, offset: 0 })
+      {
+        limit: FLAT_OUTPUT_PAGE_SIZE,
+        offset: 0
+      }
     )
     expect(store.flatOutputAssets.map((a) => a.id)).toEqual(['a1', 'a2'])
   })
 
-  it('marks hasMore=false when the page is short', async () => {
-    vi.mocked(assetService.getAssetsByTag).mockResolvedValueOnce([
-      makeAsset('a1', 'one.png')
-    ])
+  it('trusts server has_more over page size for a short page', async () => {
+    vi.mocked(assetService.getAssetsPageByTag).mockResolvedValueOnce(
+      makePage([makeAsset('a1', 'one.png')], { hasMore: true })
+    )
 
     const store = useAssetsStore()
     await store.updateFlatOutputs()
 
-    expect(store.flatOutputHasMore).toBe(false)
+    expect(store.flatOutputHasMore).toBe(true)
   })
 
-  it('marks hasMore=true when a full page is returned', async () => {
+  it('marks hasMore=false when the server reports the last page', async () => {
     const fullPage = Array.from({ length: FLAT_OUTPUT_PAGE_SIZE }, (_, i) =>
       makeAsset(`a${i}`, `f${i}.png`)
     )
-    vi.mocked(assetService.getAssetsByTag).mockResolvedValueOnce(fullPage)
+    vi.mocked(assetService.getAssetsPageByTag).mockResolvedValueOnce(
+      makePage(fullPage, { hasMore: false })
+    )
 
     const store = useAssetsStore()
     await store.updateFlatOutputs()
 
-    expect(store.flatOutputHasMore).toBe(true)
+    expect(store.flatOutputHasMore).toBe(false)
+  })
+
+  it('threads the minted cursor into after on loadMore and omits offset', async () => {
+    vi.mocked(assetService.getAssetsPageByTag)
+      .mockResolvedValueOnce(
+        makePage([makeAsset('a1', 'f1.png')], {
+          hasMore: true,
+          nextCursor: 'cursor-1'
+        })
+      )
+      .mockResolvedValueOnce(makePage([makeAsset('a2', 'f2.png')]))
+
+    const store = useAssetsStore()
+    await store.updateFlatOutputs()
+    await store.loadMoreFlatOutputs()
+
+    expect(assetService.getAssetsPageByTag).toHaveBeenLastCalledWith(
+      'output',
+      true,
+      { limit: FLAT_OUTPUT_PAGE_SIZE, after: 'cursor-1' }
+    )
+  })
+
+  it('falls back to offset paging when the server mints no cursor', async () => {
+    vi.mocked(assetService.getAssetsPageByTag)
+      .mockResolvedValueOnce(
+        makePage([makeAsset('a1', 'f1.png'), makeAsset('a2', 'f2.png')], {
+          hasMore: true
+        })
+      )
+      .mockResolvedValueOnce(makePage([makeAsset('a3', 'f3.png')]))
+
+    const store = useAssetsStore()
+    await store.updateFlatOutputs()
+    await store.loadMoreFlatOutputs()
+
+    expect(assetService.getAssetsPageByTag).toHaveBeenLastCalledWith(
+      'output',
+      true,
+      { limit: FLAT_OUTPUT_PAGE_SIZE, offset: 2 }
+    )
+  })
+
+  it('stops when the server returns a non-advancing cursor', async () => {
+    vi.mocked(assetService.getAssetsPageByTag)
+      .mockResolvedValueOnce(
+        makePage([makeAsset('a1', 'f1.png')], {
+          hasMore: true,
+          nextCursor: 'stuck'
+        })
+      )
+      .mockResolvedValueOnce(
+        makePage([makeAsset('a2', 'f2.png')], {
+          hasMore: true,
+          nextCursor: 'stuck'
+        })
+      )
+
+    const store = useAssetsStore()
+    await store.updateFlatOutputs()
+    await store.loadMoreFlatOutputs()
+
+    expect(store.flatOutputHasMore).toBe(false)
+  })
+
+  it('treats an empty page as terminal even when has_more is true', async () => {
+    vi.mocked(assetService.getAssetsPageByTag).mockResolvedValueOnce(
+      makePage([], { hasMore: true })
+    )
+
+    const store = useAssetsStore()
+    await store.updateFlatOutputs()
+
+    expect(store.flatOutputHasMore).toBe(false)
   })
 
   it('appends and dedupes on loadMoreFlatOutputs', async () => {
@@ -1570,9 +1668,9 @@ describe('assetsStore - Flat Output Assets (cloud-only)', () => {
       makeAsset('a0', 'duplicate.png'),
       makeAsset('newId', 'new.png')
     ]
-    vi.mocked(assetService.getAssetsByTag)
-      .mockResolvedValueOnce(firstPage)
-      .mockResolvedValueOnce(secondPage)
+    vi.mocked(assetService.getAssetsPageByTag)
+      .mockResolvedValueOnce(makePage(firstPage, { hasMore: true }))
+      .mockResolvedValueOnce(makePage(secondPage))
 
     const store = useAssetsStore()
     await store.updateFlatOutputs()
@@ -1582,9 +1680,9 @@ describe('assetsStore - Flat Output Assets (cloud-only)', () => {
     expect(store.flatOutputAssets.at(-1)?.id).toBe('newId')
   })
 
-  it('records error and clears media on initial-fetch failure', async () => {
+  it('records error and resolves to an empty list on initial-fetch failure', async () => {
     const err = new Error('network down')
-    vi.mocked(assetService.getAssetsByTag).mockRejectedValueOnce(err)
+    vi.mocked(assetService.getAssetsPageByTag).mockRejectedValueOnce(err)
     const consoleSpy = vi.spyOn(console, 'error').mockImplementation(() => {})
 
     try {
@@ -1599,37 +1697,105 @@ describe('assetsStore - Flat Output Assets (cloud-only)', () => {
     }
   })
 
+  it('preserves the cursor for retry when loadMore fails', async () => {
+    const err = new Error('network down')
+    vi.mocked(assetService.getAssetsPageByTag)
+      .mockResolvedValueOnce(
+        makePage([makeAsset('a1', 'f1.png')], {
+          hasMore: true,
+          nextCursor: 'cursor-1'
+        })
+      )
+      .mockRejectedValueOnce(err)
+      .mockResolvedValueOnce(makePage([makeAsset('a2', 'f2.png')]))
+    const consoleSpy = vi.spyOn(console, 'error').mockImplementation(() => {})
+
+    try {
+      const store = useAssetsStore()
+      await store.updateFlatOutputs()
+      await store.loadMoreFlatOutputs()
+
+      expect(store.flatOutputError).toBe(err)
+      expect(store.flatOutputAssets.map((a) => a.id)).toEqual(['a1'])
+      expect(store.flatOutputHasMore).toBe(true)
+
+      await store.loadMoreFlatOutputs()
+
+      expect(assetService.getAssetsPageByTag).toHaveBeenLastCalledWith(
+        'output',
+        true,
+        { limit: FLAT_OUTPUT_PAGE_SIZE, after: 'cursor-1' }
+      )
+    } finally {
+      consoleSpy.mockRestore()
+    }
+  })
+
+  it('restarts from the head when loadMore follows a failed refresh', async () => {
+    vi.mocked(assetService.getAssetsPageByTag)
+      .mockResolvedValueOnce(
+        makePage([makeAsset('a1', 'f1.png')], {
+          hasMore: true,
+          nextCursor: 'cursor-1'
+        })
+      )
+      .mockRejectedValueOnce(new Error('network down'))
+      .mockResolvedValueOnce(makePage([makeAsset('a2', 'f2.png')]))
+    const consoleSpy = vi.spyOn(console, 'error').mockImplementation(() => {})
+
+    try {
+      const store = useAssetsStore()
+      await store.updateFlatOutputs()
+      await store.updateFlatOutputs()
+      await store.loadMoreFlatOutputs()
+
+      expect(assetService.getAssetsPageByTag).toHaveBeenLastCalledWith(
+        'output',
+        true,
+        { limit: FLAT_OUTPUT_PAGE_SIZE, offset: 0 }
+      )
+    } finally {
+      consoleSpy.mockRestore()
+    }
+  })
+
   it('refresh resets pagination', async () => {
-    vi.mocked(assetService.getAssetsByTag)
+    vi.mocked(assetService.getAssetsPageByTag)
       .mockResolvedValueOnce(
-        Array.from({ length: FLAT_OUTPUT_PAGE_SIZE }, (_, i) =>
-          makeAsset(`a${i}`, `f${i}.png`)
-        )
+        makePage([makeAsset('a1', 'f1.png')], {
+          hasMore: true,
+          nextCursor: 'cursor-1'
+        })
       )
-      .mockResolvedValueOnce([makeAsset('fresh', 'fresh.png')])
+      .mockResolvedValueOnce(makePage([makeAsset('fresh', 'fresh.png')]))
 
     const store = useAssetsStore()
     await store.updateFlatOutputs()
     await store.updateFlatOutputs()
 
+    expect(assetService.getAssetsPageByTag).toHaveBeenLastCalledWith(
+      'output',
+      true,
+      { limit: FLAT_OUTPUT_PAGE_SIZE, offset: 0 }
+    )
     expect(store.flatOutputAssets.map((a) => a.id)).toEqual(['fresh'])
     expect(store.flatOutputHasMore).toBe(false)
   })
 
   it('dedupes concurrent fetches into a single request', async () => {
-    let resolvePage!: (assets: AssetItem[]) => void
-    const pagePromise = new Promise<AssetItem[]>((res) => {
+    let resolvePage!: (page: AssetResponse) => void
+    const pagePromise = new Promise<AssetResponse>((res) => {
       resolvePage = res
     })
-    vi.mocked(assetService.getAssetsByTag).mockReturnValueOnce(pagePromise)
+    vi.mocked(assetService.getAssetsPageByTag).mockReturnValueOnce(pagePromise)
 
     const store = useAssetsStore()
     const p1 = store.updateFlatOutputs()
     const p2 = store.updateFlatOutputs()
 
-    expect(vi.mocked(assetService.getAssetsByTag)).toHaveBeenCalledTimes(1)
+    expect(vi.mocked(assetService.getAssetsPageByTag)).toHaveBeenCalledTimes(1)
 
-    resolvePage([makeAsset('shared-1', 'shared.png', 'h.png')])
+    resolvePage(makePage([makeAsset('shared-1', 'shared.png', 'h.png')]))
     await Promise.all([p1, p2])
 
     expect(store.flatOutputAssets.map((x) => x.id)).toEqual(['shared-1'])
diff --git a/src/stores/assetsStore.ts b/src/stores/assetsStore.ts
index 3889182465f..0a8b20e4b5e 100644
--- a/src/stores/assetsStore.ts
+++ b/src/stores/assetsStore.ts
@@ -267,6 +267,7 @@ export const useAssetsStore = defineStore('assets', () => {
   const flatOutputHasMore = ref(true)
   const flatOutputIsLoadingMore = ref(false)
   const flatOutputSeenIds = new Set<string>()
+  let flatOutputNextCursor: string | undefined
   let flatOutputInFlight: Promise<AssetItem[]> | null = null
 
   async function fetchFlatOutputs(loadMore: boolean): Promise<AssetItem[]> {
@@ -278,26 +279,36 @@ export const useAssetsStore = defineStore('assets', () => {
     } else {
       flatOutputLoading.value = true
       flatOutputOffset.value = 0
+      flatOutputNextCursor = undefined
       flatOutputHasMore.value = true
       flatOutputSeenIds.clear()
     }
     flatOutputError.value = null
 
     flatOutputInFlight = (async () => {
+      const requestedAfter = loadMore ? flatOutputNextCursor : undefined
       try {
-        const page = await assetService.getAssetsByTag(OUTPUT_TAG, true, {
+        const page = await assetService.getAssetsPageByTag(OUTPUT_TAG, true, {
           limit: FLAT_OUTPUT_PAGE_SIZE,
-          offset: flatOutputOffset.value
+          ...(requestedAfter
+            ? { after: requestedAfter }
+            : { offset: flatOutputOffset.value })
         })
+        const batch = page.assets
         const fresh = loadMore
-          ? page.filter((asset) => !flatOutputSeenIds.has(asset.id))
-          : page
+          ? batch.filter((asset) => !flatOutputSeenIds.has(asset.id))
+          : batch
         for (const asset of fresh) flatOutputSeenIds.add(asset.id)
         flatOutputAssets.value = loadMore
           ? [...flatOutputAssets.value, ...fresh]
-          : page
-        flatOutputOffset.value += page.length
-        flatOutputHasMore.value = page.length === FLAT_OUTPUT_PAGE_SIZE
+          : batch
+        flatOutputOffset.value += batch.length
+        const nextCursor = page.next_cursor || undefined
+        const cursorStuck =
+          nextCursor !== undefined && nextCursor === requestedAfter
+        flatOutputNextCursor = cursorStuck ? undefined : nextCursor
+        flatOutputHasMore.value =
+          fresh.length > 0 && page.has_more && !cursorStuck
         return flatOutputAssets.value
       } catch (err) {
         flatOutputError.value = err