Fix for scheduler

wavefront/client/src/api/index.ts

@@ -13,6 +13,7 @@ import { LLMInferenceService } from './llm-inference-service';
 import { MessageProcessorService } from './message-processor-service';
 import { ModelInferenceService } from './model-inference-service';
 import { NamespaceService } from './namespace-service';
+import { ScheduledJobService } from './scheduled-job-service';
 import { SttConfigService } from './stt-config-service';
 import { TelephonyConfigService } from './telephony-config-service';
 import { ToolService } from './tool-service';
@@ -80,6 +81,10 @@ class FloConsoleService {
     return new NamespaceService(this.http);
   }
 
+  get scheduledJobService() {
+    return new ScheduledJobService(this.http);
+  }
+
   get sttConfigService() {
     return new SttConfigService(this.http);
   }

wavefront/client/src/api/scheduled-job-service.ts

@@ -0,0 +1,43 @@
+import {
+  CreateScheduledJobRequest,
+  CreateScheduledJobResponse,
+  DeleteScheduledJobResponse,
+  ListScheduledJobsResponse,
+  UpdateScheduledJobResponse,
+} from '@app/types/scheduled-job';
+import { AxiosInstance } from 'axios';
+
+export class ScheduledJobService {
+  constructor(private http: AxiosInstance) {}
+
+  async createScheduledJob(request: CreateScheduledJobRequest): Promise<CreateScheduledJobResponse> {
+    return this.http.post(`/v1/:appId/floware/v1/scheduled-jobs`, request);
+  }
+
+  async listScheduledJobs(params: {
+    limit?: number;
+    query_id?: string;
+    datasource_id?: string;
+    job_type?: string;
+    job_status?: string;
+  }): Promise<ListScheduledJobsResponse> {
+    return this.http.get(`/v1/:appId/floware/v1/scheduled-jobs`, { params });
+  }
+
+  async updateScheduledJob(
+    jobId: string,
+    payload: {
+      cron_expr?: string;
+      timezone?: string;
+      payload?: Record<string, unknown>;
+      max_retries?: number;
+      status?: 'active' | 'paused' | 'running' | 'failed' | 'completed';
+    }
+  ): Promise<UpdateScheduledJobResponse> {
+    return this.http.patch(`/v1/:appId/floware/v1/scheduled-jobs/${jobId}`, payload);
+  }
+
+  async deleteScheduledJob(jobId: string): Promise<DeleteScheduledJobResponse> {
+    return this.http.delete(`/v1/:appId/floware/v1/scheduled-jobs/${jobId}`);
+  }
+}