Chore: switch sqlite-vec to the paperless-ngx patched wheels

They are built from a patched fork that carries upstream PRs including NEON on Linux arm64, memory-safety fixes and performance improvements for both reading and cosine ranking
Chore: restrict uv lock environments to supported architectures
2026-11-14 08:32:19 +00:00 · 2026-11-12 10:32:19 -08:00 · 2026-11-12 10:25:12 -08:00
152 changed files with 37827 additions and 49731 deletions
@@ -288,12 +288,6 @@ The API supports various bulk-editing operations which are executed asynchronous
 For bulk operations on documents, use the endpoint `/api/documents/bulk_edit/` which accepts
 a json payload of the format:

-Document bulk operations, including the dedicated document action endpoints, return
-`{"result":"OK","task_id":"…"}` when queued. Use `/api/tasks/?task_id={uuid}`
-to check the task outcome. Actions that create or reprocess files may start further
-consumption or reprocessing tasks and completion of the bulk task means those tasks
-were scheduled, not that their file processing has finished.
-
 ```json
 {
  "documents": [LIST_OF_DOCUMENT_IDS],
@@ -493,7 +493,7 @@ fields and permissions, which will be merged.

 #### Types {#workflow-trigger-types}

-Currently, there are five events that correspond to workflow trigger 'types':
+Currently, there are four events that correspond to workflow trigger 'types':

 1. **Consumption Started**: _before_ a document is consumed, so events can include filters by source (mail, consumption
   folder or API), file path, file name, mail rule
@@ -505,10 +505,8 @@ Currently, there are five events that correspond to workflow trigger 'types':
 4. **Scheduled**: a scheduled trigger that can be used to run workflows at a specific time. The date used can be either the document
   added, created, updated date or you can specify a (date) custom field. You can also specify a day offset from the date (positive
   offsets will trigger after the date, negative offsets will trigger before).
-5. **Manual**: a trigger that only runs when you explicitly choose to run the workflow against one or more existing documents. See
-   [running a workflow manually](#running-a-workflow-manually) below.

-The following flow diagram illustrates the document trigger types:
+The following flow diagram illustrates the four document trigger types:

 ```mermaid
 flowchart TD
@@ -528,10 +526,6 @@ flowchart TD
    matching
    trigger(s)"}

-    manual{"Matching
-    'Manual'
-    trigger(s)"}
-
    A[New Document] --> consumption
    consumption --> |Yes| C[Workflow Actions Run]
    consumption --> |No| D
@@ -549,10 +543,6 @@ flowchart TD
    scheduled --> |Yes| N[Workflow Actions Run]
    scheduled --> |No| O[Document Saved]
    N --> O
-    P[User Runs Workflow] --> manual
-    manual --> |Yes| Q[Workflow Actions Run]
-    manual --> |No| R[Document Saved]
-    Q --> R
 ```

 #### Filters {#workflow-trigger-filters}
@@ -564,9 +554,9 @@ Workflows allow you to filter by:
 - File path, including wildcards. Note that enabling `PAPERLESS_CONSUMER_RECURSIVE` would allow, for
  example, automatically assigning documents to different owners based on the upload directory.
 - Mail rule. Choosing this option will force 'mail fetch' to be the workflow source.
- Content matching (`Added`, `Updated`, `Scheduled` and `Manual` triggers only). Filter document content using the matching settings.
+- Content matching (`Added`, `Updated` and `Scheduled` triggers only). Filter document content using the matching settings.

-There are also 'advanced' filters available for `Added`, `Updated`, `Scheduled` and `Manual` triggers:
+There are also 'advanced' filters available for `Added`, `Updated` and `Scheduled` triggers:

 - Any Tags: Filter for documents with any of the specified tags.
 - All Tags: Filter for documents with all of the specified tags.
@@ -579,22 +569,6 @@ There are also 'advanced' filters available for `Added`, `Updated`, `Scheduled`
 - Not Storage paths: Filter documents without any of these storage paths.
 - Custom field query: Filter documents with a custom field query (the same as used for the document list filters).

-#### Running a workflow manually {#running-a-workflow-manually}
-
-A workflow with a **Manual** trigger does not run automatically. Instead, it can be run on demand against existing
-documents from the web UI:
-
- From the document list, select one or more documents and choose **Run workflow** from the "Actions" menu.
- From an individual document, choose **Run workflow** from the "Actions" menu.
-
-You will be asked which workflow to run. From the document list, the workflow's trigger filters apply by default, so
-documents that do not match are skipped. You can choose to **run on all selected documents** to ignore the filters.
-From an individual document, the option to ignore trigger filters is selected by default. Clear it to run the workflow
-only if the document matches its trigger filters.
-
-Manual runs happen in the background. As with scheduled workflows, the document list is not refreshed automatically when
-they finish, so you may need to reload the list to see the results.
-
 ### Workflow Actions

 #### Types {#workflow-action-types}
@@ -675,7 +649,7 @@ new version of the same document, this time with normal OCR/text extraction appl
 a password-protected file added with this trigger will briefly exist as an un-OCR'd version before
 the properly processed version is created.

-**Document Added**, **Document Updated**, **Scheduled**, **Manual**: these triggers run against a document that
+**Document Added**, **Document Updated**, **Scheduled**: these triggers run against a document that
 already exists, so password removal happens immediately: the decrypted content is queued for
 consumption as a new version right away. Note that if the document's initial consumption also
 happened while it was still encrypted, that original version will likewise be missing OCR text.
@@ -71,7 +71,7 @@ dependencies = [
  "scikit-learn~=1.9.0",
  "sentence-transformers>=5.6.1",
  "setproctitle~=1.3.4",
-  "sqlite-vec==0.1.9",
+  "sqlite-vec==0.1.10+paperless.3",
  "tantivy~=0.26.0",
  "tika-client[httpx]~=1.0",
  "torch>=2.13,<2.15",
@@ -151,8 +151,9 @@ typing = [
 required-version = ">=0.9.0"
 prerelease = "disallow"
 environments = [
-  "sys_platform == 'darwin'",
-  "sys_platform == 'linux'",
+  "sys_platform == 'darwin' and platform_machine == 'arm64'",
+  "sys_platform == 'linux' and platform_machine == 'aarch64'",
+  "sys_platform == 'linux' and platform_machine == 'x86_64'",
 ]
 package = false
 [tool.uv.sources]
@@ -163,6 +164,12 @@ psycopg-c = [
  { url = "https://github.com/paperless-ngx/builder/releases/download/psycopg-trixie-3.3.4/psycopg_c-3.3.4-cp314-cp314-linux_x86_64.whl", marker = "sys_platform == 'linux' and platform_machine == 'x86_64' and python_version == '3.14'" },
  { url = "https://github.com/paperless-ngx/builder/releases/download/psycopg-trixie-3.3.4/psycopg_c-3.3.4-cp314-cp314-linux_aarch64.whl", marker = "sys_platform == 'linux' and platform_machine == 'aarch64' and python_version == '3.14'" },
 ]
+# Patched sqlite-vec builds
+sqlite-vec = [
+  { url = "https://github.com/paperless-ngx/builder/releases/download/sqlite-vec-0.1.10%2Bpaperless.3/sqlite_vec-0.1.10%2Bpaperless.3-py3-none-manylinux_2_29_x86_64.whl", marker = "sys_platform == 'linux' and platform_machine == 'x86_64'" },
+  { url = "https://github.com/paperless-ngx/builder/releases/download/sqlite-vec-0.1.10%2Bpaperless.3/sqlite_vec-0.1.10%2Bpaperless.3-py3-none-manylinux_2_29_aarch64.whl", marker = "sys_platform == 'linux' and platform_machine == 'aarch64'" },
+  { url = "https://github.com/paperless-ngx/builder/releases/download/sqlite-vec-0.1.10%2Bpaperless.3/sqlite_vec-0.1.10%2Bpaperless.3-py3-none-macosx_11_0_arm64.whl", marker = "sys_platform == 'darwin' and platform_machine == 'arm64'" },
+]
 torch = [
  { index = "pytorch-cpu" },
 ]
@@ -35,7 +35,6 @@ import { SearchService } from 'src/app/services/rest/search.service'
 import { SettingsService } from 'src/app/services/settings.service'
 import { TasksService } from 'src/app/services/tasks.service'
 import { ToastService } from 'src/app/services/toast.service'
-import { TrashService } from 'src/app/services/trash.service'
 import { UploadDocumentsService } from 'src/app/services/upload-documents.service'
 import { WebsocketStatusService } from 'src/app/services/websocket-status.service'
 import { environment } from 'src/environments/environment'
@@ -231,7 +230,7 @@ describe('AppFrameComponent', () => {
    expect(refresh).toHaveBeenCalledWith(document.id)
    expect(maybeRefreshSpy).toHaveBeenCalledTimes(1)
    expect(tasksReload).toHaveBeenCalledTimes(1)
-    expect(success).toHaveBeenCalledWith('Operation completed.')
+    expect(success).toHaveBeenCalledWith('Bulk operation completed.')
    fixture.destroy()
    bulkEvents.next({
      task_id: 'bulk-task',
@@ -263,33 +262,14 @@ describe('AppFrameComponent', () => {
      })
    }
    expect(reload).toHaveBeenCalledTimes(2)
+    expect(error).toHaveBeenCalledWith(expect.any(String), 'Could not update')
    expect(error).toHaveBeenCalledWith(
-      'Operation failed. Some changes may already have been applied.',
-      'Could not update'
-    )
-    expect(error).toHaveBeenCalledWith(
-      'Operation revoked.',
+      'Bulk operation revoked.',
      'Task expired before execution.'
    )
    expect(success).not.toHaveBeenCalled()
  })

-  it('defers the delete success toast to TrashService', () => {
-    const success = jest.spyOn(toastService, 'showSuccess')
-    const trashService = TestBed.inject(TrashService)
-    const handleStatus = jest.spyOn(trashService, 'handleDeleteTaskStatus')
-    bulkEvents.next({
-      task_id: 'delete-1',
-      operation: 'delete',
-      status: PaperlessTaskStatus.Success,
-    })
-    expect(handleStatus).toHaveBeenCalledWith(
-      'delete-1',
-      PaperlessTaskStatus.Success
-    )
-    expect(success).not.toHaveBeenCalled()
-  })
-
  it('should initialize the saved view service', () => {
    expect(savedViewSpy).toHaveBeenCalled()
  })
@@ -59,7 +59,6 @@ import { SavedViewService } from 'src/app/services/rest/saved-view.service'
 import { SettingsService } from 'src/app/services/settings.service'
 import { TasksService } from 'src/app/services/tasks.service'
 import { ToastService } from 'src/app/services/toast.service'
-import { TrashService } from 'src/app/services/trash.service'
 import { UploadDocumentsService } from 'src/app/services/upload-documents.service'
 import { WebsocketStatusService } from 'src/app/services/websocket-status.service'
 import { environment } from 'src/environments/environment'
@@ -116,7 +115,6 @@ export class AppFrameComponent
  settingsService = inject(SettingsService)
  tasksService = inject(TasksService)
  private readonly toastService = inject(ToastService)
-  private readonly trashService = inject(TrashService)
  private modalService = inject(NgbModal)
  permissionsService = inject(PermissionsService)
  private djangoMessagesService = inject(DjangoMessagesService)
@@ -184,7 +182,7 @@ export class AppFrameComponent
        ),
        takeUntilDestroyed(this.destroyRef)
      )
-      .subscribe(({ task_id, operation, status, error }) => {
+      .subscribe(({ status, error }) => {
        this.documentList.reload(null, false)
        this.documentList.reduceSelectionToFilter()
        // maybe someday we can optimize to only refresh affected documents
@@ -200,16 +198,13 @@ export class AppFrameComponent
        ) {
          this.tasksService.reload()
        }
-        if (operation === 'delete') {
-          this.trashService.handleDeleteTaskStatus(task_id, status)
-        }
-        if (status === PaperlessTaskStatus.Success && operation !== 'delete') {
-          this.toastService.showSuccess($localize`Operation completed.`)
+        if (status === PaperlessTaskStatus.Success) {
+          this.toastService.showSuccess($localize`Bulk operation completed.`)
        } else if (status === PaperlessTaskStatus.Revoked) {
-          this.toastService.showError($localize`Operation revoked.`, error)
-        } else if (status === PaperlessTaskStatus.Failure) {
+          this.toastService.showError($localize`Bulk operation revoked.`, error)
+        } else {
          this.toastService.showError(
-            $localize`Operation failed. Some changes may already have been applied.`,
+            $localize`Bulk operation failed. Some changes may already have been applied.`,
            error
          )
        }
@@ -118,7 +118,6 @@ import personFill from 'bootstrap-icons/icons/person-fill.svg'
 import personLock from 'bootstrap-icons/icons/person-lock.svg'
 import personSquare from 'bootstrap-icons/icons/person-square.svg'
 import person from 'bootstrap-icons/icons/person.svg'
-import playCircle from 'bootstrap-icons/icons/play-circle.svg'
 import playFill from 'bootstrap-icons/icons/play-fill.svg'
 import plusCircle from 'bootstrap-icons/icons/plus-circle.svg'
 import plus from 'bootstrap-icons/icons/plus.svg'
@@ -280,7 +279,6 @@ export const icons: Record<string, string> = {
  personFillLock,
  personLock,
  personSquare,
-  playCircle,
  playFill,
  plus,
  plusCircle,
@@ -1,37 +0,0 @@
-<div class="modal-header">
-  <h4 class="modal-title" id="modal-basic-title">{{title}}</h4>
-  <button type="button" class="btn-close" aria-label="Close" (click)="cancel()">
-  </button>
-</div>
-<div class="modal-body">
-  @if (message) {
-    <p class="text-break" [innerHTML]="message"></p>
-  }
-  <div class="mb-3">
-    <label class="form-label" for="runWorkflowSelect" i18n>Workflow</label>
-    <select class="form-select" id="runWorkflowSelect" [(ngModel)]="workflowId" (ngModelChange)="workflowSelected()">
-      <option [ngValue]="null" disabled i18n>Select a workflow</option>
-      @for (workflow of workflows; track workflow.id) {
-        <option [ngValue]="workflow.id">{{workflow.name}}</option>
-      }
-    </select>
-  </div>
-  <div class="form-check">
-    <input class="form-check-input" type="checkbox" id="runWorkflowForce" [(ngModel)]="force" />
-    @if (singleDocument) {
-      <label class="form-check-label" for="runWorkflowForce" i18n>Run on this document regardless of trigger filters</label>
-      <div class="form-text" i18n>Ignore the workflow's trigger filters for this document.</div>
-    } @else {
-      <label class="form-check-label" for="runWorkflowForce" i18n>Run on all selected documents</label>
-      <div class="form-text" i18n>Ignore the workflow's trigger filters and run on every selected document.</div>
-    }
-  </div>
-</div>
-<div class="modal-footer">
-  <button type="button" class="btn" [class]="cancelBtnClass" (click)="cancel()" [disabled]="!buttonsEnabled">
-    <span class="d-inline-block" style="padding-bottom: 1px;">{{cancelBtnCaption}}</span>
-  </button>
-  <button type="button" class="btn" [class]="btnClass" (click)="confirm()" [disabled]="!confirmButtonEnabled || !buttonsEnabled">
-    {{btnCaption}}
-  </button>
-</div>
@@ -1,63 +0,0 @@
-import { ComponentFixture, TestBed } from '@angular/core/testing'
-import { NgbActiveModal } from '@ng-bootstrap/ng-bootstrap'
-import { RunWorkflowConfirmDialogComponent } from './run-workflow-confirm-dialog.component'
-
-describe('RunWorkflowConfirmDialogComponent', () => {
-  let component: RunWorkflowConfirmDialogComponent
-  let fixture: ComponentFixture<RunWorkflowConfirmDialogComponent>
-
-  beforeEach(async () => {
-    TestBed.configureTestingModule({
-      providers: [NgbActiveModal],
-      imports: [RunWorkflowConfirmDialogComponent],
-    }).compileComponents()
-
-    fixture = TestBed.createComponent(RunWorkflowConfirmDialogComponent)
-    component = fixture.componentInstance
-    component.workflows = [{ id: 5, name: 'Manual workflow' } as any]
-    fixture.detectChanges()
-  })
-
-  it('should disable confirm until a workflow is selected and not force by default', () => {
-    expect(component.confirmButtonEnabled).toBeFalsy()
-    expect(component.force).toBeFalsy()
-
-    component.workflowId = 5
-    component.workflowSelected()
-    expect(component.confirmButtonEnabled).toBeTruthy()
-
-    component.workflowId = null
-    component.workflowSelected()
-    expect(component.confirmButtonEnabled).toBeFalsy()
-  })
-
-  it('should render an option per workflow', () => {
-    const options = fixture.nativeElement.querySelectorAll(
-      '#runWorkflowSelect option'
-    )
-    // placeholder option + one per workflow
-    expect(options).toHaveLength(2)
-    expect(options[1].textContent).toContain('Manual workflow')
-  })
-
-  it('should describe the checkbox for a selection or a single document', async () => {
-    const checkbox = fixture.nativeElement.querySelector('#runWorkflowForce')
-    expect(checkbox.checked).toBe(false)
-    expect(fixture.nativeElement.textContent).toContain(
-      'Run on all selected documents'
-    )
-
-    component.singleDocument = true
-    component.force = true
-    fixture.detectChanges()
-    await fixture.whenStable()
-    fixture.detectChanges()
-    expect(checkbox.checked).toBe(true)
-    expect(fixture.nativeElement.textContent).toContain(
-      'Run on this document regardless of trigger filters'
-    )
-    expect(fixture.nativeElement.textContent).not.toContain(
-      'Run on all selected documents'
-    )
-  })
-})
@@ -1,26 +0,0 @@
-import { Component } from '@angular/core'
-import { FormsModule } from '@angular/forms'
-import { Workflow } from 'src/app/data/workflow'
-import { ConfirmDialogComponent } from '../confirm-dialog.component'
-
-@Component({
-  selector: 'pngx-run-workflow-confirm-dialog',
-  templateUrl: './run-workflow-confirm-dialog.component.html',
-  imports: [FormsModule],
-})
-export class RunWorkflowConfirmDialogComponent extends ConfirmDialogComponent {
-  public workflows: Workflow[] = []
-
-  public workflowId: number = null
-
-  public singleDocument: boolean = false
-
-  // i.e. ignore the workflow's trigger filters
-  public force: boolean = false
-
-  override confirmButtonEnabled = false
-
-  public workflowSelected(): void {
-    this.confirmButtonEnabled = !!this.workflowId
-  }
-}
@@ -164,7 +164,7 @@
          <pngx-input-text i18n-title title="Filter path" formControlName="filter_path" horizontal="true" i18n-hint hint="Apply to documents that match this path. Wildcards specified as * are allowed. Case-normalized." [error]="error?.filter_path"></pngx-input-text>
          <pngx-input-select i18n-title title="Filter mail rule" [items]="mailRules()" horizontal="true" [allowNull]="true" formControlName="filter_mailrule" i18n-hint hint="Apply to documents consumed via this mail rule." [error]="error?.filter_mailrule"></pngx-input-select>
        }
-        @if (formGroup.get('type').value === WorkflowTriggerType.DocumentAdded || formGroup.get('type').value === WorkflowTriggerType.DocumentUpdated || formGroup.get('type').value === WorkflowTriggerType.Scheduled || formGroup.get('type').value === WorkflowTriggerType.Manual) {
+        @if (formGroup.get('type').value === WorkflowTriggerType.DocumentAdded || formGroup.get('type').value === WorkflowTriggerType.DocumentUpdated || formGroup.get('type').value === WorkflowTriggerType.Scheduled) {
          <pngx-input-select i18n-title title="Content matching algorithm" horizontal="true" [items]="getMatchingAlgorithms()" formControlName="matching_algorithm"></pngx-input-select>
          @if (matchingPatternRequired(formGroup)) {
            <pngx-input-text i18n-title title="Content matching pattern" horizontal="true" formControlName="match" [error]="error?.match"></pngx-input-text>
@@ -175,7 +175,7 @@
        }
      </div>
    </div>
-    @if (formGroup.get('type').value === WorkflowTriggerType.DocumentAdded || formGroup.get('type').value === WorkflowTriggerType.DocumentUpdated || formGroup.get('type').value === WorkflowTriggerType.Scheduled || formGroup.get('type').value === WorkflowTriggerType.Manual) {
+    @if (formGroup.get('type').value === WorkflowTriggerType.DocumentAdded || formGroup.get('type').value === WorkflowTriggerType.DocumentUpdated || formGroup.get('type').value === WorkflowTriggerType.Scheduled) {
      <div class="row mt-3">
        <div class="col">
          <div class="trigger-filters mb-3">
@@ -123,10 +123,6 @@ export const WORKFLOW_TYPE_OPTIONS = [
    id: WorkflowTriggerType.Scheduled,
    name: $localize`Scheduled`,
  },
-  {
-    id: WorkflowTriggerType.Manual,
-    name: $localize`Manual`,
-  },
 ]

 export const WORKFLOW_ACTION_OPTIONS = [
@@ -49,12 +49,6 @@
        <pngx-bs-icon width="1em" height="1em" name="arrow-counterclockwise" class="me-2"></pngx-bs-icon><span i18n>Reprocess</span>
      </button>

-      @if (manualWorkflows().length > 0) {
-        <button ngbDropdownItem (click)="runWorkflow()" [disabled]="!userCanEdit || !userIsOwner">
-          <pngx-bs-icon width="1em" height="1em" name="play-circle" class="me-2"></pngx-bs-icon><span i18n>Run workflow</span>
-        </button>
-      }
-
      <button ngbDropdownItem (click)="printDocument()" [hidden]="useNativePdfViewer || isMobile">
        <pngx-bs-icon width="1em" height="1em" name="printer" class="me-2"></pngx-bs-icon><span i18n>Print</span>
      </button>
@@ -1013,77 +1013,27 @@ describe('DocumentDetailComponent', () => {
    ])
  })

-  it('should queue reprocess, show the task link and close the modal', () => {
+  it('should support reprocess, confirm and close modal after started', () => {
    initNormally()
    const reprocessSpy = jest.spyOn(documentService, 'reprocessDocuments')
-    reprocessSpy.mockReturnValue(of({ result: 'OK', task_id: 'reprocess-1' }))
+    reprocessSpy.mockReturnValue(of(true))
    let openModal: NgbModalRef
    modalService.activeInstances.subscribe((modal) => (openModal = modal[0]))
    const modalSpy = jest.spyOn(modalService, 'open')
-    const toastSpy = jest.spyOn(toastService, 'show')
+    const toastSpy = jest.spyOn(toastService, 'showInfo')
    component.reprocess()
    const modalCloseSpy = jest.spyOn(openModal, 'close')
    openModal.componentInstance.confirmClicked.next()
    expect(reprocessSpy).toHaveBeenCalledWith({ documents: [doc.id] }, false)
    expect(modalSpy).toHaveBeenCalled()
-    expect(toastSpy).toHaveBeenCalledWith(
-      expect.objectContaining({
-        content: 'Document reprocessing queued.',
-        actionName: 'View task',
-      })
-    )
-    toastSpy.mock.calls.at(-1)[0].action()
-    expect(router.navigate).toHaveBeenCalledWith(['/tasks'], {
-      queryParams: { task_id: 'reprocess-1' },
-    })
+    expect(toastSpy).toHaveBeenCalled()
    expect(modalCloseSpy).toHaveBeenCalled()
  })

-  it('should run a workflow on the document, confirm and close modal', () => {
-    initNormally()
-    const bulkEditSpy = jest.spyOn(documentService, 'bulkEdit')
-    bulkEditSpy.mockReturnValue(of({ result: 'OK', task_id: 'workflow-1' }))
-    let openModal: NgbModalRef
-    modalService.activeInstances.subscribe((modal) => (openModal = modal[0]))
-    const toastSpy = jest.spyOn(toastService, 'show')
-    component.runWorkflow()
-    expect(openModal.componentInstance.singleDocument).toBe(true)
-    expect(openModal.componentInstance.force).toBe(true)
-    const modalCloseSpy = jest.spyOn(openModal, 'close')
-    openModal.componentInstance.workflowId = 5
-    openModal.componentInstance.confirmClicked.next()
-    expect(bulkEditSpy).toHaveBeenCalledWith(
-      { documents: [doc.id] },
-      'run_workflow',
-      { workflow: 5, filter_documents: false }
-    )
-    expect(toastSpy).toHaveBeenCalledWith(
-      expect.objectContaining({ content: 'Workflow queued.' })
-    )
-    expect(modalCloseSpy).toHaveBeenCalled()
-  })
-
-  it('should apply workflow filters when the single-document checkbox is cleared', () => {
-    initNormally()
-    const bulkEditSpy = jest.spyOn(documentService, 'bulkEdit')
-    bulkEditSpy.mockReturnValue(of({ result: 'OK', task_id: 'workflow-2' }))
-    let openModal: NgbModalRef
-    modalService.activeInstances.subscribe((modal) => (openModal = modal[0]))
-    component.runWorkflow()
-    openModal.componentInstance.workflowId = 5
-    openModal.componentInstance.force = false
-    openModal.componentInstance.confirmClicked.next()
-    expect(bulkEditSpy).toHaveBeenCalledWith(
-      { documents: [doc.id] },
-      'run_workflow',
-      { workflow: 5, filter_documents: true }
-    )
-  })
-
  it('should pass remote OCR choice when reprocessing', () => {
    initNormally()
    const reprocessSpy = jest.spyOn(documentService, 'reprocessDocuments')
-    reprocessSpy.mockReturnValue(of({ result: 'OK', task_id: 'reprocess-2' }))
+    reprocessSpy.mockReturnValue(of(true))
    let openModal: NgbModalRef
    modalService.activeInstances.subscribe((modal) => (openModal = modal[0]))
    component.reprocess()
@@ -2016,7 +1966,6 @@ describe('DocumentDetailComponent', () => {
    modalService.activeInstances.subscribe((m) => (modal = m[0]))
    const closeSpy = jest.spyOn(openDocumentsService, 'closeDocument')
    const errorSpy = jest.spyOn(toastService, 'showError')
-    const queuedToastSpy = jest.spyOn(toastService, 'show')
    initNormally()
    component.selectedVersionId.set(10)
    component.editPdf()
@@ -2035,7 +1984,6 @@ describe('DocumentDetailComponent', () => {
      update_document: false,
      include_metadata: true,
      source_mode: 'explicit_selection',
-      from_webui: true,
    })
    req.error(new ErrorEvent('failed'))
    expect(errorSpy).toHaveBeenCalled()
@@ -2048,18 +1996,13 @@ describe('DocumentDetailComponent', () => {
    req = httpTestingController.expectOne(
      `${environment.apiBaseUrl}documents/edit_pdf/`
    )
-    req.flush({ result: 'OK', task_id: 'edit-pdf-1' })
-    expect(closeSpy).not.toHaveBeenCalled()
-    expect(queuedToastSpy).toHaveBeenCalledWith(
-      expect.objectContaining({ content: 'PDF edit queued.' })
-    )
+    req.flush(true)
+    expect(closeSpy).toHaveBeenCalled()
  })

  it('should support removing password protection from pdfs', () => {
    let modal: NgbModalRef
    modalService.activeInstances.subscribe((m) => (modal = m[0]))
-    const closeSpy = jest.spyOn(openDocumentsService, 'closeDocument')
-    const queuedToastSpy = jest.spyOn(toastService, 'show')
    initNormally()
    component.selectedVersionId.set(10)
    component.password = 'secret'
@@ -2080,13 +2023,8 @@ describe('DocumentDetailComponent', () => {
      include_metadata: false,
      delete_original: true,
      source_mode: 'explicit_selection',
-      from_webui: true,
    })
-    req.flush({ result: 'OK', task_id: 'remove-password-1' })
-    expect(closeSpy).not.toHaveBeenCalled()
-    expect(queuedToastSpy).toHaveBeenCalledWith(
-      expect.objectContaining({ content: 'Password removal queued.' })
-    )
+    req.flush(true)
  })

  it('should require the current password before removing it', () => {
@@ -2138,9 +2076,9 @@ describe('DocumentDetailComponent', () => {
    const req = httpTestingController.expectOne(
      `${environment.apiBaseUrl}documents/remove_password/`
    )
-    req.flush({ result: 'OK', task_id: 'remove-password-2' })
+    req.flush(true)

-    expect(refreshSpy).not.toHaveBeenCalled()
+    expect(refreshSpy).toHaveBeenCalledWith(doc.id)
  })

  it('should support keyboard shortcuts', () => {
@@ -68,8 +68,6 @@ import { StoragePath } from 'src/app/data/storage-path'
 import { Tag } from 'src/app/data/tag'
 import { SETTINGS_KEYS, SuggestionSource } from 'src/app/data/ui-settings'
 import { User } from 'src/app/data/user'
-import { Workflow } from 'src/app/data/workflow'
-import { WorkflowTriggerType } from 'src/app/data/workflow-trigger'
 import { IfPermissionsDirective } from 'src/app/directives/if-permissions.directive'
 import { CustomDatePipe } from 'src/app/pipes/custom-date.pipe'
 import { DocumentTitlePipe } from 'src/app/pipes/document-title.pipe'
@@ -95,7 +93,6 @@ import { SavedViewService } from 'src/app/services/rest/saved-view.service'
 import { StoragePathService } from 'src/app/services/rest/storage-path.service'
 import { TagService } from 'src/app/services/rest/tag.service'
 import { UserService } from 'src/app/services/rest/user.service'
-import { WorkflowService } from 'src/app/services/rest/workflow.service'
 import { SettingsService } from 'src/app/services/settings.service'
 import { ToastService } from 'src/app/services/toast.service'
 import { TrashService } from 'src/app/services/trash.service'
@@ -107,7 +104,6 @@ import { DocumentDetailFieldID } from '../admin/settings/settings.component'
 import { ConfirmDialogComponent } from '../common/confirm-dialog/confirm-dialog.component'
 import { PasswordRemovalConfirmDialogComponent } from '../common/confirm-dialog/password-removal-confirm-dialog/password-removal-confirm-dialog.component'
 import { ReprocessConfirmDialogComponent } from '../common/confirm-dialog/reprocess-confirm-dialog/reprocess-confirm-dialog.component'
-import { RunWorkflowConfirmDialogComponent } from '../common/confirm-dialog/run-workflow-confirm-dialog/run-workflow-confirm-dialog.component'
 import { CustomFieldsDropdownComponent } from '../common/custom-fields-dropdown/custom-fields-dropdown.component'
 import { CorrespondentEditDialogComponent } from '../common/edit-dialog/correspondent-edit-dialog/correspondent-edit-dialog.component'
 import { DocumentTypeEditDialogComponent } from '../common/edit-dialog/document-type-edit-dialog/document-type-edit-dialog.component'
@@ -237,7 +233,6 @@ export class DocumentDetailComponent
  private componentRouterService = inject(ComponentRouterService)
  private deviceDetectorService = inject(DeviceDetectorService)
  private savedViewService = inject(SavedViewService)
-  private readonly workflowService = inject(WorkflowService)
  private readonly websocketStatusService = inject(WebsocketStatusService)
  private readonly useNativePdfViewerSetting = this.settings.getSignal<boolean>(
    SETTINGS_KEYS.USE_NATIVE_PDF_VIEWER
@@ -300,7 +295,6 @@ export class DocumentDetailComponent
  readonly correspondents = signal<Correspondent[]>(undefined)
  readonly documentTypes = signal<DocumentType[]>(undefined)
  readonly storagePaths = signal<StoragePath[]>(undefined)
-  readonly manualWorkflows = signal<Workflow[]>([])

  documentForm: FormGroup = new FormGroup({
    title: new FormControl(''),
@@ -842,20 +836,6 @@ export class DocumentDetailComponent
        .pipe(first(), takeUntil(this.unsubscribeNotifier))
        .subscribe((result) => this.users.set(result.results))
    }
-    if (
-      this.permissionsService.currentUserCan(
-        PermissionAction.View,
-        PermissionType.Workflow
-      )
-    ) {
-      this.workflowService
-        .list(1, 100000, null, null, {
-          trigger_type: WorkflowTriggerType.Manual,
-          enabled: true,
-        })
-        .pipe(first(), takeUntil(this.unsubscribeNotifier))
-        .subscribe((result) => this.manualWorkflows.set(result.results))
-    }

    this.getCustomFields()

@@ -1558,10 +1538,9 @@ export class DocumentDetailComponent
          modal.componentInstance.remoteOcr
        )
        .subscribe({
-          next: ({ task_id }) => {
-            this.notifyTaskQueued(
-              task_id,
-              $localize`Document reprocessing queued.`
+          next: () => {
+            this.toastService.showInfo(
+              $localize`Reprocess operation for "${this.document().title}" will begin in the background.`
            )
            if (modal) {
              modal.close()
@@ -1580,59 +1559,6 @@ export class DocumentDetailComponent
    })
  }

-  runWorkflow() {
-    const modal = this.modalService.open(RunWorkflowConfirmDialogComponent, {
-      backdrop: 'static',
-    })
-    modal.componentInstance.title = $localize`Run workflow`
-    modal.componentInstance.message = $localize`Run a workflow on "${this.document().title}".`
-    modal.componentInstance.btnCaption = $localize`Run`
-    modal.componentInstance.workflows = this.manualWorkflows()
-    modal.componentInstance.singleDocument = true
-    modal.componentInstance.force = true
-    modal.componentInstance.confirmClicked.subscribe(() => {
-      modal.componentInstance.buttonsEnabled.set(false)
-      this.documentsService
-        .bulkEdit({ documents: [this.document().id] }, 'run_workflow', {
-          workflow: modal.componentInstance.workflowId,
-          filter_documents: !modal.componentInstance.force,
-        })
-        .subscribe({
-          next: ({ task_id }) => {
-            this.notifyTaskQueued(task_id, $localize`Workflow queued.`)
-            modal.close()
-          },
-          error: (error) => {
-            modal.componentInstance.buttonsEnabled.set(true)
-            this.toastService.showError(
-              $localize`Error executing operation`,
-              error
-            )
-          },
-        })
-    })
-  }
-
-  private notifyTaskQueued(taskId: string, content: string) {
-    const canViewTasks = this.permissionsService.currentUserCan(
-      PermissionAction.View,
-      PermissionType.PaperlessTask
-    )
-    this.toastService.show({
-      content,
-      delay: 5000,
-      ...(canViewTasks
-        ? {
-            actionName: $localize`View task`,
-            action: () =>
-              this.router.navigate(['/tasks'], {
-                queryParams: { task_id: taskId },
-              }),
-          }
-        : {}),
-    })
-  }
-
  private getSelectedNonLatestVersionId(): number | null {
    const versions = this.document()?.versions ?? []
    if (!versions.length || !this.selectedVersionId()) {
@@ -2008,9 +1934,14 @@ export class DocumentDetailComponent
          })
          .pipe(first(), takeUntil(this.unsubscribeNotifier))
          .subscribe({
-            next: ({ task_id }) => {
-              this.notifyTaskQueued(task_id, $localize`PDF edit queued.`)
+            next: () => {
+              this.toastService.showInfo(
+                $localize`PDF edit operation for "${this.document().title}" will begin in the background.`
+              )
              modal.close()
+              if (modal.componentInstance.deleteOriginal) {
+                this.openDocumentService.closeDocument(this.document())
+              }
            },
            error: (error) => {
              if (modal) {
@@ -2060,13 +1991,17 @@ export class DocumentDetailComponent
          })
          .pipe(first(), takeUntil(this.unsubscribeNotifier))
          .subscribe({
-            next: ({ task_id }) => {
-              this.notifyTaskQueued(
-                task_id,
-                $localize`Password removal queued.`
+            next: () => {
+              this.toastService.showInfo(
+                $localize`Password removal operation for "${this.document().title}" will begin in the background.`
              )
              this.networkActive.set(false)
              modal.close()
+              if (!dialog.updateDocument && dialog.deleteOriginal) {
+                this.openDocumentService.closeDocument(this.document())
+              } else if (dialog.updateDocument) {
+                this.openDocumentService.refreshDocument(this.documentId())
+              }
            },
            error: (error) => {
              dialog.buttonsEnabled.set(true)
@@ -2,7 +2,6 @@ import { DatePipe } from '@angular/common'
 import { SimpleChange, signal } from '@angular/core'
 import { ComponentFixture, TestBed } from '@angular/core/testing'
 import { By } from '@angular/platform-browser'
-import { Router } from '@angular/router'
 import { NgbModal } from '@ng-bootstrap/ng-bootstrap'
 import { Subject, of, throwError } from 'rxjs'
 import { DocumentVersionInfo } from 'src/app/data/document'
@@ -34,7 +33,7 @@ describe('DocumentVersionDropdownComponent', () => {
    >
  >
  let toastService: jest.Mocked<
-    Pick<ToastService, 'show' | 'showError' | 'showInfo' | 'showSuccess'>
+    Pick<ToastService, 'showError' | 'showInfo' | 'showSuccess'>
  >
  let finished$: Subject<{ taskId: string }>
  let failed$: Subject<{ taskId: string; message?: string }>
@@ -55,7 +54,6 @@ describe('DocumentVersionDropdownComponent', () => {
    }
    modalService = { open: jest.fn() }
    toastService = {
-      show: jest.fn(),
      showError: jest.fn(),
      showInfo: jest.fn(),
      showSuccess: jest.fn(),
@@ -90,10 +88,6 @@ describe('DocumentVersionDropdownComponent', () => {
          provide: PermissionsService,
          useValue: permissionsService,
        },
-        {
-          provide: Router,
-          useValue: { navigate: jest.fn() },
-        },
        {
          provide: WebsocketStatusService,
          useValue: {
@@ -383,7 +377,7 @@ describe('DocumentVersionDropdownComponent', () => {
    expect(component.versionLabelDraft).toEqual('')
  })

-  it('addExistingDocumentAsVersion should queue with a label and wait to refresh versions', () => {
+  it('addExistingDocumentAsVersion should merge with a label and refresh versions', () => {
    const confirmClicked = new Subject<number>()
    const modal = {
      componentInstance: {
@@ -394,9 +388,14 @@ describe('DocumentVersionDropdownComponent', () => {
      close: jest.fn(),
    }
    modalService.open.mockReturnValue(modal as any)
-    documentService.mergeDocumentsAsVersions.mockReturnValue(
-      of({ result: 'OK', task_id: 'versions-1' })
-    )
+    documentService.mergeDocumentsAsVersions.mockReturnValue(of({} as any))
+    // Newest first, as the API returns them. The merged document has a lower id
+    // than the root, which is the whole point of merging an existing document.
+    const versions: DocumentVersionInfo[] = [
+      { id: 2, is_root: false, checksum: 'cccc' },
+      { id: 3, is_root: true, checksum: 'aaaa' },
+    ]
+    documentService.getVersions.mockReturnValue(of({ id: 3, versions } as any))
    component.newVersionLabel = '  Imported  '
    const versionsEmitSpy = jest.spyOn(component.versionsUpdated, 'emit')
    const selectedEmitSpy = jest.spyOn(component.versionSelected, 'emit')
@@ -411,16 +410,11 @@ describe('DocumentVersionDropdownComponent', () => {
      'Imported'
    )
    expect(documentService.updateVersionLabel).not.toHaveBeenCalled()
-    expect(documentService.getVersions).not.toHaveBeenCalled()
-    expect(versionsEmitSpy).not.toHaveBeenCalled()
-    expect(selectedEmitSpy).not.toHaveBeenCalled()
+    expect(documentService.getVersions).toHaveBeenCalledWith(3)
+    expect(versionsEmitSpy).toHaveBeenCalledWith(versions)
+    expect(selectedEmitSpy).toHaveBeenCalledWith(2)
    expect(component.newVersionLabel).toEqual('')
    expect(modal.close).toHaveBeenCalled()
-    expect(toastService.show).toHaveBeenCalledWith(
-      expect.objectContaining({
-        content: 'Existing document queued to be added as a version.',
-        actionName: 'View task',
-      })
-    )
+    expect(toastService.showSuccess).toHaveBeenCalled()
  })
 })
@@ -11,7 +11,6 @@ import {
  SimpleChanges,
 } from '@angular/core'
 import { FormsModule } from '@angular/forms'
-import { Router } from '@angular/router'
 import { NgbDropdownModule, NgbModal } from '@ng-bootstrap/ng-bootstrap'
 import { merge, of, Subject } from 'rxjs'
 import {
@@ -28,11 +27,6 @@ import { BootstrapIconComponent } from 'src/app/components/common/bootstrap-icon
 import { DocumentVersionInfo } from 'src/app/data/document'
 import { IfPermissionsDirective } from 'src/app/directives/if-permissions.directive'
 import { CustomDatePipe } from 'src/app/pipes/custom-date.pipe'
-import {
-  PermissionAction,
-  PermissionsService,
-  PermissionType,
-} from 'src/app/services/permissions.service'
 import { DocumentService } from 'src/app/services/rest/document.service'
 import { ToastService } from 'src/app/services/toast.service'
 import {
@@ -83,8 +77,6 @@ export class DocumentVersionDropdownComponent
  private readonly toastService = inject(ToastService)
  private readonly websocketStatusService = inject(WebsocketStatusService)
  private readonly modalService = inject(NgbModal)
-  private readonly router = inject(Router)
-  private readonly permissionsService = inject(PermissionsService)
  private readonly destroy$ = new Subject<void>()
  private readonly documentChange$ = new Subject<void>()

@@ -313,32 +305,24 @@ export class DocumentVersionDropdownComponent
            versionLabel
          )
          .pipe(
+            switchMap(() => this.documentsService.getVersions(this.documentId)),
            first(),
            finalize(() => dialog.buttonsEnabled.set(true)),
            takeUntil(this.destroy$),
            takeUntil(this.documentChange$)
          )
          .subscribe({
-            next: ({ task_id }) => {
+            next: (document) => {
+              if (document?.versions?.length) {
+                this.versionsUpdated.emit(document.versions)
+                // The API returns versions newest first
+                this.versionSelected.emit(document.versions[0].id)
+              }
              this.newVersionLabel = ''
              modal.close()
-              const canViewTasks = this.permissionsService.currentUserCan(
-                PermissionAction.View,
-                PermissionType.PaperlessTask
+              this.toastService.showSuccess(
+                $localize`Existing document added as a version.`
              )
-              this.toastService.show({
-                content: $localize`Existing document queued to be added as a version.`,
-                delay: 5000,
-                ...(canViewTasks
-                  ? {
-                      actionName: $localize`View task`,
-                      action: () =>
-                        this.router.navigate(['/tasks'], {
-                          queryParams: { task_id },
-                        }),
-                    }
-                  : {}),
-              })
            },
            error: (error) => {
              this.toastService.showError(
@@ -98,11 +98,6 @@
          <button ngbDropdownItem (click)="mergeSelectedAsVersions()" [disabled]="!userOwnsAll || !userCanEditAll || !userCanDelete || list.allSelected || list.selectedCount < 2">
            <pngx-bs-icon name="journal-bookmark-fill" class="me-2"></pngx-bs-icon><ng-container i18n>Merge as versions</ng-container>
          </button>
-          @if (manualWorkflows.length > 0) {
-            <button ngbDropdownItem (click)="runWorkflowSelected()" [disabled]="!canRunWorkflow">
-              <pngx-bs-icon name="play-circle" class="me-2"></pngx-bs-icon><ng-container i18n>Run workflow</ng-container>
-            </button>
-          }
        </div>
      </div>
    </div>
@@ -17,7 +17,6 @@ import { FILTER_TITLE } from 'src/app/data/filter-rule-type'
 import { Results } from 'src/app/data/results'
 import { StoragePath } from 'src/app/data/storage-path'
 import { Tag } from 'src/app/data/tag'
-import { WorkflowTriggerType } from 'src/app/data/workflow-trigger'
 import { FilterPipe } from 'src/app/pipes/filter.pipe'
 import { DocumentListViewService } from 'src/app/services/document-list-view.service'
 import {
@@ -37,7 +36,6 @@ import { ShareLinkBundleService } from 'src/app/services/rest/share-link-bundle.
 import { StoragePathService } from 'src/app/services/rest/storage-path.service'
 import { TagService } from 'src/app/services/rest/tag.service'
 import { UserService } from 'src/app/services/rest/user.service'
-import { WorkflowService } from 'src/app/services/rest/workflow.service'
 import { SettingsService } from 'src/app/services/settings.service'
 import { ToastService } from 'src/app/services/toast.service'
 import { TrashService } from 'src/app/services/trash.service'
@@ -85,7 +83,6 @@ describe('BulkEditorComponent', () => {
  let customFieldsService: CustomFieldsService
  let httpTestingController: HttpTestingController
  let shareLinkBundleService: ShareLinkBundleService
-  let workflowService: WorkflowService
  let router: Router

  beforeEach(async () => {
@@ -176,22 +173,6 @@ describe('BulkEditorComponent', () => {
            delete: jest.fn(),
          },
        },
-        {
-          provide: WorkflowService,
-          useValue: {
-            list: jest.fn(() =>
-              of({
-                results: [
-                  {
-                    id: 5,
-                    name: 'Manual workflow',
-                    triggers: [{ type: WorkflowTriggerType.Manual }],
-                  },
-                ],
-              })
-            ),
-          },
-        },
        {
          provide: Router,
          useValue: { navigate: jest.fn().mockResolvedValue(true) },
@@ -214,7 +195,6 @@ describe('BulkEditorComponent', () => {
    customFieldsService = TestBed.inject(CustomFieldsService)
    httpTestingController = TestBed.inject(HttpTestingController)
    shareLinkBundleService = TestBed.inject(ShareLinkBundleService)
-    workflowService = TestBed.inject(WorkflowService)
    router = TestBed.inject(Router)

    fixture = TestBed.createComponent(BulkEditorComponent)
@@ -674,53 +654,6 @@ describe('BulkEditorComponent', () => {
    )
  })

-  it('should load manual workflows on init', () => {
-    jest.spyOn(permissionsService, 'currentUserCan').mockReturnValue(true)
-    fixture.detectChanges()
-    expect(workflowService.list).toHaveBeenCalledWith(1, 100000, null, null, {
-      trigger_type: WorkflowTriggerType.Manual,
-      enabled: true,
-    })
-    expect(component.manualWorkflows).toHaveLength(1)
-    expect(component.manualWorkflows[0].id).toEqual(5)
-  })
-
-  it('should run a workflow on the selection via the run workflow dialog', () => {
-    let modal: NgbModalRef
-    modalService.activeInstances.subscribe((m) => (modal = m[0]))
-    jest.spyOn(permissionsService, 'currentUserCan').mockReturnValue(true)
-    jest
-      .spyOn(documentListViewService, 'documents', 'get')
-      .mockReturnValue([{ id: 3 }, { id: 4 }])
-    jest
-      .spyOn(documentListViewService, 'selected', 'get')
-      .mockReturnValue(new Set([3, 4]))
-    fixture.detectChanges()
-    component.runWorkflowSelected()
-    expect(modal).not.toBeUndefined()
-    expect(modal.componentInstance.workflows).toEqual(component.manualWorkflows)
-    expect(modal.componentInstance.singleDocument).toBe(false)
-    expect(modal.componentInstance.force).toBe(false)
-    modal.componentInstance.workflowId = 5
-    modal.componentInstance.force = true
-    modal.componentInstance.confirm()
-    const req = httpTestingController.expectOne(
-      `${environment.apiBaseUrl}documents/bulk_edit/`
-    )
-    expect(req.request.body.method).toEqual('run_workflow')
-    expect(req.request.body.parameters).toEqual({
-      workflow: 5,
-      filter_documents: false,
-    })
-    req.flush(true)
-    httpTestingController.match(
-      `${environment.apiBaseUrl}documents/?page=1&page_size=50&ordering=-created&truncate_content=true&include_selection_data=true`
-    ) // list reload
-    httpTestingController.match(
-      `${environment.apiBaseUrl}documents/?page=1&page_size=100000&fields=id`
-    ) // listAllFilteredIds
-  })
-
  it('should set modal dialog text accordingly for tag edit confirmation', () => {
    let modal: NgbModalRef
    modalService.activeInstances.subscribe((m) => (modal = m[m.length - 1]))
@@ -1239,15 +1172,14 @@ describe('BulkEditorComponent', () => {
    let req = httpTestingController.expectOne(
      `${environment.apiBaseUrl}documents/delete/`
    )
-    const trackSpy = jest
-      .spyOn(trashService, 'trackMovedToTrash')
+    const notifySpy = jest
+      .spyOn(trashService, 'notifyMovedToTrash')
      .mockImplementation(() => {})
-    req.flush({ result: 'OK', task_id: 'delete-1' })
+    req.flush(true)
    expect(req.request.body).toEqual({
      documents: [3, 4],
-      from_webui: true,
    })
-    expect(trackSpy).toHaveBeenCalledWith('delete-1', 2, [3, 4])
+    expect(notifySpy).toHaveBeenCalledWith(expect.any(String), [3, 4])
    httpTestingController.match(
      `${environment.apiBaseUrl}documents/?page=1&page_size=50&ordering=-created&truncate_content=true&include_selection_data=true`
    ) // list reload
@@ -1264,9 +1196,9 @@ describe('BulkEditorComponent', () => {
    req = httpTestingController.expectOne(
      `${environment.apiBaseUrl}documents/delete/`
    )
-    req.flush({ result: 'OK', task_id: 'delete-2' })
+    req.flush(true)
    // ids aren't known when all matching documents are selected, so no undo
-    expect(trackSpy).toHaveBeenLastCalledWith('delete-2', 0, null)
+    expect(notifySpy).toHaveBeenLastCalledWith(expect.any(String), null)
    httpTestingController.match(
      `${environment.apiBaseUrl}documents/?page=1&page_size=50&ordering=-created&truncate_content=true&include_selection_data=true`
    ) // list reload
@@ -1346,11 +1278,10 @@ describe('BulkEditorComponent', () => {
    let req = httpTestingController.expectOne(
      `${environment.apiBaseUrl}documents/reprocess/`
    )
-    req.flush({ result: 'OK', task_id: 'reprocess-1' })
+    req.flush(true)
    expect(req.request.body).toEqual({
      documents: [3, 4],
      remote_ocr: false,
-      from_webui: true,
    })
    httpTestingController.match(
      `${environment.apiBaseUrl}documents/?page=1&page_size=50&ordering=-created&truncate_content=true&include_selection_data=true`
@@ -1381,12 +1312,11 @@ describe('BulkEditorComponent', () => {
    let req = httpTestingController.expectOne(
      `${environment.apiBaseUrl}documents/rotate/`
    )
-    req.flush({ result: 'OK', task_id: 'rotate-1' })
+    req.flush(true)
    expect(req.request.body).toEqual({
      documents: [3, 4],
      degrees: 90,
      source_mode: 'latest_version',
-      from_webui: true,
    })
    httpTestingController.match(
      `${environment.apiBaseUrl}documents/?page=1&page_size=50&ordering=-created&truncate_content=true&include_selection_data=true`
@@ -1424,11 +1354,10 @@ describe('BulkEditorComponent', () => {
    let req = httpTestingController.expectOne(
      `${environment.apiBaseUrl}documents/merge/`
    )
-    req.flush({ result: 'OK', task_id: 'merge-1' })
+    req.flush(true)
    expect(req.request.body).toEqual({
      documents: [3, 4],
      metadata_document_id: 3,
-      from_webui: true,
    })
    httpTestingController.match(
      `${environment.apiBaseUrl}documents/?page=1&page_size=50&ordering=-created&truncate_content=true&include_selection_data=true`
@@ -1443,12 +1372,11 @@ describe('BulkEditorComponent', () => {
    req = httpTestingController.expectOne(
      `${environment.apiBaseUrl}documents/merge/`
    )
-    req.flush({ result: 'OK', task_id: 'merge-2' })
+    req.flush(true)
    expect(req.request.body).toEqual({
      documents: [3, 4],
      metadata_document_id: 3,
      delete_originals: true,
-      from_webui: true,
    })
    httpTestingController.match(
      `${environment.apiBaseUrl}documents/?page=1&page_size=50&ordering=-created&truncate_content=true&include_selection_data=true`
@@ -1465,12 +1393,11 @@ describe('BulkEditorComponent', () => {
    req = httpTestingController.expectOne(
      `${environment.apiBaseUrl}documents/merge/`
    )
-    req.flush({ result: 'OK', task_id: 'merge-3' })
+    req.flush(true)
    expect(req.request.body).toEqual({
      documents: [3, 4],
      metadata_document_id: 3,
      archive_fallback: true,
-      from_webui: true,
    })
    httpTestingController.match(
      `${environment.apiBaseUrl}documents/?page=1&page_size=50&ordering=-created&truncate_content=true&include_selection_data=true`
@@ -1509,8 +1436,8 @@ describe('BulkEditorComponent', () => {
      .mockReturnValue(true)
    const mergeAsVersionsSpy = jest
      .spyOn(documentService, 'mergeDocumentsAsVersions')
-      .mockReturnValue(of({ result: 'OK', task_id: 'versions-1' }))
-    const toastSpy = jest.spyOn(toastService, 'show')
+      .mockReturnValue(of(true))
+    const toastSuccessSpy = jest.spyOn(toastService, 'showSuccess')
    fixture.detectChanges()

    component.mergeSelectedAsVersions()
@@ -1526,8 +1453,8 @@ describe('BulkEditorComponent', () => {
      `${environment.apiBaseUrl}documents/?page=1&page_size=100000&fields=id`
    )
    expect(documentListViewService.selected.size).toEqual(0)
-    expect(toastSpy).toHaveBeenCalledWith(
-      expect.objectContaining({ content: 'Bulk operation queued.' })
+    expect(toastSuccessSpy).toHaveBeenCalledWith(
+      'Documents merged as versions.'
    )
  })

@@ -19,17 +19,24 @@ import {
  NgbModalRef,
 } from '@ng-bootstrap/ng-bootstrap'
 import { saveAs } from 'file-saver'
-import { first, map, Observable, Subject, switchMap, takeUntil } from 'rxjs'
-import { BulkOperationResponse } from 'src/app/data/bulk-operation'
+import {
+  first,
+  map,
+  Observable,
+  Subject,
+  switchMap,
+  takeUntil,
+  tap,
+} from 'rxjs'
 import { BootstrapIconComponent } from 'src/app/components/common/bootstrap-icon/bootstrap-icon.component'
 import { ConfirmDialogComponent } from 'src/app/components/common/confirm-dialog/confirm-dialog.component'
 import { CustomField } from 'src/app/data/custom-field'
 import { MatchingModel } from 'src/app/data/matching-model'
 import { SelectionDataItem } from 'src/app/data/results'
 import { SETTINGS_KEYS } from 'src/app/data/ui-settings'
-import { Workflow } from 'src/app/data/workflow'
 import { IfPermissionsDirective } from 'src/app/directives/if-permissions.directive'
 import { DocumentListViewService } from 'src/app/services/document-list-view.service'
+import { OpenDocumentsService } from 'src/app/services/open-documents.service'
 import {
  PermissionAction,
  PermissionsService,
@@ -44,8 +51,8 @@ import {
  DocumentService,
  MergeDocumentsRequest,
 } from 'src/app/services/rest/document.service'
+import { SavedViewService } from 'src/app/services/rest/saved-view.service'
 import { ShareLinkBundleService } from 'src/app/services/rest/share-link-bundle.service'
-import { WorkflowService } from 'src/app/services/rest/workflow.service'
 import { StoragePathService } from 'src/app/services/rest/storage-path.service'
 import { TagService } from 'src/app/services/rest/tag.service'
 import { SettingsService } from 'src/app/services/settings.service'
@@ -57,7 +64,6 @@ import { MergeAsVersionsConfirmDialogComponent } from '../../common/confirm-dial
 import { MergeConfirmDialogComponent } from '../../common/confirm-dialog/merge-confirm-dialog/merge-confirm-dialog.component'
 import { ReprocessConfirmDialogComponent } from '../../common/confirm-dialog/reprocess-confirm-dialog/reprocess-confirm-dialog.component'
 import { RotateConfirmDialogComponent } from '../../common/confirm-dialog/rotate-confirm-dialog/rotate-confirm-dialog.component'
-import { RunWorkflowConfirmDialogComponent } from '../../common/confirm-dialog/run-workflow-confirm-dialog/run-workflow-confirm-dialog.component'
 import { CorrespondentEditDialogComponent } from '../../common/edit-dialog/correspondent-edit-dialog/correspondent-edit-dialog.component'
 import { CustomFieldEditDialogComponent } from '../../common/edit-dialog/custom-field-edit-dialog/custom-field-edit-dialog.component'
 import { DocumentTypeEditDialogComponent } from '../../common/edit-dialog/document-type-edit-dialog/document-type-edit-dialog.component'
@@ -75,7 +81,6 @@ import { PermissionsDialogComponent } from '../../common/permissions-dialog/perm
 import { ShareLinkBundleDialogComponent } from '../../common/share-link-bundle-dialog/share-link-bundle-dialog.component'
 import { ComponentWithPermissions } from '../../with-permissions/with-permissions.component'
 import { CustomFieldsBulkEditDialogComponent } from './custom-fields-bulk-edit-dialog/custom-fields-bulk-edit-dialog.component'
-import { WorkflowTriggerType } from 'src/app/data/workflow-trigger'

@Component({
  selector: 'pngx-bulk-editor',
@@ -101,17 +106,16 @@ export class BulkEditorComponent
  private documentService = inject(DocumentService)
  private trashService = inject(TrashService)
  private modalService = inject(NgbModal)
+  private openDocumentService = inject(OpenDocumentsService)
  private settings = inject(SettingsService)
  private toastService = inject(ToastService)
  private storagePathService = inject(StoragePathService)
  private customFieldService = inject(CustomFieldsService)
  public readonly permissionService = inject(PermissionsService)
+  private savedViewService = inject(SavedViewService)
  private readonly shareLinkBundleService = inject(ShareLinkBundleService)
-  private readonly workflowService = inject(WorkflowService)
  private readonly router = inject(Router)

-  public manualWorkflows: Workflow[] = []
-
  tagSelectionModel = new FilterableDropdownSelectionModel(true)
  correspondentSelectionModel = new FilterableDropdownSelectionModel()
  documentTypeSelectionModel = new FilterableDropdownSelectionModel()
@@ -254,20 +258,6 @@ export class BulkEditorComponent
          (result) => (this.customFieldsSelectionModel.items = result.results)
        )
    }
-    if (
-      this.permissionService.currentUserCan(
-        PermissionAction.View,
-        PermissionType.Workflow
-      )
-    ) {
-      this.workflowService
-        .list(1, 100000, null, null, {
-          trigger_type: WorkflowTriggerType.Manual,
-          enabled: true,
-        })
-        .pipe(first())
-        .subscribe((result) => (this.manualWorkflows = result.results))
-    }

    this.downloadForm
      .get('downloadFileTypeArchive')
@@ -296,28 +286,6 @@ export class BulkEditorComponent
    this.unsubscribeNotifier.complete()
  }

-  get canRunWorkflow(): boolean {
-    return this.userCanEditAll && this.manualWorkflows.length > 0
-  }
-
-  runWorkflowSelected() {
-    const modal = this.modalService.open(RunWorkflowConfirmDialogComponent, {
-      backdrop: 'static',
-    })
-    modal.componentInstance.title = $localize`Run workflow`
-    modal.componentInstance.message = $localize`Run a workflow on ${this.getSelectionSize()} selected document(s).`
-    modal.componentInstance.btnCaption = $localize`Run`
-    modal.componentInstance.workflows = this.manualWorkflows
-    modal.componentInstance.confirmClicked
-      .pipe(takeUntil(this.unsubscribeNotifier))
-      .subscribe(() => {
-        this.executeBulkEditMethod(modal, 'run_workflow', {
-          workflow: modal.componentInstance.workflowId,
-          filter_documents: !modal.componentInstance.force,
-        })
-      })
-  }
-
  private executeBulkEditMethod(
    modal: NgbModalRef,
    method: DocumentBulkEditMethod,
@@ -360,21 +328,41 @@ export class BulkEditorComponent

  private executeDocumentAction(
    modal: NgbModalRef,
-    request: Observable<BulkOperationResponse>,
-    onQueued?: (taskId: string) => void
+    request: Observable<any>,
+    options: { clearSelection?: boolean; successMessage?: string } = {}
  ) {
    if (modal) {
      modal.componentInstance.buttonsEnabled.set(false)
    }
    request.pipe(first()).subscribe({
-      next: ({ task_id }) => {
-        this.handleOperationQueued(modal, task_id)
-        onQueued?.(task_id)
+      next: () => {
+        this.handleOperationSuccess(modal, options.clearSelection ?? false)
+        if (options.successMessage) {
+          this.toastService.showSuccess(options.successMessage)
+        }
      },
      error: (error) => this.handleOperationError(modal, error),
    })
  }

+  private handleOperationSuccess(
+    modal: NgbModalRef,
+    clearSelection: boolean = false
+  ) {
+    if (clearSelection) {
+      this.list.selected.clear()
+    }
+    this.list.reload()
+    this.list.reduceSelectionToFilter()
+    this.list.selected.forEach((id) => {
+      this.openDocumentService.refreshDocument(id)
+    })
+    this.savedViewService.maybeRefreshDocumentCounts()
+    if (modal) {
+      modal.close()
+    }
+  }
+
  private handleOperationError(modal: NgbModalRef, error: any) {
    if (modal) {
      modal.componentInstance.buttonsEnabled.set(true)
@@ -942,8 +930,16 @@ export class BulkEditorComponent
    const count = this.getSelectionSize()
    this.executeDocumentAction(
      modal,
-      this.documentService.deleteDocuments(this.getSelectionQuery()),
-      (taskId) => this.trashService.trackMovedToTrash(taskId, count, documents)
+      this.documentService
+        .deleteDocuments(this.getSelectionQuery())
+        .pipe(
+          tap(() =>
+            this.trashService.notifyMovedToTrash(
+              $localize`Moved ${count} document(s) to the trash`,
+              documents
+            )
+          )
+        )
    )
  }

@@ -1057,7 +1053,11 @@ export class BulkEditorComponent
        mergeDialog.buttonsEnabled.set(false)
        this.executeDocumentAction(
          modal,
-          this.documentService.mergeDocuments(mergeDialog.documentIDs(), args)
+          this.documentService.mergeDocuments(mergeDialog.documentIDs(), args),
+          { clearSelection: !!args.delete_originals }
+        )
+        this.toastService.showInfo(
+          $localize`Merged document will be queued for consumption.`
        )
      })
  }
@@ -1082,7 +1082,11 @@ export class BulkEditorComponent
          this.documentService.mergeDocumentsAsVersions(
            mergeDialog.documentIDs(),
            mergeDialog.rootDocumentID()
-          )
+          ),
+          {
+            clearSelection: true,
+            successMessage: $localize`Documents merged as versions.`,
+          }
        )
      })
  }
@@ -2,47 +2,26 @@
  <div>
    <form [formGroup]="noteForm" class="needs-validation mt-3" *pngxIfPermissions="{ action: PermissionAction.Add, type: PermissionType.Note }" novalidate>
      <div class="form-group">
-        <textarea class="form-control form-control-sm" [class.is-invalid]="newNoteError" [class.d-none]="noteView() !== NoteViewMode.Edit" [attr.aria-invalid]="newNoteError" aria-label="Note" i18n-aria-label aria-describedby="noteFeedback" rows="3" formControlName="newNote" placeholder="Enter note (Markdown is supported)" i18n-placeholder (keydown)="noteFormKeydown($event)" required></textarea>
-        @if (noteView() === NoteViewMode.Preview) {
-          <section class="form-control form-control-sm note-preview" aria-label="Note preview" i18n-aria-label>
-            @if (noteForm.get('newNote').value) {
-              <div class="note-markdown text-break text-wrap" [innerHTML]="noteForm.get('newNote').value | markdown"></div>
-            } @else {
-              <span class="text-muted" i18n>Nothing to preview</span>
-            }
-          </section>
-        }
-        <div id="noteFeedback" class="invalid-feedback" i18n>
-          Please enter a note.
-        </div>
+        <textarea class="form-control form-control-sm" [class.is-invalid]="newNoteError" rows="3" formControlName="newNote" placeholder="Enter note" i18n-placeholder (keydown)="noteFormKeydown($event)" required></textarea>
+        <div class="invalid-feedback" i18n>
+                Please enter a note.
+            </div>
      </div>
-      <div class="form-group mt-2 d-flex justify-content-between align-items-center">
+      <div class="form-group mt-2 d-flex justify-content-end align-items-center">
        @if (networkActive()) {
          <div class="spinner-border spinner-border-sm fw-normal me-auto" role="status"></div>
        }
-        <fieldset class="btn-group btn-group-sm" aria-label="Note input mode" i18n-aria-label>
-          <input type="radio" class="btn-check" id="noteViewEdit" name="noteViewMode" [checked]="noteView() === NoteViewMode.Edit" (change)="noteView.set(NoteViewMode.Edit)">
-          <label class="btn btn-outline-secondary" for="noteViewEdit" i18n>Edit</label>
-          <input type="radio" class="btn-check" id="noteViewPreview" name="noteViewMode" [checked]="noteView() === NoteViewMode.Preview" (change)="noteView.set(NoteViewMode.Preview)">
-          <label class="btn btn-outline-secondary" for="noteViewPreview" i18n>Preview</label>
-        </fieldset>
        <button type="button" class="btn btn-primary btn-sm" [disabled]="networkActive() || addDisabled()" (click)="addNote()" i18n>Add note</button>
      </div>
    </form>
    <hr>
-      @for (note of notes(); track note.id) {
+      @for (note of notes(); track note) {
        <div class="card border mb-3">
          <div class="card-body text-dark">
-            @if (note.format === NoteFormat.Markdown) {
-              <div class="card-text note-markdown text-break text-wrap" [innerHTML]="note.note | markdown"></div>
-            } @else {
-              <p class="card-text">{{note.note}}</p>
-            }
+            <p class="card-text">{{note.note}}</p>
          </div>
          <div class="d-flex card-footer small bg-light text-primary justify-content-between align-items-center">
-            <span>
-              {{displayName(note)}} - {{ note.created | customDate}}
-            </span>
+            <span>{{displayName(note)}} - {{ note.created | customDate}}</span>
            <button type="button" class="btn btn-link btn-sm p-0 fade" title="Delete note" i18n-title (click)="deleteNote(note.id)" *pngxIfPermissions="{ action: PermissionAction.Delete, type: PermissionType.Note }">
              <pngx-bs-icon name="trash"></pngx-bs-icon>
              <span class="visually-hidden" i18n>Delete note</span>
@@ -5,45 +5,3 @@
 .card:hover .fade {
    opacity: 1;
 }
-
-.note-preview {
-  min-height: calc(1.5em * 3 + 0.5rem + var(--bs-border-width) * 2); // textfield height with 3 rows
-}
-
-.note-markdown ::ng-deep {
-  h1, h2, h3, h4, h5, h6 {
-    font-size: 1em;
-    font-weight: bold;
-  }
-
-  h1 { font-size: 1.25em; }
-  h2 { font-size: 1.15em; }
-  h3 { font-size: 1.05em; }
-
-  table {
-    margin-bottom: 1rem;
-    display: block;
-    overflow-x: auto;
-  }
-
-  th, td {
-    padding: 0.15rem 0.4rem;
-    border: 1px solid var(--bs-border-color);
-  }
-
-  pre {
-    padding: 0.5rem;
-    background-color: var(--bs-tertiary-bg);
-    border-radius: var(--bs-border-radius);
-  }
-
-  blockquote {
-    padding-left: 0.75rem;
-    border-left: 0.25rem solid var(--bs-border-color);
-    color: var(--bs-secondary-color);
-  }
-
-  > :last-child {
-    margin-bottom: 0;
-  }
-}
@@ -5,7 +5,7 @@ import { ComponentFixture, TestBed } from '@angular/core/testing'
 import { FormsModule, ReactiveFormsModule } from '@angular/forms'
 import { By } from '@angular/platform-browser'
 import { of, throwError } from 'rxjs'
-import { DocumentNote, NoteFormat } from 'src/app/data/document-note'
+import { DocumentNote } from 'src/app/data/document-note'
 import { IfPermissionsDirective } from 'src/app/directives/if-permissions.directive'
 import { CustomDatePipe } from 'src/app/pipes/custom-date.pipe'
 import { PermissionsService } from 'src/app/services/permissions.service'
@@ -129,66 +129,6 @@ describe('DocumentNotesComponent', () => {
    expect(fixture.debugElement.nativeElement.textContent).toContain('user3')
  })

-  it('should render notes according to their format', () => {
-    component.notes.set([
-      { id: 31, note: '**x**', format: NoteFormat.Markdown },
-      {
-        id: 32,
-        note: '<script>alert(1)</script>',
-        format: NoteFormat.Markdown,
-      },
-      { id: 33, note: '**x**', format: NoteFormat.Plain },
-    ])
-    fixture.detectChanges()
-
-    const noteCards = fixture.debugElement.queryAll(By.css('.card-text'))
-    expect(noteCards[0].query(By.css('strong')).nativeElement.textContent).toBe(
-      'x'
-    )
-    expect(noteCards[1].query(By.css('script'))).toBeNull()
-    expect(noteCards[2].query(By.css('strong'))).toBeNull()
-    expect(noteCards[2].nativeElement.textContent).toBe('**x**')
-  })
-
-  it('should toggle between edit and preview', () => {
-    const radios = fixture.debugElement.queryAll(
-      By.css('.btn-group input[type="radio"]')
-    )
-    radios[1].triggerEventHandler('change')
-    fixture.detectChanges()
-    expect(
-      fixture.debugElement.query(By.css('.note-preview')).nativeElement
-        .textContent
-    ).toContain('Nothing to preview')
-
-    component.noteForm.get('newNote').setValue('**bold**')
-    fixture.detectChanges()
-    expect(
-      fixture.debugElement.query(By.css('.note-preview strong'))
-    ).not.toBeNull()
-    expect(
-      fixture.debugElement.query(By.css('textarea')).nativeElement.classList
-    ).toContain('d-none')
-
-    radios[0].triggerEventHandler('change')
-    fixture.detectChanges()
-    expect(fixture.debugElement.query(By.css('.note-preview'))).toBeNull()
-    expect(
-      fixture.debugElement.query(By.css('textarea')).nativeElement.classList
-    ).not.toContain('d-none')
-  })
-
-  it('should return to edit mode after saving', () => {
-    component.documentId.set(12)
-    component.noteForm.get('newNote').setValue('Preview note')
-    fixture.debugElement
-      .queryAll(By.css('.btn-group input[type="radio"]'))[1]
-      .triggerEventHandler('change')
-    jest.spyOn(notesService, 'addNote').mockReturnValueOnce(of(notes))
-    component.addNote()
-    expect(component.noteView()).toBe('edit')
-  })
-
  it('should handle note user display in all situations', () => {
    expect(
      component.displayName({
@@ -221,7 +161,7 @@ describe('DocumentNotesComponent', () => {
    const addSpy = jest.spyOn(notesService, 'addNote')
    addSpy.mockReturnValueOnce(throwError(() => new Error('error saving note')))
    const toastsSpy = jest.spyOn(toastService, 'showError')
-    const addButton = fixture.debugElement.query(By.css('.btn-primary'))
+    const addButton = fixture.debugElement.query(By.css('button'))
    addButton.triggerEventHandler('click')
    expect(addSpy).toHaveBeenCalledWith(12, note)
    expect(toastsSpy).toHaveBeenCalled()
@@ -250,9 +190,7 @@ describe('DocumentNotesComponent', () => {
    component.documentId.set(12)
    component.notes.set(notes)
    fixture.detectChanges()
-    const deleteButton = fixture.debugElement.query(
-      By.css('.card-footer button')
-    )
+    const deleteButton = fixture.debugElement.queryAll(By.css('button'))[1] // 0 is add button
    const deleteSpy = jest.spyOn(notesService, 'deleteNote')
    const toastsSpy = jest.spyOn(toastService, 'showError')
    deleteSpy.mockReturnValueOnce(
@@ -14,21 +14,15 @@ import {
  ReactiveFormsModule,
 } from '@angular/forms'
 import { BootstrapIconComponent } from 'src/app/components/common/bootstrap-icon/bootstrap-icon.component'
-import { DocumentNote, NoteFormat } from 'src/app/data/document-note'
+import { DocumentNote } from 'src/app/data/document-note'
 import { User } from 'src/app/data/user'
 import { IfPermissionsDirective } from 'src/app/directives/if-permissions.directive'
 import { CustomDatePipe } from 'src/app/pipes/custom-date.pipe'
-import { MarkdownPipe } from 'src/app/pipes/markdown.pipe'
 import { DocumentNotesService } from 'src/app/services/rest/document-notes.service'
 import { UserService } from 'src/app/services/rest/user.service'
 import { ToastService } from 'src/app/services/toast.service'
 import { ComponentWithPermissions } from '../with-permissions/with-permissions.component'

-enum NoteViewMode {
-  Edit = 'edit',
-  Preview = 'preview',
-}
-
@Component({
  selector: 'pngx-document-notes',
  templateUrl: './document-notes.component.html',
@@ -36,7 +30,6 @@ enum NoteViewMode {
  imports: [
    IfPermissionsDirective,
    CustomDatePipe,
-    MarkdownPipe,
    FormsModule,
    ReactiveFormsModule,
    BootstrapIconComponent,
@@ -50,9 +43,6 @@ export class DocumentNotesComponent extends ComponentWithPermissions {
  readonly notes = model<DocumentNote[]>([])
  readonly addDisabled = input(false)
  readonly networkActive = signal(false)
-  protected readonly NoteViewMode = NoteViewMode
-  protected readonly NoteFormat = NoteFormat
-  protected readonly noteView = signal<NoteViewMode>(NoteViewMode.Edit)

  noteForm: FormGroup = new FormGroup({
    newNote: new FormControl(''),
@@ -85,7 +75,6 @@ export class DocumentNotesComponent extends ComponentWithPermissions {
      next: (result) => {
        this.notes.set(result)
        this.noteForm.get('newNote').reset()
-        this.noteView.set(NoteViewMode.Edit)
        this.networkActive.set(false)
        this.updated.emit(this.notes())
      },
@@ -1,14 +1,8 @@
 import { ObjectWithId } from './object-with-id'
 import { User } from './user'

-export enum NoteFormat {
-  Plain = 'plain',
-  Markdown = 'markdown',
-}
-
 export interface DocumentNote extends ObjectWithId {
  created?: Date
  note?: string
  user?: User
-  format?: NoteFormat
 }
@@ -12,7 +12,6 @@ export enum WorkflowTriggerType {
  DocumentAdded = 2,
  DocumentUpdated = 3,
  Scheduled = 4,
-  Manual = 5,
 }

 export enum ScheduleDateField {
@@ -1,7 +1,6 @@
 import { HttpTestingController } from '@angular/common/http/testing'
 import { TestBed } from '@angular/core/testing'
 import { Subscription } from 'rxjs'
-import { NoteFormat } from 'src/app/data/document-note'
 import { environment } from 'src/environments/environment'
 import { commonAbstractPaperlessServiceTests } from './abstract-paperless-service.spec'
 import { DocumentNotesService } from './document-notes.service'
@@ -51,7 +50,6 @@ describe(`Additional service tests for DocumentNotesService`, () => {
    expect(req.request.method).toEqual('POST')
    expect(req.request.body).toEqual({
      note: content,
-      format: NoteFormat.Markdown,
    })
  })

@@ -1,7 +1,7 @@
 import { HttpParams } from '@angular/common/http'
 import { Injectable } from '@angular/core'
 import { Observable } from 'rxjs'
-import { DocumentNote, NoteFormat } from 'src/app/data/document-note'
+import { DocumentNote } from 'src/app/data/document-note'
 import { AbstractPaperlessService } from './abstract-paperless-service'

@Injectable({
@@ -22,7 +22,6 @@ export class DocumentNotesService extends AbstractPaperlessService<DocumentNote>
  addNote(id: number, note: string): Observable<DocumentNote[]> {
    return this.http.post<DocumentNote[]>(this.getResourceUrl(id, 'notes'), {
      note: note,
-      format: NoteFormat.Markdown,
    })
  }

@@ -290,7 +290,6 @@ describe(`DocumentService`, () => {
    expect(req.request.method).toEqual('POST')
    expect(req.request.body).toEqual({
      documents: ids,
-      from_webui: true,
    })
  })

@@ -304,7 +303,6 @@ describe(`DocumentService`, () => {
    expect(req.request.body).toEqual({
      documents: ids,
      remote_ocr: false,
-      from_webui: true,
    })
  })

@@ -319,7 +317,6 @@ describe(`DocumentService`, () => {
    expect(req.request.body).toEqual({
      documents: ids,
      remote_ocr: true,
-      from_webui: true,
    })
  })

@@ -334,7 +331,6 @@ describe(`DocumentService`, () => {
      documents: ids,
      degrees: 90,
      source_mode: 'latest_version',
-      from_webui: true,
    })
  })

@@ -350,7 +346,6 @@ describe(`DocumentService`, () => {
      documents: ids,
      metadata_document_id: 1,
      delete_originals: true,
-      from_webui: true,
    })
  })

@@ -364,7 +359,6 @@ describe(`DocumentService`, () => {
    expect(req.request.body).toEqual({
      documents: ids,
      root_document_id: 2,
-      from_webui: true,
    })
  })

@@ -380,7 +374,6 @@ describe(`DocumentService`, () => {
      documents: ids,
      root_document_id: 2,
      version_label: 'Imported',
-      from_webui: true,
    })
  })

@@ -395,7 +388,6 @@ describe(`DocumentService`, () => {
    expect(req.request.body).toEqual({
      documents: ids,
      operations: [{ page: 1, rotate: 90, doc: 0 }],
-      from_webui: true,
    })
  })

@@ -411,7 +403,6 @@ describe(`DocumentService`, () => {
      documents: ids,
      password: 'secret',
      update_document: true,
-      from_webui: true,
    })
  })

@@ -39,7 +39,6 @@ export type DocumentBulkEditMethod =
  | 'modify_tags'
  | 'modify_custom_fields'
  | 'set_permissions'
-  | 'run_workflow'

 export interface MergeDocumentsRequest {
  metadata_document_id?: number
@@ -351,24 +350,19 @@ export class DocumentService extends AbstractPaperlessService<Document> {
  }

  deleteDocuments(selection: DocumentSelectionQuery) {
-    return this.http.post<BulkOperationResponse>(
-      this.getResourceUrl(null, 'delete'),
-      { ...selection, from_webui: true }
-    )
+    return this.http.post(this.getResourceUrl(null, 'delete'), {
+      ...selection,
+    })
  }

  reprocessDocuments(
    selection: DocumentSelectionQuery,
    remoteOcr: boolean = false
  ) {
-    return this.http.post<BulkOperationResponse>(
-      this.getResourceUrl(null, 'reprocess'),
-      {
-        ...selection,
-        remote_ocr: remoteOcr,
-        from_webui: true,
-      }
-    )
+    return this.http.post(this.getResourceUrl(null, 'reprocess'), {
+      ...selection,
+      remote_ocr: remoteOcr,
+    })
  }

  rotateDocuments(
@@ -376,26 +370,18 @@ export class DocumentService extends AbstractPaperlessService<Document> {
    degrees: number,
    sourceMode: BulkEditSourceMode = BulkEditSourceMode.LATEST_VERSION
  ) {
-    return this.http.post<BulkOperationResponse>(
-      this.getResourceUrl(null, 'rotate'),
-      {
-        ...selection,
-        degrees,
-        source_mode: sourceMode,
-        from_webui: true,
-      }
-    )
+    return this.http.post(this.getResourceUrl(null, 'rotate'), {
+      ...selection,
+      degrees,
+      source_mode: sourceMode,
+    })
  }

  mergeDocuments(ids: number[], request: MergeDocumentsRequest = {}) {
-    return this.http.post<BulkOperationResponse>(
-      this.getResourceUrl(null, 'merge'),
-      {
-        documents: ids,
-        ...request,
-        from_webui: true,
-      }
-    )
+    return this.http.post(this.getResourceUrl(null, 'merge'), {
+      documents: ids,
+      ...request,
+    })
  }

  mergeDocumentsAsVersions(
@@ -403,40 +389,28 @@ export class DocumentService extends AbstractPaperlessService<Document> {
    rootDocumentId: number,
    versionLabel?: string
  ) {
-    return this.http.post<BulkOperationResponse>(
-      this.getResourceUrl(null, 'merge_as_versions'),
-      {
-        documents: ids,
-        root_document_id: rootDocumentId,
-        ...(versionLabel ? { version_label: versionLabel } : {}),
-        from_webui: true,
-      }
-    )
+    return this.http.post(this.getResourceUrl(null, 'merge_as_versions'), {
+      documents: ids,
+      root_document_id: rootDocumentId,
+      ...(versionLabel ? { version_label: versionLabel } : {}),
+    })
  }

  editPdfDocuments(ids: number[], request: EditPdfDocumentsRequest) {
-    return this.http.post<BulkOperationResponse>(
-      this.getResourceUrl(null, 'edit_pdf'),
-      {
-        documents: ids,
-        ...request,
-        from_webui: true,
-      }
-    )
+    return this.http.post(this.getResourceUrl(null, 'edit_pdf'), {
+      documents: ids,
+      ...request,
+    })
  }

  removePasswordDocuments(
    ids: number[],
    request: RemovePasswordDocumentsRequest
  ) {
-    return this.http.post<BulkOperationResponse>(
-      this.getResourceUrl(null, 'remove_password'),
-      {
-        documents: ids,
-        ...request,
-        from_webui: true,
-      }
-    )
+    return this.http.post(this.getResourceUrl(null, 'remove_password'), {
+      documents: ids,
+      ...request,
+    })
  }

  getSelectionData(
@@ -5,7 +5,6 @@ import {
  HttpTestingController,
 } from '@angular/common/http/testing'
 import { environment } from 'src/environments/environment'
-import { PaperlessTaskStatus } from '../data/paperless-task'
 import { DocumentListViewService } from './document-list-view.service'
 import { Toast, ToastService } from './toast.service'
 import { TrashService } from './trash.service'
@@ -106,27 +105,4 @@ describe('TrashService', () => {
    expect(toast.content).toEqual('Moved 500 document(s) to the trash')
    expect(toast.action).toBeUndefined()
  })
-
-  it('offers Undo only after the matching delete task succeeds', () => {
-    let toasts: Toast[] = []
-    toastService.getToasts().subscribe((t) => (toasts = [...t]))
-    service.trackMovedToTrash('delete-1', 2, [1, 2])
-    expect(toasts).toHaveLength(0)
-    service.handleDeleteTaskStatus('other-delete', PaperlessTaskStatus.Success)
-    expect(toasts).toHaveLength(0)
-    service.handleDeleteTaskStatus('delete-1', PaperlessTaskStatus.Success)
-    expect(toasts).toHaveLength(1)
-    expect(toasts[0].actionName).toBe('Undo')
-  })
-
-  it('handles completion before the queue response and does not offer Undo on failure', () => {
-    let toasts: Toast[] = []
-    toastService.getToasts().subscribe((t) => (toasts = [...t]))
-    service.handleDeleteTaskStatus('delete-1', PaperlessTaskStatus.Success)
-    service.trackMovedToTrash('delete-1', 1, [1])
-    expect(toasts[0].actionName).toBe('Undo')
-    service.trackMovedToTrash('delete-2', 1, [2])
-    service.handleDeleteTaskStatus('delete-2', PaperlessTaskStatus.Failure)
-    expect(toasts).toHaveLength(1)
-  })
 })
@@ -3,7 +3,6 @@ import { Injectable, inject } from '@angular/core'
 import { Observable } from 'rxjs'
 import { environment } from 'src/environments/environment'
 import { Document } from '../data/document'
-import { PaperlessTaskStatus } from '../data/paperless-task'
 import { Results } from '../data/results'
 import { DocumentListViewService } from './document-list-view.service'
 import { ToastLevel, ToastService } from './toast.service'
@@ -15,49 +14,6 @@ export class TrashService {
  private http = inject(HttpClient)
  private toastService = inject(ToastService)
  private documentListViewService = inject(DocumentListViewService)
-  private pendingMoves = new Map<
-    string,
-    { count: number; documents?: number[] }
-  >()
-  private completedMoves = new Map<string, PaperlessTaskStatus>()
-
-  public trackMovedToTrash(
-    taskId: string,
-    count: number,
-    documents?: number[]
-  ) {
-    const status = this.completedMoves.get(taskId)
-    if (status !== undefined) {
-      this.completedMoves.delete(taskId)
-      if (status === PaperlessTaskStatus.Success) {
-        this.notifyMovedToTrash(
-          $localize`Moved ${count} document(s) to the trash`,
-          documents
-        )
-      }
-    } else {
-      this.pendingMoves.set(taskId, { count, documents })
-    }
-  }
-
-  public handleDeleteTaskStatus(taskId: string, status: PaperlessTaskStatus) {
-    const move = this.pendingMoves.get(taskId)
-    if (move) {
-      this.pendingMoves.delete(taskId)
-      if (status === PaperlessTaskStatus.Success) {
-        this.notifyMovedToTrash(
-          $localize`Moved ${move.count} document(s) to the trash`,
-          move.documents
-        )
-      }
-    } else {
-      // in case the task finishes fast
-      this.completedMoves.set(taskId, status)
-      if (this.completedMoves.size > 100) {
-        this.completedMoves.delete(this.completedMoves.keys().next().value)
-      }
-    }
-  }

  public getTrash(page: number = 1): Observable<Results<Document>> {
    const httpParams = new HttpParams().set('page', page.toString())
@@ -42,7 +42,6 @@ from documents.plugins.helpers import DocumentsStatusManager
 from documents.tasks import bulk_update_documents
 from documents.tasks import consume_file
 from documents.tasks import remove_document_from_index
-from documents.tasks import run_workflows_for_documents
 from documents.tasks import update_document_content_maybe_archive_file
 from documents.versioning import get_latest_version_for_root
 from documents.versioning import get_root_document
@@ -427,7 +426,6 @@ def delete(doc_ids: list[int]) -> Literal["OK"]:
                "Detected a possible incompatible database column. See https://docs.paperless-ngx.com/troubleshooting/#convert-uuid-field",
            )
        logger.error(f"Error deleting documents: {e!s}")
-        raise

    return "OK"

@@ -466,25 +464,6 @@ def reprocess(doc_ids: list[int], *, remote_ocr: bool = False) -> Literal["OK"]:
    return "OK"


-def run_workflow(
-    doc_ids: list[int],
-    workflow: int,
-    *,
-    filter_documents: bool = True,
-) -> Literal["OK"]:
-    """
-    Manually run a single workflow against the given documents.
-
-    Called from the tracked bulk operation task.
-    """
-    run_workflows_for_documents(
-        document_ids=doc_ids,
-        workflow_id=workflow,
-        filter_documents=filter_documents,
-    )
-    return "OK"
-
-
 def set_permissions(
    doc_ids: list[int],
    set_permissions: PermissionsSpec,
@@ -1,4 +1,4 @@
-"""Queued document bulk operations."""
+"""Queued document metadata edits."""

 from typing import Any

@@ -12,7 +12,6 @@ from rest_framework.exceptions import PermissionDenied
 from documents import bulk_edit
 from documents.models import CustomFieldInstance
 from documents.models import Document
-from documents.models import PaperlessTask
 from documents.permissions import has_document_operation_permissions
 from documents.tasks import bulk_update_documents

@@ -26,35 +25,7 @@ MODIFIED_FIELDS = {
    "modify_custom_fields": "custom_fields",
    "set_permissions": None,
 }
-LEGACY_MODIFIED_FIELDS = {"delete": "deleted_at", "reprocess": "checksum"}
-QUEUED_OPERATIONS = frozenset(
-    (
-        *MODIFIED_FIELDS,
-        "delete",
-        "reprocess",
-        "run_workflow",
-        "rotate",
-        "merge",
-        "merge_as_versions",
-        "split",
-        "delete_pages",
-        "edit_pdf",
-        "remove_password",
-    ),
-)
-USER_OPERATIONS = frozenset(
-    {
-        "split",
-        "merge",
-        "rotate",
-        "delete_pages",
-        "edit_pdf",
-        "remove_password",
-        "merge_as_versions",
-    },
-)
-# merge_as_versions doesn't queue any consume tasks
-TRIGGER_SOURCE_OPERATIONS = USER_OPERATIONS - {"merge_as_versions"}
+QUEUED_OPERATIONS = frozenset(MODIFIED_FIELDS)


 def snapshot_field(doc_ids: list[int], field: str) -> dict[int, Any]:
@@ -95,7 +66,6 @@ def execute_bulk_operation(
    document_ids: list[int],
    parameters: dict,
    user_id: int,
-    trigger_source: str = PaperlessTask.TriggerSource.API_UPLOAD,
 ) -> dict:
    if operation not in QUEUED_OPERATIONS:
        raise ValueError(f"Unsupported bulk operation: {operation}")
@@ -109,39 +79,6 @@ def execute_bulk_operation(
    ):
        raise PermissionDenied("Insufficient permissions to execute bulk operation")

-    if operation == "run_workflow" and not user.has_perm("documents.view_workflow"):
-        raise PermissionDenied("Insufficient permissions to run this workflow")
-
-    if operation not in MODIFIED_FIELDS:
-        execution_parameters = parameters.copy()
-        if operation in USER_OPERATIONS:
-            execution_parameters["user"] = user
-        if operation in TRIGGER_SOURCE_OPERATIONS:
-            execution_parameters["trigger_source"] = trigger_source
-        modified_field = LEGACY_MODIFIED_FIELDS.get(operation)
-        with set_actor(user):
-            old_values = (
-                snapshot_field(document_ids, modified_field)
-                if settings.AUDIT_LOG_ENABLED and modified_field
-                else {}
-            )
-            method(document_ids, **execution_parameters)
-            if settings.AUDIT_LOG_ENABLED and modified_field:
-                from auditlog.models import LogEntry
-
-                new_values = snapshot_field(document_ids, modified_field)
-                for doc in Document.objects.filter(pk__in=document_ids):
-                    LogEntry.objects.log_create(
-                        instance=doc,
-                        changes={
-                            modified_field: [old_values[doc.pk], new_values[doc.pk]],
-                        },
-                        action=LogEntry.Action.UPDATE,
-                        actor=user,
-                        additional_data={"reason": f"Bulk edit: {operation}"},
-                    )
-        return {"operation": operation, "document_count": len(document_ids)}
-
    affected_ids: list[int] = []
    modified_field = MODIFIED_FIELDS[operation]
    # Keep metadata writes and their audit entries together. Follow-up processing
@@ -35,7 +35,6 @@ from django_filters.rest_framework import DateTimeFilter
 from django_filters.rest_framework import Filter
 from django_filters.rest_framework import FilterSet
 from django_filters.rest_framework import MultipleChoiceFilter
-from django_filters.rest_framework import NumberFilter
 from drf_spectacular.utils import extend_schema_field
 from guardian.utils import get_group_obj_perms_model
 from guardian.utils import get_user_obj_perms_model
@@ -53,7 +52,6 @@ from documents.models import ShareLink
 from documents.models import ShareLinkBundle
 from documents.models import StoragePath
 from documents.models import Tag
-from documents.models import Workflow
 from documents.permissions import annotate_authorizing_fields
 from documents.permissions import permitted_document_ids
 from documents.permissions import permitted_object_ids
@@ -251,17 +249,6 @@ class CustomFieldFilterSet(FilterSet):
        }


-class WorkflowFilterSet(FilterSet):
-    trigger_type = NumberFilter(field_name="triggers__type", distinct=True)
-
-    class Meta:
-        model = Workflow
-        fields = {
-            "id": ID_KWARGS,
-            "enabled": ["exact"],
-        }
-
-
@extend_schema_field(serializers.CharField)
 class CustomFieldsFilter(Filter):
    def filter(self, qs, value):
@@ -684,7 +684,6 @@ def document_matches_workflow(
                trigger_type == WorkflowTrigger.WorkflowTriggerType.DOCUMENT_ADDED
                or trigger_type == WorkflowTrigger.WorkflowTriggerType.DOCUMENT_UPDATED
                or trigger_type == WorkflowTrigger.WorkflowTriggerType.SCHEDULED
-                or trigger_type == WorkflowTrigger.WorkflowTriggerType.MANUAL
            ):
                trigger_matched, reason = existing_document_matches_workflow(
                    document,
@@ -1,43 +0,0 @@
-# Generated by Django 5.2.18 on 2026-11-06 17:12
-
-from django.db import migrations
-from django.db import models
-
-
-class Migration(migrations.Migration):
-    dependencies = [
-        ("documents", "0028_replace_tag_tree_fields"),
-    ]
-
-    operations = [
-        migrations.AlterField(
-            model_name="workflowrun",
-            name="type",
-            field=models.PositiveSmallIntegerField(
-                choices=[
-                    (1, "Consumption Started"),
-                    (2, "Document Added"),
-                    (3, "Document Updated"),
-                    (4, "Scheduled"),
-                    (5, "Manual"),
-                ],
-                null=True,
-                verbose_name="workflow trigger type",
-            ),
-        ),
-        migrations.AlterField(
-            model_name="workflowtrigger",
-            name="type",
-            field=models.PositiveSmallIntegerField(
-                choices=[
-                    (1, "Consumption Started"),
-                    (2, "Document Added"),
-                    (3, "Document Updated"),
-                    (4, "Scheduled"),
-                    (5, "Manual"),
-                ],
-                default=1,
-                verbose_name="Workflow Trigger Type",
-            ),
-        ),
-    ]
@@ -1,23 +0,0 @@
-# Generated by Django 5.2.17 on 2026-11-03 05:57
-
-from django.db import migrations
-from django.db import models
-
-
-class Migration(migrations.Migration):
-    dependencies = [
-        ("documents", "0029_alter_workflowrun_type_alter_workflowtrigger_type"),
-    ]
-
-    operations = [
-        migrations.AddField(
-            model_name="note",
-            name="format",
-            field=models.CharField(
-                choices=[("plain", "Plain"), ("markdown", "Markdown")],
-                default="plain",
-                max_length=16,
-                verbose_name="format",
-            ),
-        ),
-    ]
@@ -1006,23 +1006,12 @@ class PaperlessTask(ModelWithOwner):


 class Note(SoftDeleteModel):
-    class Format(models.TextChoices):
-        PLAIN = ("plain", _("Plain"))
-        MARKDOWN = ("markdown", _("Markdown"))
-
    note = models.TextField(
        _("content"),
        blank=True,
        help_text=_("Note for the document"),
    )

-    format = models.CharField(
-        max_length=16,
-        choices=Format,
-        default=Format.PLAIN,
-        verbose_name=_("format"),
-    )
-
    created = models.DateTimeField(
        _("created"),
        default=timezone.now,
@@ -1543,7 +1532,6 @@ class WorkflowTrigger(models.Model):
        DOCUMENT_ADDED = 2, _("Document Added")
        DOCUMENT_UPDATED = 3, _("Document Updated")
        SCHEDULED = 4, _("Scheduled")
-        MANUAL = 5, _("Manual")

    class DocumentSourceChoices(models.IntegerChoices):
        CONSUME_FOLDER = DocumentSource.ConsumeFolder.value, _("Consume Folder")
@@ -971,19 +971,10 @@ class NotesSerializer(serializers.ModelSerializer[Note]):

    class Meta:
        model = Note
-        fields = ["id", "note", "format", "created", "user"]
+        fields = ["id", "note", "created", "user"]
        ordering = ["-created"]


-class NoteCreateSerializer(serializers.Serializer[dict[str, Any]]):
-    note = serializers.CharField()
-    format = serializers.ChoiceField(
-        choices=Note.Format.choices,
-        default=Note.Format.PLAIN,
-        required=False,
-    )
-
-
 def _get_viewable_duplicates(
    document: Document,
    user: User | None,
@@ -1688,7 +1679,6 @@ class MergeDocumentsSerializer(DocumentListSerializer, SourceModeValidationMixin

 class MergeDocumentsAsVersionsSerializer(DocumentListSerializer):
    root_document_id = serializers.IntegerField(required=True)
-    from_webui = serializers.BooleanField(required=False, default=False)
    version_label = serializers.CharField(
        required=False,
        allow_blank=True,
@@ -1802,12 +1792,11 @@ class RemovePasswordDocumentsSerializer(


 class DeleteDocumentsSerializer(DocumentSelectionSerializer):
-    from_webui = serializers.BooleanField(required=False, default=False)
+    pass


 class ReprocessDocumentsSerializer(DocumentSelectionSerializer):
    remote_ocr = serializers.BooleanField(required=False, default=False)
-    from_webui = serializers.BooleanField(required=False, default=False)


 class BulkEditSerializer(
@@ -1840,7 +1829,6 @@ class BulkEditSerializer(
            "modify_tags",
            "modify_custom_fields",
            "set_permissions",
-            "run_workflow",
            *LEGACY_DOCUMENT_ACTION_METHODS,
        ],
        label="Method",
@@ -1930,8 +1918,6 @@ class BulkEditSerializer(
            return bulk_edit.reprocess
        elif method == "set_permissions":
            return bulk_edit.set_permissions
-        elif method == "run_workflow":
-            return bulk_edit.run_workflow
        elif method == "rotate":
            return bulk_edit.rotate
        elif method == "merge":
@@ -2171,35 +2157,6 @@ class BulkEditSerializer(
        else:
            parameters["remote_ocr"] = False

-    def _validate_parameters_run_workflow(self, parameters) -> None:
-        if "workflow" not in parameters:
-            raise serializers.ValidationError("workflow not specified")
-        try:
-            workflow = Workflow.objects.get(id=parameters["workflow"])
-        except (Workflow.DoesNotExist, ValueError, TypeError):
-            raise serializers.ValidationError("Workflow does not exist")
-        request = self.context.get("request")
-        user = getattr(request, "user", None)
-        if user is not None and not user.has_perm("documents.view_workflow"):
-            raise PermissionDenied(
-                "Insufficient permissions to run this workflow",
-            )
-        if not workflow.enabled:
-            raise serializers.ValidationError("Workflow is not enabled")
-        if not workflow.triggers.filter(
-            type=WorkflowTrigger.WorkflowTriggerType.MANUAL,
-        ).exists():
-            raise serializers.ValidationError(
-                "Workflow does not have a manual trigger",
-            )
-        if "filter_documents" in parameters:
-            if not isinstance(parameters["filter_documents"], bool):
-                raise serializers.ValidationError(
-                    "filter_documents must be a boolean",
-                )
-        else:
-            parameters["filter_documents"] = True
-
    def validate_parameters_remove_password(self, parameters):
        if "password" not in parameters:
            raise serializers.ValidationError("password not specified")
@@ -2266,8 +2223,6 @@ class BulkEditSerializer(
            self.validate_parameters_remove_password(parameters)
        elif method == bulk_edit.reprocess:
            self._validate_parameters_reprocess(parameters)
-        elif method == bulk_edit.run_workflow:
-            self._validate_parameters_run_workflow(parameters)

        return attrs

@@ -864,8 +864,6 @@ def run_workflows(
    logging_group: uuid.UUID | None = None,
    overrides: DocumentMetadataOverrides | None = None,
    original_file: Path | None = None,
-    *,
-    skip_matching: bool = False,
 ) -> tuple[DocumentMetadataOverrides, str] | None:
    """
    Execute workflows matching a document for the given trigger. When `overrides` is provided
@@ -876,10 +874,6 @@ def run_workflows(
    `document.source_path` (Document) or `document.original_file` (ConsumableDocument).

    Passing `workflow_to_run` skips the workflow query (currently only used by scheduled runs).
-
-    Passing `skip_matching` runs the workflow's actions without evaluating its trigger
-    filters against the document. It is only meaningful together with `workflow_to_run`
-    (e.g. a manual run the user has explicitly forced onto the selected documents).
    """

    use_overrides = overrides is not None
@@ -929,11 +923,7 @@ def run_workflows(
                )
                break

-        if skip_matching or matching.document_matches_workflow(
-            document,
-            workflow,
-            trigger_type,
-        ):
+        if matching.document_matches_workflow(document, workflow, trigger_type):
            action: WorkflowAction
            has_move_to_trash_action = False
            for action in workflow.actions.order_by("order", "pk"):
@@ -1206,8 +1196,6 @@ def before_task_publish_handler(
                "document_count": len(task_kwargs["document_ids"]),
            }
            owner_id = task_kwargs["user_id"]
-            if task_kwargs["operation"] == "delete":
-                task_type = PaperlessTask.TaskType.BULK_DELETE
        else:
            input_data = _extract_input_data(task_type, task_kwargs)
            owner_id = _extract_owner_id(task_type, task_kwargs)
@@ -53,7 +53,6 @@ from documents.models import ShareLink
 from documents.models import ShareLinkBundle
 from documents.models import StoragePath
 from documents.models import Tag
-from documents.models import Workflow
 from documents.models import WorkflowRun
 from documents.models import WorkflowTrigger
 from documents.plugins.base import ConsumeTaskPlugin
@@ -692,51 +691,6 @@ def check_scheduled_workflows() -> None:
                        )


-@shared_task
-def run_workflows_for_documents(
-    document_ids: list[int],
-    workflow_id: int,
-    *,
-    filter_documents: bool = True,
-) -> None:
-    """
-    Run a single workflow manually against the given documents.
-
-    ``filter_documents`` controls whether the workflow's trigger filters are applied.
-    When True, only documents matching the existing filters will have the workflow run.
-    When False, the workflow will be run on all specified documents regardless of the filters.
-    ``
-    """
-    try:
-        workflow = Workflow.objects.get(id=workflow_id)
-    except Workflow.DoesNotExist:
-        logger.warning(
-            f"Manual workflow run requested for missing workflow {workflow_id}",
-        )
-        return
-
-    for document in Document.objects.filter(
-        id__in=document_ids,
-        root_document__isnull=True,
-    ):
-        try:
-            run_workflows(
-                trigger_type=WorkflowTrigger.WorkflowTriggerType.MANUAL,
-                document=document,
-                workflow_to_run=workflow,
-                skip_matching=not filter_documents,
-            )
-            # Manual runs dont send document_updated signal, so ws here to ensure clients are refreshed
-            send_websocket_document_updated(
-                sender=None,
-                document=document,
-            )
-        except Exception:
-            logger.exception(
-                f"Error running workflow {workflow} on document {document.pk}",
-            )
-
-
 def update_document_parent_tags(tag: Tag, new_parent: Tag) -> None:
    """
    When a tag's parent changes, ensure all documents containing the tag also have
@@ -15,11 +15,7 @@ from documents.models import Document
 from documents.models import DocumentType
 from documents.models import StoragePath
 from documents.models import Tag
-from documents.models import Workflow
-from documents.models import WorkflowAction
-from documents.models import WorkflowTrigger
 from paperless_testing.dirs import DirectoriesMixin
-from paperless_testing.factories import DocumentFactory
 from paperless_testing.factories import UserFactory
 from paperless_testing.permissions import grant_all_global
 from paperless_testing.permissions import grant_global
@@ -626,111 +622,6 @@ class TestBulkEditAPI(DirectoriesMixin, APITestCase):
        self.assertEqual(args[0], [self.doc1.id])
        self.assertEqual(kwargs, {"remote_ocr": True})

-    def _make_manual_workflow(self) -> Workflow:
-        trigger = WorkflowTrigger.objects.create(
-            type=WorkflowTrigger.WorkflowTriggerType.MANUAL,
-        )
-        action = WorkflowAction.objects.create()
-        workflow = Workflow.objects.create(name="Manual workflow", order=0)
-        workflow.triggers.add(trigger)
-        workflow.actions.add(action)
-        return workflow
-
-    def _run_workflow(self, parameters, documents=None):
-        return self.client.post(
-            "/api/documents/bulk_edit/",
-            json.dumps(
-                {
-                    "documents": documents or [self.doc1.id],
-                    "method": "run_workflow",
-                    "parameters": parameters,
-                },
-            ),
-            content_type="application/json",
-        )
-
-    @mock.patch("documents.views.bulk_edit.run_workflow")
-    def test_run_workflow(self, m) -> None:
-        """A valid run_workflow call passes the docs, workflow id and filter flag through."""
-        self.setup_mock(m, "run_workflow")
-        workflow = self._make_manual_workflow()
-
-        response = self._run_workflow({"workflow": workflow.id})
-
-        self.assertEqual(response.status_code, status.HTTP_200_OK)
-        args, kwargs = m.call_args
-        self.assertEqual(args[0], [self.doc1.id])
-        self.assertEqual(kwargs, {"workflow": workflow.id, "filter_documents": True})
-
-        self._run_workflow({"workflow": workflow.id, "filter_documents": False})
-        self.assertFalse(m.call_args.kwargs["filter_documents"])
-
-    @mock.patch("documents.views.bulk_edit.run_workflow")
-    def test_run_workflow_invalid_parameters(self, m) -> None:
-        """Invalid run_workflow parameters are rejected before dispatch."""
-        self.setup_mock(m, "run_workflow")
-        manual = self._make_manual_workflow()
-        non_manual = Workflow.objects.create(name="Non-manual", order=0)
-        non_manual.triggers.add(
-            WorkflowTrigger.objects.create(
-                type=WorkflowTrigger.WorkflowTriggerType.DOCUMENT_ADDED,
-            ),
-        )
-        disabled = Workflow.objects.create(
-            name="Disabled manual",
-            order=0,
-            enabled=False,
-        )
-        disabled.triggers.add(
-            WorkflowTrigger.objects.create(
-                type=WorkflowTrigger.WorkflowTriggerType.MANUAL,
-            ),
-        )
-        for label, parameters in (
-            ("missing workflow", {}),
-            ("nonexistent workflow", {"workflow": 9999}),
-            ("no manual trigger", {"workflow": non_manual.id}),
-            ("disabled workflow", {"workflow": disabled.id}),
-            ("non-bool filter", {"workflow": manual.id, "filter_documents": "nope"}),
-        ):
-            with self.subTest(label):
-                response = self._run_workflow(parameters)
-                self.assertEqual(
-                    response.status_code,
-                    status.HTTP_400_BAD_REQUEST,
-                )
-        m.assert_not_called()
-
-    @mock.patch("documents.views.bulk_edit.run_workflow")
-    def test_run_workflow_requires_ownership(self, m) -> None:
-        """A non-owner without document ownership is forbidden (actions mutate docs)."""
-        self.setup_mock(m, "run_workflow")
-        user = UserFactory(username="no_perms")
-        grant_all_global(user)
-        doc = DocumentFactory(owner=UserFactory(username="other"))
-        workflow = self._make_manual_workflow()
-        self.client.force_authenticate(user=user)
-
-        response = self._run_workflow({"workflow": workflow.id}, documents=[doc.id])
-
-        self.assertEqual(response.status_code, status.HTTP_403_FORBIDDEN)
-        m.assert_not_called()
-
-    @mock.patch("documents.views.bulk_edit.run_workflow")
-    def test_run_workflow_requires_workflow_permission(self, m) -> None:
-        """Owning the documents is not enough without view_workflow permission."""
-        self.setup_mock(m, "run_workflow")
-        user = UserFactory(username="no_wf_perms")
-        grant_global(user, "change_document")
-        doc = DocumentFactory(owner=user)
-        workflow = self._make_manual_workflow()
-        self.client.force_authenticate(user=user)
-
-        response = self._run_workflow({"workflow": workflow.id}, documents=[doc.id])
-
-        self.assertEqual(response.status_code, status.HTTP_403_FORBIDDEN)
-        m.assert_not_called()
-
    @mock.patch("documents.serialisers.bulk_edit.set_storage_path")
    def test_api_set_storage_path(self, m) -> None:
        """
@@ -3689,7 +3689,6 @@ class TestDocumentApi(DirectoriesMixin, ConsumeTaskMixin, APITestCase):
            {
                "id": note.id,
                "note": note.note,
-                "format": Note.Format.PLAIN,
                "user": {
                    "id": note.user.id,
                    "username": note.user.username,
@@ -3738,64 +3737,11 @@ class TestDocumentApi(DirectoriesMixin, ConsumeTaskMixin, APITestCase):
        resp_data = resp_data[0]

        self.assertEqual(resp_data["note"], "this is a posted note")
-        self.assertEqual(resp_data["format"], Note.Format.PLAIN)

        doc = Document.objects.get(pk=doc.pk)
        # modified was updated to today
        self.assertEqual(doc.modified.day, timezone.now().day)

-    def test_create_markdown_note(self) -> None:
-        doc = DocumentFactory(
-            title="test",
-            content="this is a document which will have a markdown note",
-        )
-
-        response = self.client.post(
-            f"/api/documents/{doc.pk}/notes/",
-            data={"note": "**markdown**", "format": Note.Format.MARKDOWN},
-            format="json",
-        )
-
-        self.assertEqual(response.status_code, status.HTTP_200_OK)
-        note = Note.objects.get(document=doc)
-        self.assertEqual(note.format, Note.Format.MARKDOWN)
-
-        response = self.client.get(f"/api/documents/{doc.pk}/notes/", format="json")
-        self.assertEqual(response.status_code, status.HTTP_200_OK)
-        self.assertEqual(response.json()[0]["format"], Note.Format.MARKDOWN)
-
-    def test_create_note_rejects_unsupported_format(self) -> None:
-        doc = DocumentFactory(
-            title="test",
-            content="this is a document which will have a note",
-        )
-
-        response = self.client.post(
-            f"/api/documents/{doc.pk}/notes/",
-            data={"note": "unsupported", "format": "html"},
-            format="json",
-        )
-
-        self.assertEqual(response.status_code, status.HTTP_400_BAD_REQUEST)
-        self.assertIn("format", response.json())
-        self.assertFalse(Note.objects.filter(document=doc).exists())
-
-    def test_create_note_requires_note(self) -> None:
-        doc = DocumentFactory(
-            title="test",
-            content="this is a document which will have a note",
-        )
-
-        response = self.client.post(
-            f"/api/documents/{doc.pk}/notes/",
-            data={"format": Note.Format.MARKDOWN},
-            format="json",
-        )
-
-        self.assertEqual(response.status_code, status.HTTP_400_BAD_REQUEST)
-        self.assertIn("note", response.json())
-        self.assertFalse(Note.objects.filter(document=doc).exists())
-
    def test_create_note_only_saves_document_modified_field(self) -> None:
        """
        GIVEN:
@@ -100,47 +100,6 @@ class TestApiWorkflows(DirectoriesMixin, APITestCase):
            self.action.assign_correspondent.pk,
        )

-    def test_api_get_workflows_filter_trigger_type(self) -> None:
-        """
-        GIVEN:
-            - A consumption workflow and a manual workflow
-        WHEN:
-            - Workflows are requested filtered by trigger_type
-        THEN:
-            - Only workflows with a matching trigger are returned
-        """
-        manual_trigger = WorkflowTrigger.objects.create(
-            type=WorkflowTrigger.WorkflowTriggerType.MANUAL,
-        )
-        manual_workflow = Workflow.objects.create(name="Manual", order=1)
-        manual_workflow.triggers.add(manual_trigger)
-
-        response = self.client.get(
-            f"{self.ENDPOINT}?trigger_type={WorkflowTrigger.WorkflowTriggerType.MANUAL}",
-            format="json",
-        )
-
-        self.assertEqual(response.status_code, status.HTTP_200_OK)
-        self.assertEqual(response.data["count"], 1)
-        self.assertEqual(response.data["results"][0]["id"], manual_workflow.id)
-
-    def test_api_get_workflows_filter_enabled(self) -> None:
-        """
-        GIVEN:
-            - An enabled workflow and a disabled workflow
-        WHEN:
-            - Workflows are requested filtered by enabled
-        THEN:
-            - Only enabled workflows are returned
-        """
-        Workflow.objects.create(name="Disabled", order=1, enabled=False)
-
-        response = self.client.get(f"{self.ENDPOINT}?enabled=true", format="json")
-
-        self.assertEqual(response.status_code, status.HTTP_200_OK)
-        self.assertEqual(response.data["count"], 1)
-        self.assertEqual(response.data["results"][0]["id"], self.workflow.id)
-
    def test_api_get_workflow_actions_ordered(self) -> None:
        """
        GIVEN:
@@ -698,10 +698,10 @@ class TestBulkEdit(DirectoriesMixin, TestCase):
    def test_delete_documents_old_uuid_field(self, m) -> None:
        m.side_effect = Exception("Data too long for column 'transaction_id' at row 1")
        doc_ids = [self.doc1.id, self.doc2.id, self.doc3.id]
+        bulk_edit.delete(doc_ids)
        with self.assertLogs(level="WARNING") as cm:
-            with self.assertRaisesRegex(Exception, "Data too long for column"):
-                bulk_edit.delete(doc_ids)
-        self.assertIn("possible incompatible database column", cm.output[0])
+            bulk_edit.delete(doc_ids)
+            self.assertIn("possible incompatible database column", cm.output[0])


 class TestPDFActions(DirectoriesMixin, TestCase):
@@ -54,7 +54,6 @@ def test_request_only_queues(bulk_setup, endpoint, operation, parameters):
        "document_ids": [doc.pk],
        "parameters": parameters,
        "user_id": user.pk,
-        "trigger_source": "web_ui",
    }
    assert enqueue.call_args.kwargs["headers"]["trigger_source"] == "web_ui"

@@ -103,87 +102,6 @@ def test_permissions_rechecked_on_worker(bulk_setup):
    assert doc.correspondent_id is None


-@pytest.mark.django_db
-def test_document_action_runs_with_user_in_worker(bulk_setup):
-    user, _, doc, _ = bulk_setup
-    with mock.patch("documents.bulk_edit.rotate") as rotate:
-        result = execute_bulk_operation(
-            "rotate",
-            [doc.pk],
-            {"degrees": 90},
-            user.pk,
-            trigger_source="web_ui",
-        )
-    rotate.assert_called_once_with(
-        [doc.pk],
-        degrees=90,
-        user=user,
-        trigger_source="web_ui",
-    )
-    assert result == {"operation": "rotate", "document_count": 1}
-
-
-@pytest.mark.django_db
-def test_document_action_queue_contains_only_serializable_parameters(bulk_setup):
-    user, client, doc, _ = bulk_setup
-    with mock.patch("documents.views.execute_bulk_operation.apply_async") as enqueue:
-        enqueue.return_value.id = "rotate-task"
-        response = client.post(
-            "/api/documents/rotate/",
-            {"documents": [doc.pk], "degrees": 90, "from_webui": True},
-            format="json",
-        )
-    assert response.data == {"result": "OK", "task_id": "rotate-task"}
-    assert enqueue.call_args.kwargs["kwargs"] == {
-        "operation": "rotate",
-        "document_ids": [doc.pk],
-        "parameters": {"degrees": 90, "source_mode": "latest_version"},
-        "user_id": user.pk,
-        "trigger_source": "web_ui",
-    }
-
-
-@pytest.mark.django_db
-def test_reprocess_keeps_bulk_audit_entry(bulk_setup, settings):
-    user, _, doc, _ = bulk_setup
-    settings.AUDIT_LOG_ENABLED = True
-    LogEntry.objects.all().delete()
-    with mock.patch("documents.bulk_edit.reprocess"):
-        execute_bulk_operation("reprocess", [doc.pk], {}, user.pk)
-    entry = LogEntry.objects.get_for_object(doc).get()
-    assert entry.changes_dict["checksum"] == [doc.checksum, doc.checksum]
-    assert entry.actor_id == user.pk
-
-
-@pytest.mark.django_db
-def test_workflow_runs_in_tracked_task_instead_of_dispatching_another(bulk_setup):
-    user, _, doc, _ = bulk_setup
-    with mock.patch("documents.bulk_edit.run_workflows_for_documents") as run:
-        execute_bulk_operation(
-            "run_workflow",
-            [doc.pk],
-            {"workflow": 7, "filter_documents": False},
-            user.pk,
-        )
-    run.assert_called_once_with(
-        document_ids=[doc.pk],
-        workflow_id=7,
-        filter_documents=False,
-    )
-
-
-@pytest.mark.django_db
-def test_delete_failure_propagates_from_worker(bulk_setup):
-    user, _, doc, _ = bulk_setup
-    with mock.patch(
-        "documents.models.Document.delete",
-        side_effect=RuntimeError("delete failed"),
-    ):
-        with pytest.raises(RuntimeError, match="delete failed"):
-            execute_bulk_operation("delete", [doc.pk], {}, user.pk)
-    assert Document.objects.filter(pk=doc.pk).exists()
-
-
@pytest.mark.django_db
 def test_queue_failure_does_not_change_documents(bulk_setup):
    _, client, doc, correspondent = bulk_setup
@@ -244,22 +162,6 @@ def test_tracked_outcome_records_initiator_and_result(bulk_setup, failed):
        assert task.result_data == {"document_count": 1}


-@pytest.mark.django_db
-def test_queued_delete_is_tracked_as_bulk_delete(bulk_setup):
-    user, _, doc, _ = bulk_setup
-    before_task_publish_handler(
-        headers={"task": execute_bulk_operation.name, "id": "delete-task"},
-        body=(
-            (),
-            {"operation": "delete", "document_ids": [doc.pk], "user_id": user.pk},
-            {},
-        ),
-    )
-    task = PaperlessTask.objects.get(task_id="delete-task")
-    assert task.task_type == PaperlessTask.TaskType.BULK_DELETE
-    assert task.owner_id == user.pk
-
-
@pytest.mark.django_db
 def test_large_filtered_selection_is_one_task(bulk_setup):
    _, client, _, _ = bulk_setup
@@ -382,46 +284,24 @@ async def test_completion_socket_is_private(anyio_backend):


@pytest.mark.django_db
-def test_legacy_trash_queues_without_deleting_in_request(bulk_setup):
-    user, client, doc, _ = bulk_setup
-    data = {"documents": [doc.pk], "method": "delete", "parameters": {}}
-    with mock.patch("documents.views.execute_bulk_operation.apply_async") as enqueue:
-        enqueue.return_value.id = "delete-task"
+@pytest.mark.parametrize("endpoint", ["delete", "bulk_edit"])
+def test_trash_remains_synchronous(bulk_setup, endpoint):
+    _, client, doc, _ = bulk_setup
+    data = {"documents": [doc.pk]}
+    if endpoint == "bulk_edit":
+        data.update(method="delete", parameters={})
+    with (
+        mock.patch("documents.views.execute_bulk_operation.apply_async") as enqueue,
+        mock.patch("documents.search.get_backend"),
+    ):
        response = client.post(
-            "/api/documents/bulk_edit/",
+            f"/api/documents/{endpoint}/",
            data,
            format="json",
            HTTP_ACCEPT="application/json; version=9",
        )
    assert response.status_code == 200
-    assert response.data == {"result": "OK", "task_id": "delete-task"}
-    assert Document.objects.filter(pk=doc.pk).exists()
-    assert enqueue.call_args.kwargs["kwargs"] == {
-        "operation": "delete",
-        "document_ids": [doc.pk],
-        "parameters": {},
-        "user_id": user.pk,
-        "trigger_source": "api_upload",
-    }
-
-
-@pytest.mark.django_db
-def test_dedicated_trash_queues_without_deleting_in_request(bulk_setup):
-    user, client, doc, _ = bulk_setup
-    with mock.patch("documents.views.execute_bulk_operation.apply_async") as enqueue:
-        enqueue.return_value.id = "delete-task"
-        response = client.post(
-            "/api/documents/delete/",
-            {"documents": [doc.pk]},
-            format="json",
-        )
-    assert response.status_code == 200
-    assert response.data == {"result": "OK", "task_id": "delete-task"}
-    assert Document.objects.filter(pk=doc.pk).exists()
-    assert enqueue.call_args.kwargs["kwargs"] == {
-        "operation": "delete",
-        "document_ids": [doc.pk],
-        "parameters": {},
-        "user_id": user.pk,
-        "trigger_source": "api_upload",
-    }
+    assert response.data == {"result": "OK"}
+    assert not Document.objects.filter(pk=doc.pk).exists()
+    assert Document.deleted_objects.filter(pk=doc.pk).exists()
+    enqueue.assert_not_called()
@@ -8,7 +8,6 @@ from rest_framework import status
 from rest_framework.test import APITestCase

 from documents.bulk_edit import merge_as_versions
-from documents.bulk_operations import execute_bulk_operation
 from documents.models import Document
 from documents.serialisers import MergeDocumentsAsVersionsSerializer
 from paperless_testing.factories import UserFactory
@@ -35,7 +34,6 @@ class TestMergeDocumentsAsVersionsSerializer(TestCase):
            {
                "documents": [self.doc1.id, self.doc2.id, self.doc3.id],
                "root_document_id": self.doc2.id,
-                "from_webui": False,
            },
        )

@@ -350,17 +348,6 @@ class TestMergeDocumentsAsVersionsAPI(APITestCase):
            owner=self.user,
        )
        self.client.force_authenticate(user=self.user)
-        enqueue = mock.patch(
-            "documents.views.execute_bulk_operation.apply_async",
-            side_effect=lambda *, kwargs, headers: self.run_operation(kwargs),
-        )
-        enqueue.start()
-        self.addCleanup(enqueue.stop)
-
-    @staticmethod
-    def run_operation(kwargs):
-        execute_bulk_operation(**kwargs)
-        return mock.Mock(id="test-bulk-operation")

    @mock.patch("documents.views.bulk_edit.merge_as_versions")
    def test_merges_documents_as_versions(self, merge_mock) -> None:
@@ -380,10 +367,7 @@ class TestMergeDocumentsAsVersionsAPI(APITestCase):
        )

        self.assertEqual(response.status_code, status.HTTP_200_OK)
-        self.assertEqual(
-            response.data,
-            {"result": "OK", "task_id": "test-bulk-operation"},
-        )
+        self.assertEqual(response.data, {"result": "OK"})
        merge_mock.assert_called_once_with(
            [self.doc1.id, self.doc2.id],
            root_document_id=self.doc2.id,
@@ -2288,83 +2288,6 @@ class TestWorkflows(
        doc.refresh_from_db()
        self.assertEqual(doc.owner, self.user2)

-    def _make_manual_workflow(self, *, require_tag: Tag | None = None) -> Workflow:
-        trigger = WorkflowTrigger.objects.create(
-            type=WorkflowTrigger.WorkflowTriggerType.MANUAL,
-        )
-        if require_tag is not None:
-            trigger.filter_has_all_tags.add(require_tag)
-        action = WorkflowAction.objects.create(assign_owner=self.user2)
-        workflow = Workflow.objects.create(name="Manual workflow", order=0)
-        workflow.triggers.add(trigger)
-        workflow.actions.add(action)
-        return workflow
-
-    @mock.patch("documents.tasks.send_websocket_document_updated")
-    def test_manual_workflow_run_applies_and_notifies(self, mock_ws) -> None:
-        """A manual run applies the workflow's actions and pushes a websocket update."""
-        workflow = self._make_manual_workflow()
-        doc = DocumentFactory()
-
-        tasks.run_workflows_for_documents([doc.pk], workflow.pk)
-
-        doc.refresh_from_db()
-        self.assertEqual(doc.owner, self.user2)
-        self.assertEqual(mock_ws.call_args.kwargs["document"].pk, doc.pk)
-
-    def test_manual_workflow_run_respects_filters(self) -> None:
-        """With filter_documents=True, a document failing the trigger filters is skipped."""
-        workflow = self._make_manual_workflow(require_tag=self.t1)
-        doc = DocumentFactory()
-
-        tasks.run_workflows_for_documents([doc.pk], workflow.pk, filter_documents=True)
-
-        doc.refresh_from_db()
-        self.assertIsNone(doc.owner)
-
-    def test_manual_workflow_run_force_ignores_filters(self) -> None:
-        """With filter_documents=False, actions run regardless of the trigger filters."""
-        workflow = self._make_manual_workflow(require_tag=self.t1)
-        doc = DocumentFactory()
-
-        tasks.run_workflows_for_documents([doc.pk], workflow.pk, filter_documents=False)
-
-        doc.refresh_from_db()
-        self.assertEqual(doc.owner, self.user2)
-
-    def test_manual_workflow_run_missing_workflow(self) -> None:
-        """A missing workflow id logs a warning rather than raising."""
-        doc = DocumentFactory()
-        with self.assertLogs("paperless.tasks", level="WARNING"):
-            tasks.run_workflows_for_documents([doc.pk], 9999)
-
-    @mock.patch("documents.tasks.send_websocket_document_updated")
-    @mock.patch("documents.tasks.run_workflows")
-    def test_manual_workflow_run_continues_after_error(
-        self,
-        mock_run_workflows,
-        mock_ws,
-    ) -> None:
-        """A failure on one document does not abort the run for the others."""
-        workflow = self._make_manual_workflow()
-        doc1 = DocumentFactory()
-        doc2 = DocumentFactory()
-
-        def side_effect(*args, document, **kwargs):
-            if document.pk == doc1.pk:
-                raise Exception("boom")
-
-        mock_run_workflows.side_effect = side_effect
-
-        with self.assertLogs("paperless.tasks", level="ERROR"):
-            tasks.run_workflows_for_documents([doc1.pk, doc2.pk], workflow.pk)
-
-        # Both documents were attempted; the websocket update only fired for the
-        # one that did not raise.
-        self.assertEqual(mock_run_workflows.call_count, 2)
-        ws_doc_ids = [c.kwargs["document"].pk for c in mock_ws.call_args_list]
-        self.assertEqual(ws_doc_ids, [doc2.pk])
-
    @mock.patch("documents.tasks.send_websocket_document_updated")
    def test_workflow_scheduled_trigger_sends_websocket_update(
        self,
@@ -107,9 +107,9 @@ from documents import bulk_edit
 from documents.bulk_download import ArchiveOnlyStrategy
 from documents.bulk_download import OriginalAndArchiveStrategy
 from documents.bulk_download import OriginalsOnlyStrategy
-from documents.bulk_operations import TRIGGER_SOURCE_OPERATIONS
-from documents.bulk_operations import USER_OPERATIONS
+from documents.bulk_operations import QUEUED_OPERATIONS
 from documents.bulk_operations import execute_bulk_operation
+from documents.bulk_operations import snapshot_field
 from documents.caching import get_llm_suggestion_cache
 from documents.caching import get_metadata_cache
 from documents.caching import get_suggestion_cache
@@ -146,7 +146,6 @@ from documents.filters import ShareLinkFilterSet
 from documents.filters import StoragePathFilterSet
 from documents.filters import TagFilterSet
 from documents.filters import TitleContentFilter
-from documents.filters import WorkflowFilterSet
 from documents.mail import EmailAttachment
 from documents.mail import send_email
 from documents.matching import match_correspondents
@@ -207,7 +206,6 @@ from documents.serialisers import EditPdfDocumentsSerializer
 from documents.serialisers import EmailSerializer
 from documents.serialisers import MergeDocumentsAsVersionsSerializer
 from documents.serialisers import MergeDocumentsSerializer
-from documents.serialisers import NoteCreateSerializer
 from documents.serialisers import NotesSerializer
 from documents.serialisers import PostDocumentSerializer
 from documents.serialisers import RemovePasswordDocumentsSerializer
@@ -834,7 +832,12 @@ class EmailDocumentDetailSchema(EmailSerializer):
    notes=extend_schema(
        description="View, add, or delete notes for the document",
        methods=["GET", "POST", "DELETE"],
-        request=NoteCreateSerializer,
+        request=inline_serializer(
+            name="NoteCreateRequest",
+            fields={
+                "note": serializers.CharField(),
+            },
+        ),
        parameters=[
            OpenApiParameter(
                name="id",
@@ -1892,23 +1895,19 @@ class DocumentViewSet(
                    {"error": "Error retrieving notes, check logs for more detail."},
                )
        elif request.method == "POST":
-            if currentUser is not None and not has_perms_owner_aware(
-                currentUser,
-                "change_document",
-                doc,
-            ):
-                return HttpResponseForbidden(
-                    "Insufficient permissions to create notes",
-                )
-
-            note_serializer = NoteCreateSerializer(data=request.data)
-            note_serializer.is_valid(raise_exception=True)
-
            try:
+                if currentUser is not None and not has_perms_owner_aware(
+                    currentUser,
+                    "change_document",
+                    doc,
+                ):
+                    return HttpResponseForbidden(
+                        "Insufficient permissions to create notes",
+                    )
+
                c = Note.objects.create(
                    document=doc,
-                    note=note_serializer.validated_data["note"],
-                    format=note_serializer.validated_data["format"],
+                    note=request.data["note"],
                    user=currentUser,
                )
                # If audit log is enabled make an entry in the log
@@ -2974,127 +2973,41 @@ class DocumentSelectionMixin:
 class DocumentOperationPermissionMixin(PassUserMixin, DocumentSelectionMixin):
    permission_classes = (IsAuthenticated,)
    parser_classes = (parsers.JSONParser,)
+    METHOD_NAMES_REQUIRING_USER = {
+        "split",
+        "merge",
+        "rotate",
+        "delete_pages",
+        "edit_pdf",
+        "remove_password",
+        "merge_as_versions",
+    }
+    # merge_as_versions doesn't queue any consume tasks
+    METHOD_NAMES_REQUIRING_TRIGGER_SOURCE = METHOD_NAMES_REQUIRING_USER - {
+        "merge_as_versions",
+    }

    def _queue_bulk_operation(self, method, documents, parameters, from_webui):
        if "update_callback" in parameters:
            raise ValueError("Unsupported bulk operation parameter: update_callback")
-        trigger_source = (
-            PaperlessTask.TriggerSource.WEB_UI
-            if from_webui
-            else PaperlessTask.TriggerSource.API_UPLOAD
-        )
-        final_parameters = parameters.copy()
-        if method.__name__ in USER_OPERATIONS:
-            final_parameters["user"] = self.request.user
-        if method.__name__ in TRIGGER_SOURCE_OPERATIONS:
-            final_parameters["trigger_source"] = trigger_source
-        signature(method).bind(documents, **final_parameters)
+        signature(method).bind(documents, **parameters)
        task = execute_bulk_operation.apply_async(
            kwargs={
                "operation": method.__name__,
                "document_ids": documents,
                "parameters": parameters,
                "user_id": self.request.user.pk,
-                "trigger_source": trigger_source,
            },
-            headers={"trigger_source": trigger_source},
+            headers={
+                "trigger_source": (
+                    PaperlessTask.TriggerSource.WEB_UI
+                    if from_webui
+                    else PaperlessTask.TriggerSource.API_UPLOAD
+                ),
+            },
        )
        return Response({"result": "OK", "task_id": task.id})

-    def _has_document_permissions(
-        self,
-        *,
-        user: User,
-        documents: list[int],
-        method,
-        parameters: dict[str, Any],
-    ) -> bool:
-        if user.is_superuser:
-            return True
-
-        root_docs = {
-            get_root_document(doc)
-            for doc in Document.objects.select_related(
-                "owner",
-                "root_document__owner",
-            ).filter(pk__in=documents)
-        }
-        user_is_owner_of_all_documents = all(
-            (doc.owner == user or doc.owner is None) for doc in root_docs
-        )
-
-        # check global and object permissions for all documents
-        has_perms = (
-            user.has_perm(
-                "documents.change_document",
-            )
-            and not Document.global_objects.filter(pk__in=documents)
-            .exclude(pk__in=permitted_document_ids(user, perm="change_document"))
-            .exists()
-        )
-
-        # check ownership for methods that change original document
-        if (
-            (
-                has_perms
-                and method
-                in [
-                    bulk_edit.set_permissions,
-                    bulk_edit.delete,
-                    bulk_edit.rotate,
-                    bulk_edit.delete_pages,
-                    bulk_edit.edit_pdf,
-                    bulk_edit.merge_as_versions,
-                    bulk_edit.remove_password,
-                    bulk_edit.run_workflow,
-                ]
-            )
-            or (
-                method in [bulk_edit.merge, bulk_edit.split]
-                and parameters.get("delete_originals")
-            )
-            or (method == bulk_edit.edit_pdf and parameters.get("update_document"))
-        ):
-            has_perms = has_perms and user_is_owner_of_all_documents
-
-        # check global add permissions for methods that create documents
-        if (
-            has_perms
-            and (
-                method in [bulk_edit.split, bulk_edit.merge]
-                or (
-                    method in [bulk_edit.edit_pdf, bulk_edit.remove_password]
-                    and not parameters.get("update_document")
-                )
-            )
-            and not user.has_perm("documents.add_document")
-        ):
-            has_perms = False
-
-        # check global delete permissions for methods that delete documents
-        if (
-            has_perms
-            and (
-                method == bulk_edit.delete
-                # Sources stop being documents of their own, and removing one
-                # again afterwards needs delete_document
-                or method == bulk_edit.merge_as_versions
-                or (
-                    method in [bulk_edit.merge, bulk_edit.split]
-                    and parameters.get("delete_originals")
-                )
-                or (
-                    method in [bulk_edit.edit_pdf, bulk_edit.remove_password]
-                    and parameters.get("delete_original")
-                    and not parameters.get("update_document")
-                )
-            )
-            and not user.has_perm("documents.delete_document")
-        ):
-            has_perms = False
-
-        return has_perms
-
    def _execute_document_action(
        self,
        *,
@@ -3121,6 +3034,15 @@ class DocumentOperationPermissionMixin(PassUserMixin, DocumentSelectionMixin):
        user = self.request.user
        from_webui = validated_data.get("from_webui", False)

+        if method.__name__ in self.METHOD_NAMES_REQUIRING_USER:
+            parameters["user"] = user
+        if method.__name__ in self.METHOD_NAMES_REQUIRING_TRIGGER_SOURCE:
+            parameters["trigger_source"] = (
+                PaperlessTask.TriggerSource.WEB_UI
+                if from_webui
+                else PaperlessTask.TriggerSource.API_UPLOAD
+            )
+
        if not has_document_operation_permissions(
            user=user,
            documents=documents,
@@ -3130,12 +3052,8 @@ class DocumentOperationPermissionMixin(PassUserMixin, DocumentSelectionMixin):
            return HttpResponseForbidden("Insufficient permissions")

        try:
-            return self._queue_bulk_operation(
-                method,
-                documents,
-                parameters,
-                from_webui,
-            )
+            result = method(documents, **parameters)
+            return Response({"result": result})
        except Exception as e:
            logger.warning(f"An error occurred performing {operation_label}: {e!s}")
            return HttpResponseBadRequest(
@@ -3156,13 +3074,18 @@ class DocumentOperationPermissionMixin(PassUserMixin, DocumentSelectionMixin):
                name="BulkEditDocumentsResult",
                fields={
                    "result": serializers.CharField(),
-                    "task_id": serializers.CharField(),
+                    "task_id": serializers.CharField(required=False),
                },
            ),
        },
    ),
 )
 class BulkEditView(DocumentOperationPermissionMixin):
+    LEGACY_MODIFIED_FIELDS = {
+        "delete": "deleted_at",
+        "reprocess": "checksum",
+    }
+
    serializer_class = BulkEditSerializer

    def post(self, request, *args, **kwargs):
@@ -3192,6 +3115,14 @@ class BulkEditView(DocumentOperationPermissionMixin):
            user=user,
            validated_data=serializer.validated_data,
        )
+        if method.__name__ in self.METHOD_NAMES_REQUIRING_USER:
+            parameters["user"] = user
+        if method.__name__ in self.METHOD_NAMES_REQUIRING_TRIGGER_SOURCE:
+            parameters["trigger_source"] = (
+                PaperlessTask.TriggerSource.WEB_UI
+                if from_webui
+                else PaperlessTask.TriggerSource.API_UPLOAD
+            )
        if not has_document_operation_permissions(
            user=user,
            documents=documents,
@@ -3201,12 +3132,38 @@ class BulkEditView(DocumentOperationPermissionMixin):
            return HttpResponseForbidden("Insufficient permissions")

        try:
-            return self._queue_bulk_operation(
-                method,
-                documents,
-                parameters,
-                from_webui,
-            )
+            if method.__name__ in QUEUED_OPERATIONS:
+                return self._queue_bulk_operation(
+                    method,
+                    documents,
+                    parameters,
+                    from_webui,
+                )
+            modified_field = self.LEGACY_MODIFIED_FIELDS.get(method.__name__)
+            if settings.AUDIT_LOG_ENABLED and modified_field:
+                old_values = snapshot_field(documents, modified_field)
+
+            result = method(documents, **parameters)
+
+            if settings.AUDIT_LOG_ENABLED and modified_field:
+                new_values = snapshot_field(documents, modified_field)
+                for doc in Document.objects.filter(pk__in=documents):
+                    LogEntry.objects.log_create(
+                        instance=doc,
+                        changes={
+                            modified_field: [
+                                old_values[doc.pk],
+                                new_values[doc.pk],
+                            ],
+                        },
+                        action=LogEntry.Action.UPDATE,
+                        actor=user,
+                        additional_data={
+                            "reason": f"Bulk edit: {method.__name__}",
+                        },
+                    )
+
+            return Response({"result": result})
        except Exception as e:
            logger.warning(f"An error occurred performing bulk edit: {e!s}")
            return HttpResponseBadRequest(
@@ -3223,7 +3180,6 @@ class BulkEditView(DocumentOperationPermissionMixin):
                name="RotateDocumentsResult",
                fields={
                    "result": serializers.CharField(),
-                    "task_id": serializers.CharField(),
                },
            ),
        },
@@ -3251,7 +3207,6 @@ class RotateDocumentsView(DocumentOperationPermissionMixin):
                name="MergeDocumentsResult",
                fields={
                    "result": serializers.CharField(),
-                    "task_id": serializers.CharField(),
                },
            ),
        },
@@ -3279,7 +3234,6 @@ class MergeDocumentsView(DocumentOperationPermissionMixin):
                name="MergeDocumentsAsVersionsResult",
                fields={
                    "result": serializers.CharField(),
-                    "task_id": serializers.CharField(),
                },
            ),
        },
@@ -3307,7 +3261,6 @@ class MergeDocumentsAsVersionsView(DocumentOperationPermissionMixin):
                name="DeleteDocumentsResult",
                fields={
                    "result": serializers.CharField(),
-                    "task_id": serializers.CharField(),
                },
            ),
        },
@@ -3335,7 +3288,6 @@ class DeleteDocumentsView(DocumentOperationPermissionMixin):
                name="ReprocessDocumentsResult",
                fields={
                    "result": serializers.CharField(),
-                    "task_id": serializers.CharField(),
                },
            ),
        },
@@ -3363,7 +3315,6 @@ class ReprocessDocumentsView(DocumentOperationPermissionMixin):
                name="EditPdfDocumentsResult",
                fields={
                    "result": serializers.CharField(),
-                    "task_id": serializers.CharField(),
                },
            ),
        },
@@ -3391,7 +3342,6 @@ class EditPdfDocumentsView(DocumentOperationPermissionMixin):
                name="RemovePasswordDocumentsResult",
                fields={
                    "result": serializers.CharField(),
-                    "task_id": serializers.CharField(),
                },
            ),
        },
@@ -5139,8 +5089,6 @@ class WorkflowViewSet(ModelViewSet[Workflow]):

    serializer_class = WorkflowSerializer
    pagination_class = StandardPagination
-    filter_backends = (DjangoFilterBackend,)
-    filterset_class = WorkflowFilterSet

    model = Workflow