From b58d36bf2ec964b172b93d981f1b64396626c0df Mon Sep 17 00:00:00 2001
From: Matt Dawkins <matt.dawkins@kitware.com>
Date: Thu, 29 Jan 2026 12:58:46 -0500
Subject: [PATCH 1/8] Allow temporal filter to control what gets run in
 pipelines

---
 client/dive-common/apispec.ts                 |  2 +-
 .../components/RunPipelineMenu.vue            |  8 +-
 .../platform/desktop/backend/native/viame.ts  | 74 ++++++++++++++++++-
 client/platform/desktop/constants.ts          |  2 +-
 client/platform/desktop/frontend/api.ts       |  3 +-
 .../frontend/components/ViewerLoader.vue      | 15 +++-
 client/platform/web-girder/api/rpc.service.ts | 22 ++++--
 .../web-girder/views/ViewerLoader.vue         | 13 ++++
 server/dive_server/crud_rpc.py                |  4 +-
 server/dive_server/views_rpc.py               | 23 +++++-
 server/dive_tasks/tasks.py                    | 58 ++++++++++++++-
 server/dive_utils/types.py                    |  5 +-
 12 files changed, 207 insertions(+), 22 deletions(-)

diff --git a/client/dive-common/apispec.ts b/client/dive-common/apispec.ts
index d8888c6b1..6b416378c 100644
--- a/client/dive-common/apispec.ts
+++ b/client/dive-common/apispec.ts
@@ -183,7 +183,7 @@ interface DatasetMeta extends DatasetMetaMutable {
 
 interface Api {
   getPipelineList(): Promise<Pipelines>;
-  runPipeline(itemId: string, pipeline: Pipe, additionalConfig?: Record<string, string>): Promise<unknown>;
+  runPipeline(itemId: string, pipeline: Pipe, frameRange?: [number, number] | null, additionalConfig?: Record<string, string>): Promise<unknown>;
   deleteTrainedPipeline(pipeline: Pipe): Promise<void>;
   exportTrainedPipeline(path: string, pipeline: Pipe): Promise<unknown>;
 
diff --git a/client/dive-common/components/RunPipelineMenu.vue b/client/dive-common/components/RunPipelineMenu.vue
index d8ee333ff..1f234ae62 100644
--- a/client/dive-common/components/RunPipelineMenu.vue
+++ b/client/dive-common/components/RunPipelineMenu.vue
@@ -75,6 +75,11 @@ export default defineComponent({
       type: Boolean,
       default: false,
     },
+    /* Time filter range from the viewer - [startFrame, endFrame] or null */
+    timeFilter: {
+      type: Array as unknown as PropType<[number, number] | null>,
+      default: null,
+    },
   },
 
   setup(props) {
@@ -200,10 +205,11 @@ export default defineComponent({
         datasetIds = props.selectedDatasetIds.map((item) => item.substring(0, item.lastIndexOf('/')));
       }
       selectedPipeline.value = pipeline;
+      const frameRange = props.timeFilter;
       await _runPipelineRequest(() => Promise.all(
         datasetIds.map((id) => {
           const additionalConfig = additionalConfigById ? additionalConfigById[id] : undefined;
-          return runPipeline(id, pipeline, additionalConfig);
+          return runPipeline(id, pipeline, frameRange, additionalConfig);
         }),
       ));
     }
diff --git a/client/platform/desktop/backend/native/viame.ts b/client/platform/desktop/backend/native/viame.ts
index 98dd1e8fc..2e506d93c 100644
--- a/client/platform/desktop/backend/native/viame.ts
+++ b/client/platform/desktop/backend/native/viame.ts
@@ -31,6 +31,59 @@ import {
 const PipelineRelativeDir = 'configs/pipelines';
 const DiveJobManifestName = 'dive_job_manifest.json';
 
+/**
+ * Filter an image list to only include images within frame range.
+ * @param imageList List of image file paths
+ * @param frameRange Tuple of (start_frame, end_frame) inclusive (0-indexed)
+ * @returns Filtered list of image file paths
+ */
+function filterImageListByFrameRange(
+  imageList: string[],
+  frameRange: [number, number],
+): string[] {
+  const [startFrame, endFrame] = frameRange;
+  // Ensure we don't go out of bounds
+  const safeStart = Math.max(0, startFrame);
+  const safeEnd = Math.min(endFrame, imageList.length - 1);
+  return imageList.slice(safeStart, safeEnd + 1);
+}
+
+/**
+ * Filter VIAME CSV to only include detections within frame range.
+ * @param csvPath Path to the input CSV file
+ * @param frameRange Tuple of (start_frame, end_frame) inclusive
+ * @returns Path to the filtered CSV file
+ */
+async function filterCsvByFrameRange(
+  csvPath: string,
+  frameRange: [number, number],
+): Promise<string> {
+  const [startFrame, endFrame] = frameRange;
+  const filteredPath = csvPath.replace('.csv', '_filtered.csv');
+
+  const content = await fs.readFile(csvPath, 'utf-8');
+  const lines = content.split('\n');
+  const filteredLines: string[] = [];
+
+  for (const line of lines) {
+    if (line.startsWith('#') || line.trim() === '') {
+      filteredLines.push(line);
+      // eslint-disable-next-line no-continue
+      continue;
+    }
+    const parts = line.split(',');
+    if (parts.length >= 3) {
+      const frame = parseInt(parts[2], 10);
+      if (!Number.isNaN(frame) && frame >= startFrame && frame <= endFrame) {
+        filteredLines.push(line);
+      }
+    }
+  }
+
+  await fs.writeFile(filteredPath, filteredLines.join('\n'));
+  return filteredPath;
+}
+
 export interface ViameConstants {
   setupScriptAbs: string; // abs path setup comman
   trainingExe: string; // name of training binary on PATH
@@ -108,7 +161,7 @@ async function runPipeline(
   viameConstants: ViameConstants,
   forceTranscodedVideo?: boolean,
 ): Promise<DesktopJob> {
-  const { datasetId, pipeline } = runPipelineArgs;
+  const { datasetId, pipeline, frameRange } = runPipelineArgs;
 
   const isValid = await validateViamePath(settings);
   if (isValid !== true) {
@@ -199,6 +252,10 @@ async function runPipeline(
     if (meta.type === MultiType) {
       imageList = getMultiCamImageFiles(meta);
     }
+    // Filter image list by frame range if specified
+    if (frameRange) {
+      imageList = filterImageListByFrameRange(imageList, frameRange);
+    }
     const fileData = imageList
       .map((f) => npath.join(meta.originalBasePath, f))
       .join('\n');
@@ -293,8 +350,19 @@ async function runPipeline(
     if (code === 0) {
       try {
         if (!pipelineCreatesDatasetMarkers.includes(runPipelineArgs.pipeline.type)) {
-          // Filter and transcode pipelines should ensure that detector/track output files are located in the new dataset directory
-          const { meta: newMeta } = await common.ingestDataFiles(settings, datasetId, [detectorOutput, trackOutput], multiOutFiles);
+          let finalDetectorOutput = detectorOutput;
+          let finalTrackOutput = trackOutput;
+
+          if (frameRange && metaType === 'video') {
+            if (await fs.pathExists(trackOutput)) {
+              finalTrackOutput = await filterCsvByFrameRange(trackOutput, frameRange);
+            }
+            if (await fs.pathExists(detectorOutput)) {
+              finalDetectorOutput = await filterCsvByFrameRange(detectorOutput, frameRange);
+            }
+          }
+
+          const { meta: newMeta } = await common.ingestDataFiles(settings, datasetId, [finalDetectorOutput, finalTrackOutput], multiOutFiles);
           if (newMeta) {
             meta.attributes = newMeta.attributes;
             await common.saveMetadata(settings, datasetId, meta);
diff --git a/client/platform/desktop/constants.ts b/client/platform/desktop/constants.ts
index 4210319bb..bda8ff887 100644
--- a/client/platform/desktop/constants.ts
+++ b/client/platform/desktop/constants.ts
@@ -175,8 +175,8 @@ export interface RunPipeline extends JobArgs {
   type: JobType.RunPipeline;
   datasetId: string;
   pipeline: Pipe;
-  /** Optional parameters to pass to the pipeline via -s flags */
   pipelineParams?: Record<string, string>;
+  frameRange?: [number, number] | null;
   outputDatasetName?: string;
 }
 
diff --git a/client/platform/desktop/frontend/api.ts b/client/platform/desktop/frontend/api.ts
index 49a26a709..81790f6a9 100644
--- a/client/platform/desktop/frontend/api.ts
+++ b/client/platform/desktop/frontend/api.ts
@@ -118,11 +118,12 @@ async function getTrainingConfigurations(): Promise<TrainingConfigs> {
   return window.diveDesktop.invoke('get-training-configs');
 }
 
-async function runPipeline(itemId: string, pipeline: Pipe, additionalConfig?: Record<string, string>): Promise<void> {
+async function runPipeline(itemId: string, pipeline: Pipe, frameRange?: [number, number] | null, additionalConfig?: Record<string, string>): Promise<void> {
   const args: RunPipeline = {
     type: JobType.RunPipeline,
     pipeline,
     datasetId: itemId,
+    frameRange: frameRange || undefined,
     pipelineParams: additionalConfig,
   };
   gpuJobQueue.enqueue(args);
diff --git a/client/platform/desktop/frontend/components/ViewerLoader.vue b/client/platform/desktop/frontend/components/ViewerLoader.vue
index 94ca70d8c..7303d55e4 100644
--- a/client/platform/desktop/frontend/components/ViewerLoader.vue
+++ b/client/platform/desktop/frontend/components/ViewerLoader.vue
@@ -1,6 +1,6 @@
 <script lang="ts">
 import {
-  computed, defineComponent, ref, watch,
+  computed, defineComponent, ref, watch, Ref, watchEffect,
 } from 'vue';
 import Viewer from 'dive-common/components/Viewer.vue';
 import RunPipelineMenu from 'dive-common/components/RunPipelineMenu.vue';
@@ -85,6 +85,17 @@ export default defineComponent({
       return props.id;
     });
     const readOnlyMode = computed(() => settings.value?.readonlyMode || false);
+    const timeFilter: Ref<[number, number] | null> = ref(null);
+
+    // Watch the viewer's trackFilters.timeFilters and sync to local ref
+    watchEffect(() => {
+      if (viewerRef.value?.trackFilters?.timeFilters?.value) {
+        timeFilter.value = viewerRef.value.trackFilters.timeFilters.value;
+      } else {
+        timeFilter.value = null;
+      }
+    });
+
     const runningPipelines = computed(() => {
       const results: string[] = [];
       // Check if any running job contains the root props.id
@@ -120,6 +131,7 @@ export default defineComponent({
       readOnlyMode,
       runningPipelines,
       largeImageWarning,
+      timeFilter,
     };
   },
 });
@@ -159,6 +171,7 @@ export default defineComponent({
         :camera-numbers="camNumbers"
         :running-pipelines="runningPipelines"
         :read-only-mode="readOnlyMode"
+        :time-filter="timeFilter"
         v-bind="{ buttonOptions, menuOptions }"
       />
       <ImportAnnotations
diff --git a/client/platform/web-girder/api/rpc.service.ts b/client/platform/web-girder/api/rpc.service.ts
index f55323e48..3b7239df6 100644
--- a/client/platform/web-girder/api/rpc.service.ts
+++ b/client/platform/web-girder/api/rpc.service.ts
@@ -10,14 +10,20 @@ function postProcess(folderId: string, skipJobs = false, skipTranscoding = false
   });
 }
 
-function runPipeline(itemId: string, pipeline: Pipe, additionalConfig?: Record<string, string>) {
-  return girderRest.post('dive_rpc/pipeline', null, {
-    params: {
-      folderId: itemId,
-      pipeline,
-      pipelineParams: additionalConfig,
-    },
-  });
+function runPipeline(itemId: string, pipeline: Pipe, frameRange?: [number, number] | null, additionalConfig?: Record<string, string>) {
+  const params: Record<string, unknown> = {
+    folderId: itemId,
+    pipeline,
+  };
+  if (frameRange) {
+    const [startFrame, endFrame] = frameRange;
+    params.startFrame = startFrame;
+    params.endFrame = endFrame;
+  }
+  if (additionalConfig) {
+    params.pipelineParams = additionalConfig;
+  }
+  return girderRest.post('dive_rpc/pipeline', null, { params });
 }
 
 function runTraining(
diff --git a/client/platform/web-girder/views/ViewerLoader.vue b/client/platform/web-girder/views/ViewerLoader.vue
index 91544ae1b..fe248e992 100644
--- a/client/platform/web-girder/views/ViewerLoader.vue
+++ b/client/platform/web-girder/views/ViewerLoader.vue
@@ -1,6 +1,7 @@
 <script lang="ts">
 import {
   computed, defineComponent, onBeforeUnmount, onMounted, ref, toRef, watch, Ref, PropType,
+  watchEffect,
 } from 'vue';
 
 import Viewer from 'dive-common/components/Viewer.vue';
@@ -106,12 +107,22 @@ export default defineComponent({
     const currentJob = computed(() => getters['Jobs/datasetCompleteJobs'](props.id));
 
     const typeList: Ref<string[]> = ref([]);
+    const timeFilter: Ref<[number, number] | null> = ref(null);
 
     const findType = async () => {
       const meta = await loadMetadata(props.id);
       typeList.value = [meta.type];
     };
     findType();
+
+    // Watch the viewer's trackFilters.timeFilters and sync to local ref
+    watchEffect(() => {
+      if (viewerRef.value?.trackFilters?.timeFilters?.value) {
+        timeFilter.value = viewerRef.value.trackFilters.timeFilters.value;
+      } else {
+        timeFilter.value = null;
+      }
+    });
     const runningPipelines = computed(() => {
       const results: string[] = [];
       if (getters['Jobs/datasetRunningState'](props.id)) {
@@ -226,6 +237,7 @@ export default defineComponent({
       routeSet,
       largeImageWarning,
       typeList,
+      timeFilter,
     };
   },
 });
@@ -265,6 +277,7 @@ export default defineComponent({
         :selected-dataset-ids="[id]"
         :running-pipelines="runningPipelines"
         :read-only-mode="revisionNum !== undefined"
+        :time-filter="timeFilter"
       />
       <ImportAnnotations
         :button-options="buttonOptions"
diff --git a/server/dive_server/crud_rpc.py b/server/dive_server/crud_rpc.py
index defce5a6d..9fab8053c 100644
--- a/server/dive_server/crud_rpc.py
+++ b/server/dive_server/crud_rpc.py
@@ -190,7 +190,8 @@ def run_pipeline(
     folder: types.GirderModel,
     pipeline: types.PipelineDescription,
     force_transcoded=False,
-    pipeline_params: dict[str, str] = None,
+    frame_range: Optional[Tuple[int, int]] = None,
+    pipeline_params: Optional[Dict[str, str]] = None,
 ) -> types.GirderModel:
     """
     Run a pipeline on a dataset.
@@ -236,6 +237,7 @@ def run_pipeline(
         'user_id': str(user.get('_id', 'unknown')),
         'user_login': user.get('login', 'unknown'),
         'force_transcoded': force_transcoded,
+        'frame_range': frame_range,
         'pipeline_params': pipeline_params,
     }
     newjob = tasks.run_pipeline.apply_async(
diff --git a/server/dive_server/views_rpc.py b/server/dive_server/views_rpc.py
index a27114602..d3a3ae552 100644
--- a/server/dive_server/views_rpc.py
+++ b/server/dive_server/views_rpc.py
@@ -49,6 +49,20 @@ def __init__(self, resourceName):
             default=False,
             required=False,
         )
+        .param(
+            "startFrame",
+            "Start frame (inclusive) for frame range filtering",
+            paramType="query",
+            dataType="integer",
+            required=False,
+        )
+        .param(
+            "endFrame",
+            "End frame (inclusive) for frame range filtering",
+            paramType="query",
+            dataType="integer",
+            required=False,
+        )
         .jsonParam("pipeline", "The pipeline to run on the dataset", required=True)
         .jsonParam(
             "pipelineParams",
@@ -57,8 +71,13 @@ def __init__(self, resourceName):
             default=None,
         )
     )
-    def run_pipeline_task(self, folder, forceTranscoded, pipeline: PipelineDescription, pipelineParams: dict[str, str]):
-        return crud_rpc.run_pipeline(self.getCurrentUser(), folder, pipeline, forceTranscoded, pipelineParams)
+    def run_pipeline_task(self, folder, forceTranscoded, startFrame, endFrame, pipeline: PipelineDescription, pipelineParams):
+        frame_range = None
+        if startFrame is not None and endFrame is not None:
+            frame_range = (startFrame, endFrame)
+        return crud_rpc.run_pipeline(
+            self.getCurrentUser(), folder, pipeline, forceTranscoded, frame_range, pipelineParams
+        )
     
     @access.user
     @autoDescribeRoute(
diff --git a/server/dive_tasks/tasks.py b/server/dive_tasks/tasks.py
index 9614c7725..28f4c1847 100644
--- a/server/dive_tasks/tasks.py
+++ b/server/dive_tasks/tasks.py
@@ -23,6 +23,53 @@
 from dive_utils import constants, fromMeta
 from dive_utils.types import AvailableJobSchema, GirderModel, PipelineJob, TrainingJob, ExportTrainedPipelineJob
 
+
+def filter_csv_by_frame_range(csv_path: str, frame_range: Tuple[int, int]) -> str:
+    """Filter VIAME CSV to only include detections within frame range.
+
+    Args:
+        csv_path: Path to the input CSV file
+        frame_range: Tuple of (start_frame, end_frame) inclusive
+
+    Returns:
+        Path to the filtered CSV file
+    """
+    start_frame, end_frame = frame_range
+    filtered_path = csv_path.replace('.csv', '_filtered.csv')
+
+    with open(csv_path, 'r') as infile, open(filtered_path, 'w') as outfile:
+        for line in infile:
+            if line.startswith('#'):
+                outfile.write(line)
+                continue
+            parts = line.split(',')
+            if len(parts) >= 3:
+                try:
+                    frame = int(parts[2])  # Frame number is column 3 (0-indexed as column 2)
+                    if start_frame <= frame <= end_frame:
+                        outfile.write(line)
+                except ValueError:
+                    # If frame number can't be parsed, include the line
+                    outfile.write(line)
+    return filtered_path
+
+
+def filter_image_list_by_frame_range(image_list: List[str], frame_range: Tuple[int, int]) -> List[str]:
+    """Filter an image list to only include images within frame range.
+
+    Args:
+        image_list: List of image file paths
+        frame_range: Tuple of (start_frame, end_frame) inclusive (0-indexed)
+
+    Returns:
+        Filtered list of image file paths
+    """
+    start_frame, end_frame = frame_range
+    # Ensure we don't go out of bounds
+    start_frame = max(0, start_frame)
+    end_frame = min(end_frame, len(image_list) - 1)
+    return image_list[start_frame:end_frame + 1]
+
 EMPTY_JOB_SCHEMA: AvailableJobSchema = {
     'pipelines': {},
     'training': {
@@ -198,6 +245,7 @@ def run_pipeline(self: Task, params: PipelineJob):
     output_folder_id = str(params["output_folder"])
     input_revision = params["input_revision"]
     force_transcoded = params.get('force_transcoded', False)
+    frame_range = params.get('frame_range', None)
     with tempfile.TemporaryDirectory() as _working_directory, suppress(utils.CanceledError):
         _working_directory_path = Path(_working_directory)
         input_path = utils.make_directory(_working_directory_path / 'input')
@@ -241,8 +289,12 @@ def run_pipeline(self: Task, params: PipelineJob):
                 f"-s track_writer:file_name={shlex.quote(track_output_file)}",
             ]
         elif input_type == constants.ImageSequenceType:
+            # Filter image list by frame range if specified
+            filtered_media_list = input_media_list
+            if frame_range is not None:
+                filtered_media_list = filter_image_list_by_frame_range(input_media_list, frame_range)
             with open(img_list_path, "w+") as img_list_file:
-                img_list_file.write('\n'.join(input_media_list))
+                img_list_file.write('\n'.join(filtered_media_list))
             command = [
                 f". {shlex.quote(str(conf.viame_setup_script))} &&",
                 f"KWIVER_DEFAULT_LOG_LEVEL={shlex.quote(conf.kwiver_log_level)}",
@@ -284,6 +336,10 @@ def run_pipeline(self: Task, params: PipelineJob):
         else:
             output_file = detector_output_file
 
+        # Filter output CSV by frame range for videos
+        if frame_range is not None and input_type == constants.VideoType:
+            output_file = filter_csv_by_frame_range(output_file, frame_range)
+
         manager.updateStatus(JobStatus.PUSHING_OUTPUT)
         newfile = gc.uploadFileToFolder(output_folder_id, output_file)
 
diff --git a/server/dive_utils/types.py b/server/dive_utils/types.py
index e057a6e3a..403655de2 100644
--- a/server/dive_utils/types.py
+++ b/server/dive_utils/types.py
@@ -97,8 +97,9 @@ class PipelineJob(TypedDict):
     output_folder: str  # Where to upload results
     user_id: str  # user id who started the job
     user_login: str  # login of user who started the kjob
-    force_transcoded: Optional[bool]  # Force using the transcoded version
-    pipeline_params: Optional[dict[str, str]]
+    force_transcoded: Optional[bool]
+    frame_range: Optional[Tuple[int, int]]
+    pipeline_params: Optional[Dict[str, str]]
 
 
 class TrainingJob(TypedDict):

From 1225d7e68f8ab879016b751d4d758e50a924293b Mon Sep 17 00:00:00 2001
From: Matt Dawkins <matt.dawkins@kitware.com>
Date: Tue, 3 Feb 2026 13:22:10 -0500
Subject: [PATCH 2/8] Persist time filters per dataset

Save and load timeFilters in dataset metadata following the established
confidenceFilters pattern. Filters are saved on every change (toggle,
slider, timeline drag) and restored when the dataset is reopened.
---
 client/dive-common/apispec.ts                    | 3 ++-
 client/dive-common/components/Viewer.vue         | 9 +++++++++
 client/platform/desktop/backend/native/common.ts | 3 +++
 client/src/components/controls/Timeline.vue      | 8 ++++++--
 server/dive_utils/models.py                      | 1 +
 5 files changed, 21 insertions(+), 3 deletions(-)

diff --git a/client/dive-common/apispec.ts b/client/dive-common/apispec.ts
index 6b416378c..f2b875435 100644
--- a/client/dive-common/apispec.ts
+++ b/client/dive-common/apispec.ts
@@ -161,12 +161,13 @@ interface DatasetMetaMutable {
   customTypeStyling?: Record<string, CustomStyle>;
   customGroupStyling?: Record<string, CustomStyle>;
   confidenceFilters?: Record<string, number>;
+  timeFilters?: [number, number] | null;
   imageEnhancements?: ImageEnhancements;
   attributes?: Readonly<Record<string, Attribute>>;
   attributeTrackFilters?: Readonly<Record<string, AttributeTrackFilter>>;
   error?: string;
 }
-const DatasetMetaMutableKeys = ['attributes', 'confidenceFilters', 'imageEnhancements', 'customTypeStyling', 'customGroupStyling', 'attributeTrackFilters'];
+const DatasetMetaMutableKeys = ['attributes', 'confidenceFilters', 'timeFilters', 'imageEnhancements', 'customTypeStyling', 'customGroupStyling', 'attributeTrackFilters'];
 
 interface DatasetMeta extends DatasetMetaMutable {
   id: Readonly<string>;
diff --git a/client/dive-common/components/Viewer.vue b/client/dive-common/components/Viewer.vue
index 8d562df15..a12d09d07 100644
--- a/client/dive-common/components/Viewer.vue
+++ b/client/dive-common/components/Viewer.vue
@@ -433,6 +433,7 @@ export default defineComponent({
           customTypeStyling: trackStyleManager.getTypeStyles(trackFilters.allTypes),
           customGroupStyling: groupStyleManager.getTypeStyles(groupFilters.allTypes),
           confidenceFilters: trackFilters.confidenceFilters.value,
+          timeFilters: trackFilters.timeFilters.value,
           imageEnhancements: imageEnhancements.value,
           // TODO Group confidence filters are not yet supported.
         }, saveSet);
@@ -458,6 +459,12 @@ export default defineComponent({
       });
     }
 
+    function saveTimeFilter() {
+      saveMetadata(datasetId.value, {
+        timeFilters: trackFilters.timeFilters.value,
+      });
+    }
+
     function saveImageEnhancements() {
       saveMetadata(datasetId.value, {
         imageEnhancements: imageEnhancements.value,
@@ -577,6 +584,7 @@ export default defineComponent({
           loadAttributes(meta.attributes);
         }
         trackFilters.setConfidenceFilters(meta.confidenceFilters);
+        trackFilters.setTimeFilters(meta.timeFilters ?? null);
         if (meta.imageEnhancements) {
           setImageEnhancements(meta.imageEnhancements);
         }
@@ -882,6 +890,7 @@ export default defineComponent({
       handler: globalHandler,
       save,
       saveThreshold,
+      saveTimeFilter,
       updateTime,
       // multicam
       multiCamList,
diff --git a/client/platform/desktop/backend/native/common.ts b/client/platform/desktop/backend/native/common.ts
index 3068bc910..845f053fd 100644
--- a/client/platform/desktop/backend/native/common.ts
+++ b/client/platform/desktop/backend/native/common.ts
@@ -682,6 +682,9 @@ async function saveMetadata(settings: Settings, datasetId: string, args: Dataset
   if (args.attributes) {
     existing.attributes = args.attributes;
   }
+  if (args.timeFilters !== undefined) {
+    existing.timeFilters = args.timeFilters;
+  }
   if (args.error) {
     existing.error = args.error;
   }
diff --git a/client/src/components/controls/Timeline.vue b/client/src/components/controls/Timeline.vue
index 50a7fb135..99ded4bab 100644
--- a/client/src/components/controls/Timeline.vue
+++ b/client/src/components/controls/Timeline.vue
@@ -4,9 +4,9 @@ import * as d3 from 'd3';
 import {
   ref, computed, watch, onMounted, onBeforeUnmount, defineComponent, PropType,
 } from 'vue';
-import { DatasetType } from 'dive-common/apispec';
+import { DatasetType, useApi } from 'dive-common/apispec';
 import { frameToTimestamp } from 'vue-media-annotator/utils';
-import { useTrackFilters, useTime } from '../../provides';
+import { useTrackFilters, useTime, useDatasetId } from '../../provides';
 
 type TimeFilterType = 'start' | 'end' | null;
 
@@ -34,6 +34,8 @@ export default defineComponent({
   setup(props, { emit }) {
     const trackFilters = useTrackFilters();
     const { frameRate } = useTime();
+    const { saveMetadata } = useApi();
+    const datasetId = useDatasetId();
 
     const init = ref(!!props.maxFrame || 1);
     const mounted = ref(false);
@@ -318,6 +320,7 @@ export default defineComponent({
         draggingTimeFilter.value = null;
         dragTooltipFrame.value = null;
         dragTooltipPosition.value = null;
+        saveMetadata(datasetId.value, { timeFilters: trackFilters.timeFilters.value });
         return;
       }
       if (dragging.value) {
@@ -386,6 +389,7 @@ export default defineComponent({
         draggingTimeFilter.value = null;
         dragTooltipFrame.value = null;
         dragTooltipPosition.value = null;
+        saveMetadata(datasetId.value, { timeFilters: trackFilters.timeFilters.value });
       }
     }
 
diff --git a/server/dive_utils/models.py b/server/dive_utils/models.py
index 9c18c0e27..46870642b 100644
--- a/server/dive_utils/models.py
+++ b/server/dive_utils/models.py
@@ -232,6 +232,7 @@ class MetadataMutable(BaseModel):
     customTypeStyling: Optional[Dict[str, CustomStyle]]
     customGroupStyling: Optional[Dict[str, CustomStyle]]
     confidenceFilters: Optional[Dict[str, float]]
+    timeFilters: Optional[List[int]]
     imageEnhancements: Optional[Dict[str, Any]]
     attributes: Optional[Dict[str, Attribute]]
     attributeTrackFilters: Optional[Dict[str, AttributeTrackFilter]]

From fca48fb6da91aa1ca6e1b50daa4d7b77ee1eb024 Mon Sep 17 00:00:00 2001
From: Matt Dawkins <matt.dawkins@kitware.com>
Date: Tue, 3 Feb 2026 13:22:22 -0500
Subject: [PATCH 3/8] Add text inputs and overlay panel for time filter
 settings

Replace the hover-based v-menu with a click-toggled overlay panel that
appears above the controls bar on the right third of the screen. Add
frame number text fields and HH:MM:SS time inputs (for video datasets)
alongside the existing sliders. Clicking the filter button enables the
filter and opens settings; clicking again disables it; clicking outside
closes the panel without disabling.
---
 client/src/components/controls/Controls.vue | 332 ++++++++++++++------
 1 file changed, 236 insertions(+), 96 deletions(-)

diff --git a/client/src/components/controls/Controls.vue b/client/src/components/controls/Controls.vue
index 876eefd25..55731ac07 100644
--- a/client/src/components/controls/Controls.vue
+++ b/client/src/components/controls/Controls.vue
@@ -6,10 +6,10 @@ import {
 import { usePrompt } from 'dive-common/vue-utilities/prompt-service';
 import context from 'dive-common/store/context';
 import { clientSettings } from 'dive-common/store/settings';
-import { DatasetType } from 'dive-common/apispec';
+import { DatasetType, useApi } from 'dive-common/apispec';
 import { frameToTimestamp } from 'vue-media-annotator/utils';
 import { injectAggregateController } from '../annotators/useMediaController';
-import { useTime, useTrackFilters } from '../../provides';
+import { useTime, useTrackFilters, useDatasetId } from '../../provides';
 
 export default defineComponent({
   name: 'Controls',
@@ -34,6 +34,8 @@ export default defineComponent({
     const { frameRate } = useTime();
     const { visible } = usePrompt();
     const trackFilters = useTrackFilters();
+    const { saveMetadata } = useApi();
+    const datasetId = useDatasetId();
     const activeLockedCamera = ref(false);
     const activeTimeFilter = ref(false);
     watch(mediaController.frame, (frame) => {
@@ -74,18 +76,49 @@ export default defineComponent({
     const timeFilterMin = computed(() => trackFilters.timeFilters.value?.[0] ?? 0);
     const timeFilterMax = computed(() => trackFilters.timeFilters.value?.[1] ?? mediaController.maxFrame.value);
 
-    function toggleTimeFilter() {
-      if (trackFilters.timeFilters.value === null) {
+    function saveTimeFilter() {
+      saveMetadata(datasetId.value, { timeFilters: trackFilters.timeFilters.value });
+    }
+
+    function handleTimeFilterClick() {
+      if (!timeFilterActive.value) {
+        // Not enabled: enable and open settings
         trackFilters.setTimeFilters([0, mediaController.maxFrame.value]);
-      } else {
+        saveTimeFilter();
+        activeTimeFilter.value = true;
+      } else if (activeTimeFilter.value) {
+        // Enabled and settings open: disable and close
         trackFilters.setTimeFilters(null);
+        saveTimeFilter();
+        activeTimeFilter.value = false;
+      } else {
+        // Enabled but settings closed: just open settings
+        activeTimeFilter.value = true;
       }
     }
 
+    const timeFilterBtnRef = ref<HTMLElement | null>(null);
+    const clickOutsideTimeFilter = {
+      handler() {
+        activeTimeFilter.value = false;
+      },
+      include() {
+        const els: HTMLElement[] = [];
+        if (timeFilterBtnRef.value) {
+          // Vue component ref: get the underlying DOM element
+          const el = (timeFilterBtnRef.value as unknown as { $el?: HTMLElement }).$el
+            ?? timeFilterBtnRef.value;
+          els.push(el);
+        }
+        return els;
+      },
+    };
+
     function updateTimeFilterMin(value: number) {
       const current = trackFilters.timeFilters.value;
       if (current) {
         trackFilters.setTimeFilters([value, current[1]]);
+        saveTimeFilter();
       }
     }
 
@@ -93,6 +126,7 @@ export default defineComponent({
       const current = trackFilters.timeFilters.value;
       if (current) {
         trackFilters.setTimeFilters([current[0], value]);
+        saveTimeFilter();
       }
     }
 
@@ -103,6 +137,68 @@ export default defineComponent({
       return frameToTimestamp(frame, frameRate.value);
     }
 
+    function timestampToFrame(timestamp: string): number | null {
+      if (!frameRate.value) return null;
+      const parts = timestamp.split(':');
+      if (parts.length !== 3) return null;
+      const hours = parseInt(parts[0], 10);
+      const minutes = parseInt(parts[1], 10);
+      const seconds = parseInt(parts[2], 10);
+      if (Number.isNaN(hours) || Number.isNaN(minutes) || Number.isNaN(seconds)) return null;
+      const totalSeconds = hours * 3600 + minutes * 60 + seconds;
+      return Math.round(totalSeconds * frameRate.value);
+    }
+
+    const minFrameInput = ref(String(timeFilterMin.value));
+    const maxFrameInput = ref(String(timeFilterMax.value));
+    const minTimeInput = ref(formatTimestamp(timeFilterMin.value) ?? '00:00:00');
+    const maxTimeInput = ref(formatTimestamp(timeFilterMax.value) ?? '00:00:00');
+
+    watch(timeFilterMin, (val) => {
+      minFrameInput.value = String(val);
+      minTimeInput.value = formatTimestamp(val) ?? '00:00:00';
+    });
+    watch(timeFilterMax, (val) => {
+      maxFrameInput.value = String(val);
+      maxTimeInput.value = formatTimestamp(val) ?? '00:00:00';
+    });
+
+    function applyMinFrame() {
+      const val = parseInt(minFrameInput.value, 10);
+      if (!Number.isNaN(val) && val >= 0 && val <= mediaController.maxFrame.value) {
+        updateTimeFilterMin(val);
+      } else {
+        minFrameInput.value = String(timeFilterMin.value);
+      }
+    }
+
+    function applyMaxFrame() {
+      const val = parseInt(maxFrameInput.value, 10);
+      if (!Number.isNaN(val) && val >= 0 && val <= mediaController.maxFrame.value) {
+        updateTimeFilterMax(val);
+      } else {
+        maxFrameInput.value = String(timeFilterMax.value);
+      }
+    }
+
+    function applyMinTime() {
+      const frame = timestampToFrame(minTimeInput.value);
+      if (frame !== null && frame >= 0 && frame <= mediaController.maxFrame.value) {
+        updateTimeFilterMin(frame);
+      } else {
+        minTimeInput.value = formatTimestamp(timeFilterMin.value) ?? '00:00:00';
+      }
+    }
+
+    function applyMaxTime() {
+      const frame = timestampToFrame(maxTimeInput.value);
+      if (frame !== null && frame >= 0 && frame <= mediaController.maxFrame.value) {
+        updateTimeFilterMax(frame);
+      } else {
+        maxTimeInput.value = formatTimestamp(timeFilterMax.value) ?? '00:00:00';
+      }
+    }
+
     return {
       activeLockedCamera,
       activeTimeFilter,
@@ -120,11 +216,22 @@ export default defineComponent({
       timeFilterActive,
       timeFilterMin,
       timeFilterMax,
-      toggleTimeFilter,
+      handleTimeFilterClick,
+      clickOutsideTimeFilter,
+      timeFilterBtnRef,
       updateTimeFilterMin,
       updateTimeFilterMax,
       isVideo,
+      frameRate,
       formatTimestamp,
+      minFrameInput,
+      maxFrameInput,
+      minTimeInput,
+      maxTimeInput,
+      applyMinFrame,
+      applyMaxFrame,
+      applyMinTime,
+      applyMaxTime,
     };
   },
 });
@@ -144,7 +251,119 @@ export default defineComponent({
         disabled: visible(),
       },
     ]"
+    style="position: relative;"
   >
+    <v-card
+      v-if="activeTimeFilter"
+      v-click-outside="clickOutsideTimeFilter"
+      outlined
+      class="pa-2 pr-4"
+      color="blue-grey darken-3"
+      style="position: absolute; bottom: 100%; right: 0; width: 33%; min-width: 400px; z-index: 10;"
+    >
+      <v-card-title>
+        Time Filter Settings
+      </v-card-title>
+      <v-card-text>
+        <v-row class="align-center" dense>
+          <v-col>
+            <div class="text-caption mb-2">
+              Filter tracks to only show those that intersect with this time range.
+            </div>
+          </v-col>
+        </v-row>
+        <div v-if="timeFilterActive">
+          <v-row class="align-center" dense>
+            <v-col cols="auto" style="min-width: 80px;">
+              Min Frame:
+            </v-col>
+            <v-col cols="auto" style="width: 80px;">
+              <v-text-field
+                v-model="minFrameInput"
+                type="number"
+                dense
+                hide-details
+                outlined
+                :min="0"
+                :max="mediaController.maxFrame.value"
+                @blur="applyMinFrame"
+                @keydown.enter="applyMinFrame"
+              />
+            </v-col>
+            <v-col>
+              <v-slider
+                :value="timeFilterMin"
+                :min="0"
+                :max="mediaController.maxFrame.value"
+                step="1"
+                dense
+                hide-details
+                thumb-label="always"
+                @change="updateTimeFilterMin"
+              />
+            </v-col>
+            <v-col v-if="isVideo && frameRate" cols="auto" style="min-width: 60px;">
+              Time:
+            </v-col>
+            <v-col v-if="isVideo && frameRate" cols="auto" style="width: 110px;">
+              <v-text-field
+                v-model="minTimeInput"
+                dense
+                hide-details
+                outlined
+                placeholder="HH:MM:SS"
+                @blur="applyMinTime"
+                @keydown.enter="applyMinTime"
+              />
+            </v-col>
+          </v-row>
+          <v-row class="align-center" dense>
+            <v-col cols="auto" style="min-width: 80px;">
+              Max Frame:
+            </v-col>
+            <v-col cols="auto" style="width: 80px;">
+              <v-text-field
+                v-model="maxFrameInput"
+                type="number"
+                dense
+                hide-details
+                outlined
+                :min="0"
+                :max="mediaController.maxFrame.value"
+                @blur="applyMaxFrame"
+                @keydown.enter="applyMaxFrame"
+              />
+            </v-col>
+            <v-col>
+              <v-slider
+                :value="timeFilterMax"
+                :min="0"
+                :max="mediaController.maxFrame.value"
+                step="1"
+                dense
+                hide-details
+                thumb-label="always"
+                @change="updateTimeFilterMax"
+              />
+            </v-col>
+            <v-col v-if="isVideo && frameRate" cols="auto" style="min-width: 60px;">
+              Time:
+            </v-col>
+            <v-col v-if="isVideo && frameRate" cols="auto" style="width: 110px;">
+              <v-text-field
+                v-model="maxTimeInput"
+                dense
+                hide-details
+                outlined
+                placeholder="HH:MM:SS"
+                @blur="applyMaxTime"
+                @keydown.enter="applyMaxTime"
+              />
+            </v-col>
+          </v-row>
+        </div>
+      </v-card-text>
+    </v-card>
     <v-card
       class="px-4 py-1"
       tile
@@ -213,97 +432,18 @@ export default defineComponent({
           class="pl-1 py-1 shrink d-flex"
           align="right"
         >
-          <v-menu
-            v-model="activeTimeFilter"
-            :nudge-left="28"
-            left
-            top
-            :close-on-content-click="false"
-            open-on-hover
-            open-delay="750"
-            close-delay="500"
+          <v-btn
+            ref="timeFilterBtnRef"
+            icon
+            small
+            :color="timeFilterActive ? 'primary' : 'default'"
+            title="Filter tracks by time range"
+            @click.stop="handleTimeFilterClick"
           >
-            <template #activator="{ on, attrs }">
-              <v-btn
-                icon
-                small
-                :color="timeFilterActive ? 'primary' : 'default'"
-                title="Filter tracks by time range"
-                v-bind="attrs"
-                v-on="on"
-                @click="toggleTimeFilter"
-              >
-                <v-icon v-bind="attrs" v-on="on">
-                  {{ timeFilterActive ? 'mdi-filter' : 'mdi-filter-outline' }}
-                </v-icon>
-              </v-btn>
-            </template>
-            <v-card
-              outlined
-              class="pa-2 pr-4"
-              color="blue-grey darken-3"
-              style="overflow-y: none"
-            >
-              <v-card-title>
-                Time Filter Settings
-              </v-card-title>
-              <v-card-text>
-                <v-row class="align-center" dense>
-                  <v-col>
-                    <div class="text-caption mb-2">
-                      Filter tracks to only show those that intersect with this time range.
-                    </div>
-                  </v-col>
-                </v-row>
-                <div v-if="timeFilterActive">
-                  <v-row class="align-center" dense>
-                    <v-col>
-                      Min Frame:
-                    </v-col>
-                    <v-col v-if="isVideo">
-                      {{ formatTimestamp(timeFilterMin) }}
-                    </v-col>
-                    <v-col>
-                      <v-slider
-                        :value="timeFilterMin"
-                        :min="0"
-                        :max="mediaController.maxFrame.value"
-                        step="1"
-                        dense
-                        hide-details
-                        thumb-label="always"
-                        @change="updateTimeFilterMin"
-                      />
-                    </v-col>
-                  </v-row>
-                  <v-row class="align-center" dense>
-                    <v-col>
-                      Max Frame:
-                    </v-col>
-                    <v-col v-if="isVideo">
-                      {{ formatTimestamp(timeFilterMax) }}
-                    </v-col>
-
-                    <v-col>
-                      <v-slider
-                        :value="timeFilterMax"
-                        :min="0"
-                        :max="mediaController.maxFrame.value"
-                        step="1"
-                        dense
-                        hide-details
-                        thumb-label="always"
-                        @change="updateTimeFilterMax"
-                      />
-                    </v-col>
-                  </v-row>
-                </div>
-                <div v-else>
-                  <p>Click the filter icon to enable time filtering</p>
-                </div>
-              </v-card-text>
-            </v-card>
-          </v-menu>
+            <v-icon>
+              {{ timeFilterActive ? 'mdi-filter' : 'mdi-filter-outline' }}
+            </v-icon>
+          </v-btn>
           <v-menu
             v-model="activeLockedCamera"
             :nudge-left="28"

From c34dbb845d1220406b9244bb232174166e17ad45 Mon Sep 17 00:00:00 2001
From: Matt Dawkins <matt.dawkins@kitware.com>
Date: Tue, 3 Feb 2026 14:45:04 -0500
Subject: [PATCH 4/8] Fix lint errors for CI: prefer-destructuring and
 no-restricted-syntax

---
 client/platform/desktop/backend/native/viame.ts | 15 +++++----------
 1 file changed, 5 insertions(+), 10 deletions(-)

diff --git a/client/platform/desktop/backend/native/viame.ts b/client/platform/desktop/backend/native/viame.ts
index 2e506d93c..f7ff19f53 100644
--- a/client/platform/desktop/backend/native/viame.ts
+++ b/client/platform/desktop/backend/native/viame.ts
@@ -63,22 +63,17 @@ async function filterCsvByFrameRange(
 
   const content = await fs.readFile(csvPath, 'utf-8');
   const lines = content.split('\n');
-  const filteredLines: string[] = [];
-
-  for (const line of lines) {
+  const filteredLines = lines.filter((line) => {
     if (line.startsWith('#') || line.trim() === '') {
-      filteredLines.push(line);
-      // eslint-disable-next-line no-continue
-      continue;
+      return true;
     }
     const parts = line.split(',');
     if (parts.length >= 3) {
       const frame = parseInt(parts[2], 10);
-      if (!Number.isNaN(frame) && frame >= startFrame && frame <= endFrame) {
-        filteredLines.push(line);
-      }
+      return !Number.isNaN(frame) && frame >= startFrame && frame <= endFrame;
     }
-  }
+    return false;
+  });
 
   await fs.writeFile(filteredPath, filteredLines.join('\n'));
   return filteredPath;

From 0028796a2d05d91e4615005b2b8b647b5f95e77b Mon Sep 17 00:00:00 2001
From: Matt Dawkins <matt.dawkins@kitware.com>
Date: Mon, 9 Feb 2026 13:31:11 -0500
Subject: [PATCH 5/8] Set downsampler start/end frame params from DIVE frame
 range

Pass start_frame, end_frame, and frame_range_is_native to the KWIVER
downsampler when the user has selected a frame range, so VIAME skips
frames outside the range rather than post-filtering. The is_native flag
is set based on whether DIVE is downsampling (fps < originalFps).
---
 client/platform/desktop/backend/native/viame.ts | 6 ++++++
 server/dive_tasks/tasks.py                      | 6 ++++++
 2 files changed, 12 insertions(+)

diff --git a/client/platform/desktop/backend/native/viame.ts b/client/platform/desktop/backend/native/viame.ts
index f7ff19f53..0936fe8f5 100644
--- a/client/platform/desktop/backend/native/viame.ts
+++ b/client/platform/desktop/backend/native/viame.ts
@@ -234,6 +234,12 @@ async function runPipeline(
       `-p "${pipelinePath}"`,
       `-s downsampler:target_frame_rate=${meta.fps}`,
     ];
+    if (frameRange) {
+      command.push(`-s downsampler:start_frame=${frameRange[0]}`);
+      command.push(`-s downsampler:end_frame=${frameRange[1]}`);
+      const isNative = !meta.originalFps || meta.fps >= meta.originalFps;
+      command.push(`-s downsampler:frame_range_is_native=${isNative}`);
+    }
     if (!stereoOrMultiCam) {
       command.push(`-s input:video_filename="${videoAbsPath}"`);
       command.push(`-s detector_writer:file_name="${detectorOutput}"`);
diff --git a/server/dive_tasks/tasks.py b/server/dive_tasks/tasks.py
index 28f4c1847..876ec857f 100644
--- a/server/dive_tasks/tasks.py
+++ b/server/dive_tasks/tasks.py
@@ -288,6 +288,12 @@ def run_pipeline(self: Task, params: PipelineJob):
                 f"-s detector_writer:file_name={shlex.quote(detector_output_file)}",
                 f"-s track_writer:file_name={shlex.quote(track_output_file)}",
             ]
+            if frame_range is not None:
+                command.append(f"-s downsampler:start_frame={shlex.quote(str(frame_range[0]))}")
+                command.append(f"-s downsampler:end_frame={shlex.quote(str(frame_range[1]))}")
+                original_fps = fromMeta(input_folder, constants.OriginalFPSMarker, default=None)
+                is_native = original_fps is None or input_fps >= original_fps
+                command.append(f"-s downsampler:frame_range_is_native={str(is_native).lower()}")
         elif input_type == constants.ImageSequenceType:
             # Filter image list by frame range if specified
             filtered_media_list = input_media_list

From 3f82c93f1ef930dfbc1e9dbabb645af4c80a09f3 Mon Sep 17 00:00:00 2001
From: Matt Dawkins <matt.dawkins@kitware.com>
Date: Tue, 10 Feb 2026 17:35:17 -0500
Subject: [PATCH 6/8] Set downsampler renumber_frames and adjust_timestamps
 based on pipeline type

For transcode/filter pipelines with a frame range, renumber output frames
relative to the new range (frame 0 = start frame). For all other pipelines,
keep frames relative to the original video.
---
 client/platform/desktop/backend/native/viame.ts | 5 +++++
 server/dive_tasks/tasks.py                      | 5 +++++
 2 files changed, 10 insertions(+)

diff --git a/client/platform/desktop/backend/native/viame.ts b/client/platform/desktop/backend/native/viame.ts
index 0936fe8f5..b5b7be7a1 100644
--- a/client/platform/desktop/backend/native/viame.ts
+++ b/client/platform/desktop/backend/native/viame.ts
@@ -239,6 +239,11 @@ async function runPipeline(
       command.push(`-s downsampler:end_frame=${frameRange[1]}`);
       const isNative = !meta.originalFps || meta.fps >= meta.originalFps;
       command.push(`-s downsampler:frame_range_is_native=${isNative}`);
+      // Transcode/filter pipes: output frames renumbered relative to new range
+      // All other pipes: output frames relative to original video
+      const renumber = pipeline.type === 'transcode' || pipeline.type === 'filter';
+      command.push(`-s downsampler:renumber_frames=${renumber}`);
+      command.push(`-s downsampler:adjust_timestamps=${renumber}`);
     }
     if (!stereoOrMultiCam) {
       command.push(`-s input:video_filename="${videoAbsPath}"`);
diff --git a/server/dive_tasks/tasks.py b/server/dive_tasks/tasks.py
index 876ec857f..b5ef8bc43 100644
--- a/server/dive_tasks/tasks.py
+++ b/server/dive_tasks/tasks.py
@@ -294,6 +294,11 @@ def run_pipeline(self: Task, params: PipelineJob):
                 original_fps = fromMeta(input_folder, constants.OriginalFPSMarker, default=None)
                 is_native = original_fps is None or input_fps >= original_fps
                 command.append(f"-s downsampler:frame_range_is_native={str(is_native).lower()}")
+                # Transcode/filter pipes: output frames renumbered relative to new range
+                # All other pipes: output frames relative to original video
+                renumber = pipeline["pipe"].startswith(("transcode_", "filter_"))
+                command.append(f"-s downsampler:renumber_frames={str(renumber).lower()}")
+                command.append(f"-s downsampler:adjust_timestamps={str(renumber).lower()}")
         elif input_type == constants.ImageSequenceType:
             # Filter image list by frame range if specified
             filtered_media_list = input_media_list

From 232463c5052bd24e0552aa8ca030a6d14e65bf9e Mon Sep 17 00:00:00 2001
From: Bryon Lewis <Bryon.Lewis@kitware.com>
Date: Tue, 5 May 2026 09:37:24 -0400
Subject: [PATCH 7/8] combined kwiver and runtime params

---
 client/dive-common/apispec.ts                 | 13 ++++++-
 .../components/RunPipelineMenu.vue            |  5 ++-
 .../platform/desktop/backend/native/viame.ts  |  8 ++--
 client/platform/desktop/constants.ts          |  5 +--
 client/platform/desktop/frontend/api.ts       |  7 ++--
 client/platform/web-girder/api/rpc.service.ts | 13 ++-----
 server/dive_server/crud_rpc.py                | 12 +++---
 server/dive_server/views_rpc.py               | 38 +++++--------------
 server/dive_tasks/tasks.py                    | 11 +++---
 server/dive_utils/types.py                    | 15 +++++++-
 10 files changed, 66 insertions(+), 61 deletions(-)

diff --git a/client/dive-common/apispec.ts b/client/dive-common/apispec.ts
index f2b875435..67cd04716 100644
--- a/client/dive-common/apispec.ts
+++ b/client/dive-common/apispec.ts
@@ -51,6 +51,15 @@ interface PipeMetadata {
   diveParams?: DiveParam[];
 }
 
+interface PipelineRuntimeParams {
+  frameRange?: [number, number] | null;
+}
+
+interface PipelineParams {
+  kwiverParams?: Record<string, string>;
+  runtimeParams?: PipelineRuntimeParams;
+}
+
 interface Pipe {
   name: string;
   pipe: string;
@@ -184,7 +193,7 @@ interface DatasetMeta extends DatasetMetaMutable {
 
 interface Api {
   getPipelineList(): Promise<Pipelines>;
-  runPipeline(itemId: string, pipeline: Pipe, frameRange?: [number, number] | null, additionalConfig?: Record<string, string>): Promise<unknown>;
+  runPipeline(itemId: string, pipeline: Pipe, pipelineParams?: PipelineParams): Promise<unknown>;
   deleteTrainedPipeline(pipeline: Pipe): Promise<void>;
   exportTrainedPipeline(path: string, pipeline: Pipe): Promise<unknown>;
 
@@ -258,6 +267,8 @@ export {
   MultiTrackRecord,
   MultiGroupRecord,
   Pipe,
+  PipelineParams,
+  PipelineRuntimeParams,
   PipeMetadata,
   Pipelines,
   SaveDetectionsArgs,
diff --git a/client/dive-common/components/RunPipelineMenu.vue b/client/dive-common/components/RunPipelineMenu.vue
index 1f234ae62..7dfb22588 100644
--- a/client/dive-common/components/RunPipelineMenu.vue
+++ b/client/dive-common/components/RunPipelineMenu.vue
@@ -209,7 +209,10 @@ export default defineComponent({
       await _runPipelineRequest(() => Promise.all(
         datasetIds.map((id) => {
           const additionalConfig = additionalConfigById ? additionalConfigById[id] : undefined;
-          return runPipeline(id, pipeline, frameRange, additionalConfig);
+          return runPipeline(id, pipeline, {
+            kwiverParams: additionalConfig,
+            runtimeParams: frameRange ? { frameRange } : undefined,
+          });
         }),
       ));
     }
diff --git a/client/platform/desktop/backend/native/viame.ts b/client/platform/desktop/backend/native/viame.ts
index 559cfd0d1..9c83fdbef 100644
--- a/client/platform/desktop/backend/native/viame.ts
+++ b/client/platform/desktop/backend/native/viame.ts
@@ -156,7 +156,8 @@ async function runPipeline(
   viameConstants: ViameConstants,
   forceTranscodedVideo?: boolean,
 ): Promise<DesktopJob> {
-  const { datasetId, pipeline, frameRange } = runPipelineArgs;
+  const { datasetId, pipeline } = runPipelineArgs;
+  const frameRange = runPipelineArgs.pipelineParams?.runtimeParams?.frameRange ?? undefined;
 
   const isValid = await validateViamePath(settings);
   if (isValid !== true) {
@@ -317,9 +318,10 @@ async function runPipeline(
   }
 
   // Add any custom pipeline parameters
-  if (runPipelineArgs.pipelineParams) {
+  const kwiverParams = runPipelineArgs.pipelineParams?.kwiverParams;
+  if (kwiverParams) {
     const escapeValue = (val: string) => val.replace(/["$]/g, '\\$&');
-    Object.entries(runPipelineArgs.pipelineParams).forEach(([key, value]) => {
+    Object.entries(kwiverParams).forEach(([key, value]) => {
       command.push(`-s ${key}="${escapeValue(value)}"`);
     });
   }
diff --git a/client/platform/desktop/constants.ts b/client/platform/desktop/constants.ts
index bda8ff887..3d5f00508 100644
--- a/client/platform/desktop/constants.ts
+++ b/client/platform/desktop/constants.ts
@@ -1,6 +1,6 @@
 import type {
   DatasetMeta, DatasetMetaMutable, DatasetType,
-  Pipe, SubType, MediaImportResponse,
+  Pipe, SubType, MediaImportResponse, PipelineParams,
 } from 'dive-common/apispec';
 import { Attribute } from 'vue-media-annotator/use/AttributeTypes';
 import { AttributeTrackFilter } from 'vue-media-annotator/AttributeTrackFilterControls';
@@ -175,8 +175,7 @@ export interface RunPipeline extends JobArgs {
   type: JobType.RunPipeline;
   datasetId: string;
   pipeline: Pipe;
-  pipelineParams?: Record<string, string>;
-  frameRange?: [number, number] | null;
+  pipelineParams?: PipelineParams;
   outputDatasetName?: string;
 }
 
diff --git a/client/platform/desktop/frontend/api.ts b/client/platform/desktop/frontend/api.ts
index 81790f6a9..16c144450 100644
--- a/client/platform/desktop/frontend/api.ts
+++ b/client/platform/desktop/frontend/api.ts
@@ -2,7 +2,7 @@ import axios, { AxiosInstance } from 'axios';
 
 import type {
   DatasetMetaMutable, DatasetType, MultiCamImportArgs,
-  Pipe, Pipelines, SaveAttributeArgs,
+  Pipe, Pipelines, PipelineParams, SaveAttributeArgs,
   SaveAttributeTrackFilterArgs, SaveDetectionsArgs, TrainingConfigs,
 } from 'dive-common/apispec';
 
@@ -118,13 +118,12 @@ async function getTrainingConfigurations(): Promise<TrainingConfigs> {
   return window.diveDesktop.invoke('get-training-configs');
 }
 
-async function runPipeline(itemId: string, pipeline: Pipe, frameRange?: [number, number] | null, additionalConfig?: Record<string, string>): Promise<void> {
+async function runPipeline(itemId: string, pipeline: Pipe, pipelineParams?: PipelineParams): Promise<void> {
   const args: RunPipeline = {
     type: JobType.RunPipeline,
     pipeline,
     datasetId: itemId,
-    frameRange: frameRange || undefined,
-    pipelineParams: additionalConfig,
+    pipelineParams,
   };
   gpuJobQueue.enqueue(args);
 }
diff --git a/client/platform/web-girder/api/rpc.service.ts b/client/platform/web-girder/api/rpc.service.ts
index 3b7239df6..7bc6ac109 100644
--- a/client/platform/web-girder/api/rpc.service.ts
+++ b/client/platform/web-girder/api/rpc.service.ts
@@ -1,6 +1,6 @@
 import girderRest from 'platform/web-girder/plugins/girder';
 import type { GirderModel } from '@girder/components/src';
-import { Pipe } from 'dive-common/apispec';
+import type { Pipe, PipelineParams } from 'dive-common/apispec';
 
 function postProcess(folderId: string, skipJobs = false, skipTranscoding = false, additive = false, additivePrepend = '', set: string | undefined = undefined) {
   return girderRest.post<{folder: GirderModel, warnings: string[], job_ids: string[]}>(`dive_rpc/postprocess/${folderId}`, null, {
@@ -10,18 +10,13 @@ function postProcess(folderId: string, skipJobs = false, skipTranscoding = false
   });
 }
 
-function runPipeline(itemId: string, pipeline: Pipe, frameRange?: [number, number] | null, additionalConfig?: Record<string, string>) {
+function runPipeline(itemId: string, pipeline: Pipe, pipelineParams?: PipelineParams) {
   const params: Record<string, unknown> = {
     folderId: itemId,
     pipeline,
   };
-  if (frameRange) {
-    const [startFrame, endFrame] = frameRange;
-    params.startFrame = startFrame;
-    params.endFrame = endFrame;
-  }
-  if (additionalConfig) {
-    params.pipelineParams = additionalConfig;
+  if (pipelineParams) {
+    params.pipelineParams = pipelineParams;
   }
   return girderRest.post('dive_rpc/pipeline', null, { params });
 }
diff --git a/server/dive_server/crud_rpc.py b/server/dive_server/crud_rpc.py
index 9fab8053c..30d319d22 100644
--- a/server/dive_server/crud_rpc.py
+++ b/server/dive_server/crud_rpc.py
@@ -190,8 +190,7 @@ def run_pipeline(
     folder: types.GirderModel,
     pipeline: types.PipelineDescription,
     force_transcoded=False,
-    frame_range: Optional[Tuple[int, int]] = None,
-    pipeline_params: Optional[Dict[str, str]] = None,
+    pipeline_params: Optional[types.PipelineParams] = None,
 ) -> types.GirderModel:
     """
     Run a pipeline on a dataset.
@@ -199,7 +198,7 @@ def run_pipeline(
     :param folder: The girder folder containing the dataset to run on.
     :param pipeline: The pipeline to run the dataset on.
     :param force_transcoded: Force transcoding input.
-    :param pipeline_params: Dict of key values containing user specified settings.
+    :param pipeline_params: Grouped pipeline params for runtime and KWIVER settings.
     """
     verify_pipe(user, pipeline)
     crud.getCloneRoot(user, folder)
@@ -228,6 +227,9 @@ def run_pipeline(
 
     job_is_private = user.get(constants.UserPrivateQueueEnabledMarker, False)
 
+    runtime_params = (pipeline_params or {}).get("runtimeParams")
+    kwiver_params = (pipeline_params or {}).get("kwiverParams")
+
     params: types.PipelineJob = {
         "pipeline": pipeline,
         "input_folder": folder_id_str,
@@ -237,8 +239,8 @@ def run_pipeline(
         'user_id': str(user.get('_id', 'unknown')),
         'user_login': user.get('login', 'unknown'),
         'force_transcoded': force_transcoded,
-        'frame_range': frame_range,
-        'pipeline_params': pipeline_params,
+        'runtime_params': runtime_params,
+        'kwiver_params': kwiver_params,
     }
     newjob = tasks.run_pipeline.apply_async(
         queue=_get_queue_name(user, "pipelines"),
diff --git a/server/dive_server/views_rpc.py b/server/dive_server/views_rpc.py
index 9a106a62e..b0e1968fc 100644
--- a/server/dive_server/views_rpc.py
+++ b/server/dive_server/views_rpc.py
@@ -10,7 +10,7 @@
 
 from dive_utils import asbool, fromMeta
 from dive_utils.constants import DatasetMarker, FPSMarker, MarkForPostProcess, TypeMarker
-from dive_utils.types import PipelineDescription, TrainingModelTuneArgs
+from dive_utils.types import PipelineDescription, PipelineParams, TrainingModelTuneArgs
 
 from . import crud, crud_rpc, worker_capabilities
 
@@ -49,42 +49,24 @@ def __init__(self, resourceName):
             default=False,
             required=False,
         )
-        .param(
-            "startFrame",
-            "Start frame (inclusive) for frame range filtering",
-            paramType="query",
-            dataType="integer",
-            required=False,
-        )
-        .param(
-            "endFrame",
-            "End frame (inclusive) for frame range filtering",
-            paramType="query",
-            dataType="integer",
-            required=False,
-        )
         .jsonParam("pipeline", "The pipeline to run on the dataset", required=True)
         .jsonParam(
             "pipelineParams",
-            "Optional KWIVER -s parameter overrides from pipeline specified parameters",
+            "Optional pipeline parameter groups (kwiverParams and runtimeParams)",
             required=False,
             default=None,
         )
     )
-<<<<<<< HEAD
-    def run_pipeline_task(self, folder, forceTranscoded, startFrame, endFrame, pipeline: PipelineDescription, pipelineParams):
-        frame_range = None
-        if startFrame is not None and endFrame is not None:
-            frame_range = (startFrame, endFrame)
-        return crud_rpc.run_pipeline(
-            self.getCurrentUser(), folder, pipeline, forceTranscoded, frame_range, pipelineParams
-        )
-=======
-    def run_pipeline_task(self, folder, forceTranscoded, pipeline: PipelineDescription, pipelineParams: dict[str, str]):
+    def run_pipeline_task(
+        self,
+        folder,
+        forceTranscoded,
+        pipeline: PipelineDescription,
+        pipelineParams: Optional[PipelineParams],
+    ):
         worker_capabilities.require_pipeline_worker()
         return crud_rpc.run_pipeline(self.getCurrentUser(), folder, pipeline, forceTranscoded, pipelineParams)
->>>>>>> main
-    
+
     @access.user
     @autoDescribeRoute(
         Description("Export pipeline to ONNX")
diff --git a/server/dive_tasks/tasks.py b/server/dive_tasks/tasks.py
index a3b40bf95..32182a2ba 100644
--- a/server/dive_tasks/tasks.py
+++ b/server/dive_tasks/tasks.py
@@ -245,7 +245,8 @@ def run_pipeline(self: Task, params: PipelineJob):
     output_folder_id = str(params["output_folder"])
     input_revision = params["input_revision"]
     force_transcoded = params.get('force_transcoded', False)
-    frame_range = params.get('frame_range', None)
+    runtime_params = params.get('runtime_params') or {}
+    frame_range = runtime_params.get('frameRange')
     with tempfile.TemporaryDirectory() as _working_directory, suppress(utils.CanceledError):
         _working_directory_path = Path(_working_directory)
         input_path = utils.make_directory(_working_directory_path / 'input')
@@ -326,10 +327,10 @@ def run_pipeline(self: Task, params: PipelineJob):
             command.append(f'-s detection_reader:file_name={quoted_input_file}')
             command.append(f'-s track_reader:file_name={quoted_input_file}')
 
-        # Apply user-provided pipeline parameter overrides from pipeline params
-        pipeline_params = params.get('pipeline_params')
-        if pipeline_params:
-            for key, value in pipeline_params.items():
+        # Apply user-provided KWIVER parameter overrides.
+        kwiver_params = params.get('kwiver_params')
+        if kwiver_params:
+            for key, value in kwiver_params.items():
                 command.append(f'-s {shlex.quote(key)}={shlex.quote(str(value))}')
 
         manager.updateStatus(JobStatus.RUNNING)
diff --git a/server/dive_utils/types.py b/server/dive_utils/types.py
index 403655de2..b083cc186 100644
--- a/server/dive_utils/types.py
+++ b/server/dive_utils/types.py
@@ -7,6 +7,8 @@
     "DiveParam",
     "GirderModel",
     "PipelineDescription",
+    "PipelineParams",
+    "PipelineRuntimeParams",
     "PipelineJob",
     "PipelineCategory",
     "PipeMetadata",
@@ -87,6 +89,15 @@ class PipelineDescription(TypedDict):
     folderId: Optional[str]
 
 
+class PipelineRuntimeParams(TypedDict, total=False):
+    frameRange: Optional[Tuple[int, int]]
+
+
+class PipelineParams(TypedDict, total=False):
+    kwiverParams: Dict[str, str]
+    runtimeParams: PipelineRuntimeParams
+
+
 class PipelineJob(TypedDict):
     """Describes the parameters for running a pipeline on a dataset."""
 
@@ -98,8 +109,8 @@ class PipelineJob(TypedDict):
     user_id: str  # user id who started the job
     user_login: str  # login of user who started the kjob
     force_transcoded: Optional[bool]
-    frame_range: Optional[Tuple[int, int]]
-    pipeline_params: Optional[Dict[str, str]]
+    runtime_params: Optional[PipelineRuntimeParams]
+    kwiver_params: Optional[Dict[str, str]]
 
 
 class TrainingJob(TypedDict):

From fdad8c35176188aa476faf5e60abacc3ecf3c245 Mon Sep 17 00:00:00 2001
From: Bryon Lewis <Bryon.Lewis@kitware.com>
Date: Tue, 5 May 2026 09:42:38 -0400
Subject: [PATCH 8/8] prevent ranges from passing each other

---
 client/src/components/controls/Controls.vue | 14 ++++++++------
 1 file changed, 8 insertions(+), 6 deletions(-)

diff --git a/client/src/components/controls/Controls.vue b/client/src/components/controls/Controls.vue
index 55731ac07..81e5cdf12 100644
--- a/client/src/components/controls/Controls.vue
+++ b/client/src/components/controls/Controls.vue
@@ -117,7 +117,8 @@ export default defineComponent({
     function updateTimeFilterMin(value: number) {
       const current = trackFilters.timeFilters.value;
       if (current) {
-        trackFilters.setTimeFilters([value, current[1]]);
+        const newMin = Math.max(0, Math.min(value, current[1]));
+        trackFilters.setTimeFilters([newMin, current[1]]);
         saveTimeFilter();
       }
     }
@@ -125,7 +126,8 @@ export default defineComponent({
     function updateTimeFilterMax(value: number) {
       const current = trackFilters.timeFilters.value;
       if (current) {
-        trackFilters.setTimeFilters([current[0], value]);
+        const newMax = Math.min(mediaController.maxFrame.value, Math.max(value, current[0]));
+        trackFilters.setTimeFilters([current[0], newMax]);
         saveTimeFilter();
       }
     }
@@ -285,7 +287,7 @@ export default defineComponent({
                 hide-details
                 outlined
                 :min="0"
-                :max="mediaController.maxFrame.value"
+                :max="timeFilterMax"
                 @blur="applyMinFrame"
                 @keydown.enter="applyMinFrame"
               />
@@ -294,7 +296,7 @@ export default defineComponent({
               <v-slider
                 :value="timeFilterMin"
                 :min="0"
-                :max="mediaController.maxFrame.value"
+                :max="timeFilterMax"
                 step="1"
                 dense
                 hide-details
@@ -328,7 +330,7 @@ export default defineComponent({
                 dense
                 hide-details
                 outlined
-                :min="0"
+                :min="timeFilterMin"
                 :max="mediaController.maxFrame.value"
                 @blur="applyMaxFrame"
                 @keydown.enter="applyMaxFrame"
@@ -337,7 +339,7 @@ export default defineComponent({
             <v-col>
               <v-slider
                 :value="timeFilterMax"
-                :min="0"
+                :min="timeFilterMin"
                 :max="mediaController.maxFrame.value"
                 step="1"
                 dense