updated python client

Author: pranjal-astuto

onelens_backend_client_v2/models.py

@@ -1,6 +1,6 @@
 # generated by datamodel-codegen:
 #   filename:  <stdin>
-#   timestamp: 2025-12-18T13:55:15+00:00
+#   timestamp: 2025-12-23T12:41:57+00:00
 
 from __future__ import annotations
 
@@ -1601,6 +1601,22 @@ class DeleteTenantDataPipelineJobConfigsByTenantIdsResponse(BaseModel):
     rows_deleted: int = Field(..., title="Rows Deleted")
 
 
+class DeleteTenantDataPipelineJobRunConfigByJobNamesRequest(BaseModel):
+    job_names: List[str] = Field(..., title="Job Names")
+
+
+class DeleteTenantDataPipelineJobRunConfigByJobNamesResponse(BaseModel):
+    rows_deleted: int = Field(..., title="Rows Deleted")
+
+
+class DeleteTenantDataPipelineJobRunConfigByTenantIdsRequest(BaseModel):
+    tenant_ids: List[UUID] = Field(..., title="Tenant Ids")
+
+
+class DeleteTenantDataPipelineJobRunConfigByTenantIdsResponse(BaseModel):
+    rows_deleted: int = Field(..., title="Rows Deleted")
+
+
 class DeleteTenantEmbedAppsLinksResponse(BaseModel):
     pass
 
@@ -2964,6 +2980,11 @@ class GetTenantConnectionResponse(BaseModel):
     status: ConnectionStatus = Field(..., description="Status of the connection")
 
 
+class GetTenantDataPipelineJobRunConfigRequest(BaseModel):
+    tenant_ids: List[UUID] = Field(..., title="Tenant Ids")
+    job_names: Optional[List[str]] = Field([], title="Job Names")
+
+
 class GetTenantEmbedAppsLinksRequest(BaseModel):
     tenant_id: UUID4 = Field(
         ..., description="The unique identifier of the tenant", title="Tenant Id"
@@ -4747,6 +4768,12 @@ class RenameTenantDataPipelineJobConfigsRequest(BaseModel):
     new_job_name: str = Field(..., title="New Job Name")
 
 
+class RenameTenantDataPipelineJobRunConfigRequest(BaseModel):
+    tenant_ids: List[UUID] = Field(..., title="Tenant Ids")
+    old_job_name: str = Field(..., title="Old Job Name")
+    new_job_name: str = Field(..., title="New Job Name")
+
+
 class RenewalCommitmentsDataItem(BaseModel):
     commitment_type: str = Field(..., title="Commitment Type")
     arn: str = Field(..., title="Arn")
@@ -5131,6 +5158,18 @@ class ResponseDeleteTenantDataPipelineJobConfigsByTenantIdsResponse(BaseModel):
     status_code: Optional[int] = Field(200, title="Status Code")
 
 
+class ResponseDeleteTenantDataPipelineJobRunConfigByJobNamesResponse(BaseModel):
+    data: DeleteTenantDataPipelineJobRunConfigByJobNamesResponse
+    message: Optional[str] = Field(None, title="Message")
+    status_code: Optional[int] = Field(200, title="Status Code")
+
+
+class ResponseDeleteTenantDataPipelineJobRunConfigByTenantIdsResponse(BaseModel):
+    data: DeleteTenantDataPipelineJobRunConfigByTenantIdsResponse
+    message: Optional[str] = Field(None, title="Message")
+    status_code: Optional[int] = Field(200, title="Status Code")
+
+
 class ResponseDeleteTenantEmbedAppsLinksResponse(BaseModel):
     data: DeleteTenantEmbedAppsLinksResponse
     message: Optional[str] = Field(None, title="Message")
@@ -5804,6 +5843,19 @@ class TenantAnomalyTicketDetailsMixin(BaseModel):
     )
 
 
+class TenantDataPipelineJobRunConfig(BaseModel):
+    tenant_id: UUID = Field(..., title="Tenant Id")
+    job_name: str = Field(..., title="Job Name")
+    run_config: Dict[str, Any] = Field(..., title="Run Config")
+    id: UUID = Field(..., title="Id")
+
+
+class TenantDataPipelineJobRunConfigMixin(BaseModel):
+    tenant_id: UUID = Field(..., title="Tenant Id")
+    job_name: str = Field(..., title="Job Name")
+    run_config: Dict[str, Any] = Field(..., title="Run Config")
+
+
 class TenantDetailResponse(BaseModel):
     tenant_id: UUID = Field(
         ..., description="Unique identifier of the tenant", title="Tenant Id"
@@ -7070,6 +7122,14 @@ class UpsertSchedulerConfigRequest(BaseModel):
     attr2: Optional[str] = Field(None, title="Attr2")
 
 
+class UpsertTenantDataPipelineJobRunConfigBulkRequest(BaseModel):
+    configs: List[TenantDataPipelineJobRunConfigMixin] = Field(..., title="Configs")
+
+
+class UpsertTenantDataPipelineJobRunConfigBulkResponse(BaseModel):
+    configs: List[TenantDataPipelineJobRunConfig] = Field(..., title="Configs")
+
+
 class UpsertTenantSettingsAPIRequest(BaseModel):
     settings_key: str = Field(
         ..., description="Unique key for the tenant setting", title="Settings Key"
@@ -10734,6 +10794,10 @@ class GetTenantDataPipelineJobConfigsRequest(BaseModel):
     cloud_providers: Optional[List[Provider]] = Field([], title="Cloud Providers")
 
 
+class GetTenantDataPipelineJobRunConfigResponse(BaseModel):
+    configs: List[TenantDataPipelineJobRunConfig] = Field(..., title="Configs")
+
+
 class GetTenantEmbedAppsLinkResponse(BaseModel):
     created_by: UUID4 = Field(
         ...,
@@ -11855,6 +11919,10 @@ class RecommendationEngineRequest(BaseModel):
     tenant_id: UUID4 = Field(..., description="Tenant ID", title="Tenant Id")
 
 
+class RenameTenantDataPipelineJobRunConfigResponse(BaseModel):
+    configs: List[TenantDataPipelineJobRunConfig] = Field(..., title="Configs")
+
+
 class ResourceCatalogCostDataMixin(BaseModel):
     id: UUID = Field(
         ..., description="The id of the resource catalog cost data.", title="Id"
@@ -12283,6 +12351,12 @@ class ResponseGetTenantByIDResponse(BaseModel):
     status_code: Optional[int] = Field(200, title="Status Code")
 
 
+class ResponseGetTenantDataPipelineJobRunConfigResponse(BaseModel):
+    data: GetTenantDataPipelineJobRunConfigResponse
+    message: Optional[str] = Field(None, title="Message")
+    status_code: Optional[int] = Field(200, title="Status Code")
+
+
 class ResponseGetTenantEmbedAppsLinkResponse(BaseModel):
     data: GetTenantEmbedAppsLinkResponse
     message: Optional[str] = Field(None, title="Message")
@@ -12409,6 +12483,12 @@ class ResponseRateOptimizationUtilizationDataResponse(BaseModel):
     status_code: Optional[int] = Field(200, title="Status Code")
 
 
+class ResponseRenameTenantDataPipelineJobRunConfigResponse(BaseModel):
+    data: RenameTenantDataPipelineJobRunConfigResponse
+    message: Optional[str] = Field(None, title="Message")
+    status_code: Optional[int] = Field(200, title="Status Code")
+
+
 class ResponseResourceCatalogFetchV2ByIDResponse(BaseModel):
     data: ResourceCatalogFetchV2ByIDResponse
     message: Optional[str] = Field(None, title="Message")
@@ -12493,6 +12573,12 @@ class ResponseUpsertResourceCatalogCostDataResponse(BaseModel):
     status_code: Optional[int] = Field(200, title="Status Code")
 
 
+class ResponseUpsertTenantDataPipelineJobRunConfigBulkResponse(BaseModel):
+    data: UpsertTenantDataPipelineJobRunConfigBulkResponse
+    message: Optional[str] = Field(None, title="Message")
+    status_code: Optional[int] = Field(200, title="Status Code")
+
+
 class ResponseValidateHierarchyNodeFieldsResponse(BaseModel):
     data: ValidateHierarchyNodeFieldsResponse
     message: Optional[str] = Field(None, title="Message")
@@ -12558,6 +12644,22 @@ class S3RequestTimeFilter(BaseModel):
     )
 
 
+class ScopeFilter(BaseModel):
+    key: str = Field(
+        ...,
+        description="Scope key: 'account', 'provider', 'region', or 'service'",
+        title="Key",
+    )
+    operator: OnelensModelsServiceInterfacesTenantDataMetricsServiceOperator = Field(
+        ..., description="Operator: IN, NOT_IN"
+    )
+    values: List[str] = Field(
+        ...,
+        description="List of values to filter by (OR logic within filter)",
+        title="Values",
+    )
+
+
 class SearchTenantPoliciesAPIRequest(BaseModel):
     pagination: Optional[PaginationParams] = Field(
         {"page": 1, "page_size": 10},
@@ -15538,6 +15640,11 @@ class GetDeltaEventsFilters(BaseModel):
     node_ids: Optional[List[UUID]] = Field(
         None, description="List of node IDs to filter events", title="Node Ids"
     )
+    scope: Optional[List[ScopeFilter]] = Field(
+        None,
+        description="List of scope filters for account, provider, region, or service",
+        title="Scope",
+    )
 
 
 class GetDeltaEventsForWorkflowAPIRequest(BaseModel):
@@ -19180,17 +19287,17 @@ class CreateCustomTenantTicketRequestMixin(BaseModel):
         title="Post Policy Execution Last Run",
     )
     last_run_id: Optional[UUID4] = Field(
-        "fff463ac-4311-4c8a-9226-6bfa9e64ce04",
+        "91e0306c-a52b-4784-ab6f-10f25ff8abef",
         description="Id of the last policy violation/anomaly run",
         title="Last Run Id",
     )
     last_run_at: Optional[datetime] = Field(
-        "2025-12-18T19:24:27.126300",
+        "2025-12-23T18:11:21.588974",
         description="Datetime of the last policy violation/anomaly run",
         title="Last Run At",
     )
     first_run_at: Optional[datetime] = Field(
-        "2025-12-18T19:24:27.126314",
+        "2025-12-23T18:11:21.588988",
         description="Datetime of the first policy violation/anomaly run",
         title="First Run At",
     )

onelens_backend_client_v2/rpc/__init__.py

@@ -170,6 +170,10 @@
     TenantDataPipelineJobConfigServiceRpcHandler,
 )
 
+from onelens_backend_client_v2.rpc.tenant_data_pipeline_job_run_config_service_rpc_handler import (
+    TenantDataPipelineJobRunConfigServiceRpcHandler,
+)
+
 from onelens_backend_client_v2.rpc.kubernetes_management_service_rpc_handler import (
     KubernetesManagementServiceRpcHandler,
 )
@@ -245,6 +249,7 @@
     "TenantAccountServiceRpcHandler",
     "TenantSettingsServiceRpcHandler",
     "TenantDataPipelineJobConfigServiceRpcHandler",
+    "TenantDataPipelineJobRunConfigServiceRpcHandler",
     "KubernetesManagementServiceRpcHandler",
     "KubernetesDataServiceRpcHandler",
     "KubernetesResourceServiceRpcHandler",