feat(jobs): add Source sorting and surface all sources in Jobs filter

docs/cli/reference.mdx

@@ -3772,7 +3772,7 @@ nemo jobs list [OPTIONS]
 * `--workspace`
 * `--page <INTEGER>`: Page number.
 * `--page-size <INTEGER>`: Page size.
-* `--sort <CHOICE>`: The field to sort by. To sort in decreasing order, use `-` in front of the field name. [possible values: created_at, -created_at, updated_at, -updated_at]
+* `--sort <CHOICE>`: The field to sort by. To sort in decreasing order, use `-` in front of the field name. [possible values: created_at, -created_at, updated_at, -updated_at, source, -source]
 * `--all-pages`: Fetch all pages
 
 **Filter Options:**

packages/nemo_platform_plugin/src/nemo_platform_plugin/jobs/types.py

@@ -87,6 +87,25 @@ def get_sort_direction(self) -> str:
         return "desc" if self.value.startswith("-") else "asc"
 
 
+class PlatformJobListSortField(str, Enum):
+    """Sort fields for the job *list* endpoint."""
+
+    # Superset of PlatformJobSortField with `source`; only the job list can sort
+    # by source (steps/results/logs have no source field).
+    CREATED_AT_ASC = "created_at"
+    CREATED_AT_DESC = "-created_at"
+    UPDATED_AT_ASC = "updated_at"
+    UPDATED_AT_DESC = "-updated_at"
+    SOURCE_ASC = "source"
+    SOURCE_DESC = "-source"
+
+    def get_field_name(self) -> str:
+        return self.value.lstrip("-")
+
+    def get_sort_direction(self) -> str:
+        return "desc" if self.value.startswith("-") else "asc"
+
+
 class PlatformJobAttemptSortField(str, Enum):
     SEQ_ASC = "seq"
     SEQ_DESC = "-seq"

sdk/stainless.yaml

@@ -550,6 +550,7 @@ resources:
       kubernetes_volume: KubernetesVolume
       kubernetes_volume_mount: KubernetesVolumeMount
       platform_job_environment_variable: PlatformJobEnvironmentVariable
+      platform_job_list_sort_field: PlatformJobListSortField
       platform_job_response: PlatformJobResponse
       platform_job_responses_page: PlatformJobResponsesPage
       platform_job_secret_environment_variable_ref: PlatformJobSecretEnvironmentVariableRef
@@ -915,11 +916,11 @@ resources:
   evaluations:
     standalone_api: true
     models:
-      evaluator_aggregate: EvaluatorAggregate
       evaluation_filter: EvaluationFilter
       evaluation_request: EvaluationRequest
       evaluation_response: EvaluationResponse
       evaluation_responses_page: EvaluationResponsesPage
+      evaluator_aggregate: EvaluatorAggregate
       metric_stat_filters: MetricStatFilters
       number_filter: NumberFilter
     methods:

services/core/jobs/src/nmp/core/jobs/api/v2/jobs/endpoints.py

@@ -33,6 +33,7 @@
 from nmp.core.jobs.api.dependencies import dep_dispatcher
 from nmp.core.jobs.api.v2.jobs.schemas import (
     CreatePlatformJobRequest,
+    PlatformJobListSortField,
     PlatformJobListTaskResponse,
     PlatformJobResponse,
     PlatformJobsListFilter,
@@ -182,8 +183,8 @@ async def list_jobs(
     workspace: str,
     page: int = Query(default=1, description="Page number.", gt=0),
     page_size: int = Query(default=10, description="Page size.", gt=0),
-    sort: PlatformJobSortField = Query(
-        default=PlatformJobSortField.CREATED_AT_DESC,
+    sort: PlatformJobListSortField = Query(
+        default=PlatformJobListSortField.CREATED_AT_DESC,
         description="The field to sort by. To sort in decreasing order, use `-` in front of the field name.",
     ),
     parsed: ParsedFilter = Depends(make_filter_dep(PlatformJobsListFilter)),

services/core/jobs/src/nmp/core/jobs/api/v2/jobs/schemas.py

@@ -36,6 +36,7 @@
 CreatePlatformJobRequest = _types.CreatePlatformJobRequest
 PlatformJobAttemptSortField = _types.PlatformJobAttemptSortField
 PlatformJobLogSortField = _types.PlatformJobLogSortField
+PlatformJobListSortField = _types.PlatformJobListSortField
 PlatformJobResponse = _types.PlatformJobResponse
 PlatformJobSortField = _types.PlatformJobSortField
 PlatformJobStatusDetailsUpdateRequest = _types.PlatformJobStatusDetailsUpdateRequest

services/core/jobs/src/nmp/core/jobs/app/dispatcher.py

@@ -28,6 +28,7 @@
 from nmp.common.sdk_factory import get_entity_parts
 from nmp.core.jobs.api.v2.jobs.schemas import (
     CreatePlatformJobRequest,
+    PlatformJobListSortField,
     PlatformJobResponse,
     PlatformJobSortField,
     PlatformJobStepsListFilter,
@@ -339,7 +340,7 @@ async def list_jobs(
         workspace: str,
         limit: Optional[int] = None,
         offset: Optional[int] = None,
-        sort: Optional[PlatformJobSortField] = None,
+        sort: Optional[PlatformJobListSortField] = None,
     ) -> Tuple[List[PlatformJobResponse], int]:
         """List platform jobs with their current attempts."""
         # Status lives on PlatformJobAttempt, not PlatformJob, so the full filter