feat(agents)!: delete ScheduleClient/SchedulerFetcher — schedules ride SchedulerClient

BREAKING CHANGE (agent layer, no backward compatibility): the raw-fetch
ScheduleClient class and SchedulerFetcher interface are gone from the
./agents surface. SchedulerClient — which absorbed the same typed
lifecycle methods (save/get/listForAgent/pause/resume/delete/runNow/
previewNext/reconcile) in the previous commit — is re-exported from
./agents in their place; every method call site keeps its name and
signature. The scheduling e2e suite needed exactly two lines (import +
one type annotation); the schedules.* module facade, runtime
schedulesClient(), deploy({schedules}) reconciliation and
AgentClient.schedule() are unchanged.

AgentClient.schedules now hands its memoized Conductor-client promise to
SchedulerClient (single transport; the SchedulerFetcher raw-fetch path is
deleted, _rawRequestUntyped remains for /agent/* control-plane calls).
An absence test pins the deletion, mirroring the Python SDK's
test_agent_schedule_client_is_gone.

Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>

Author: Kowser

e2e/test_suite21_scheduling.test.ts

@@ -11,7 +11,7 @@ import { describe, it, expect, beforeAll, beforeEach, afterAll } from '@jest/glo
 import {
   AgentRuntime,
   Schedule,
-  ScheduleClient,
+  SchedulerClient,
   ScheduleNameConflict,
   ScheduleNotFound,
 } from '@io-orkes/conductor-javascript/agents';
@@ -40,7 +40,7 @@ describe('Suite 21: scheduling', () => {
   });
   const agentName = `e2e_ts_sched_noop_${Math.random().toString(36).slice(2, 10)}`;
   let runtime: AgentRuntime;
-  let client: ScheduleClient;
+  let client: SchedulerClient;
 
   beforeAll(async () => {
     runtime = new AgentRuntime();

src/agents/__tests__/schedule-client-absence.test.ts

@@ -0,0 +1,27 @@
+/**
+ * The agent-layer `ScheduleClient` (raw-fetch transport) and its
+ * `SchedulerFetcher` interface were deleted in favor of the SDK's
+ * `SchedulerClient` (no backward compatibility). This pins the absence so
+ * they don't silently reappear — the Python SDK enforces the same deletion
+ * (`test_agent_schedule_client_is_gone`).
+ */
+import { describe, expect, it } from "@jest/globals";
+import * as agents from "../index.js";
+import { OrkesClients } from "../../sdk/OrkesClients";
+
+describe("ScheduleClient deletion (no backward compatibility)", () => {
+  it("the agents barrel no longer exports ScheduleClient", () => {
+    expect((agents as Record<string, unknown>).ScheduleClient).toBeUndefined();
+  });
+
+  it("the agents barrel re-exports SchedulerClient in its place", () => {
+    expect(agents.SchedulerClient).toBeDefined();
+  });
+
+  it("OrkesClients grew no getAgentScheduleClient getter", () => {
+    expect(
+      (OrkesClients.prototype as unknown as Record<string, unknown>)
+        .getAgentScheduleClient,
+    ).toBeUndefined();
+  });
+});

src/agents/__tests__/schedules-api.test.ts

@@ -4,7 +4,7 @@
 import { describe, it, expect, jest } from "@jest/globals";
 import * as schedules from "../schedules-api.js";
 import type { AgentRuntime } from "../runtime.js";
-import type { ScheduleInfo } from "../schedule.js";
+import type { ScheduleInfo } from "../../sdk/clients/agent/schedule.js";
 import type { AgentResult } from "../types.js";
 
 const INFO: ScheduleInfo = {

src/agents/agent-client.ts

@@ -31,8 +31,8 @@ import { detectFramework } from "./frameworks/detect.js";
 import { serializeFrameworkAgent } from "./frameworks/serializer.js";
 import { serializeLangGraph } from "./frameworks/langgraph-serializer.js";
 import { serializeLangChain } from "./frameworks/langchain-serializer.js";
-import { Schedule, ScheduleClient } from "./schedule.js";
-import type { SchedulerFetcher } from "./schedule.js";
+import { Schedule } from "../sdk/clients/agent/schedule.js";
+import { SchedulerClient } from "../sdk/clients/scheduler/SchedulerClient.js";
 import { WorkflowClient } from "./workflow-client.js";
 import { makeAgentResult, TERMINAL_STATUSES } from "./result.js";
 import { AgentStream } from "./stream.js";
@@ -82,7 +82,7 @@ export class AgentClient {
 
   private _clientPromise?: Promise<ConductorClient>;
   private _workflowClient?: WorkflowClient;
-  private _scheduleClient?: ScheduleClient;
+  private _scheduleClient?: SchedulerClient;
   private readonly serializer: AgentConfigSerializer;
 
   // Cached minted JWT (auth-key/secret path).
@@ -127,13 +127,10 @@ export class AgentClient {
     return this._workflowClient;
   }
 
-  /** Cron schedule lifecycle client (shares this client's HTTP plumbing). */
-  get schedules(): ScheduleClient {
+  /** Cron schedule lifecycle client (shares this client's Conductor client). */
+  get schedules(): SchedulerClient {
     if (!this._scheduleClient) {
-      const fetcher: SchedulerFetcher = {
-        request: (method, path, body) => this._rawRequestUntyped(method, path, body),
-      };
-      this._scheduleClient = new ScheduleClient(fetcher);
+      this._scheduleClient = new SchedulerClient(this.getClient());
     }
     return this._scheduleClient;
   }
@@ -249,7 +246,7 @@ export class AgentClient {
     }
   }
 
-  /** Untyped request (scheduler endpoints sometimes return arrays). */
+  /** Untyped request against the agent control-plane (used by the runtime). */
   async _rawRequestUntyped(method: string, path: string, body?: unknown): Promise<unknown> {
     const url = `${this.config.serverUrl}${path}`;
     const headers: Record<string, string> = {
@@ -397,7 +394,7 @@ export class AgentClient {
    * Deploy *agent* and reconcile its cron *schedules* declaratively.
    *
    * Upserts the listed schedules and prunes the others; `[]` purges all;
-   * `null`/`undefined` leaves them untouched. Reuses the {@link ScheduleClient}.
+   * `null`/`undefined` leaves them untouched. Reuses the {@link SchedulerClient}.
    */
   async schedule(
     agent: Agent | object,

src/agents/index.ts

@@ -154,13 +154,13 @@ export { WorkflowClient } from "./workflow-client.js";
 // ── Scheduling ──────────────────────────────────────────
 export {
   Schedule,
-  ScheduleClient,
   ScheduleError,
   ScheduleNameConflict,
   ScheduleNotFound,
   InvalidCronExpression,
-} from "./schedule.js";
-export type { ScheduleOptions, ScheduleInfo, SchedulerFetcher } from "./schedule.js";
+} from "../sdk/clients/agent/schedule.js";
+export type { ScheduleOptions, ScheduleInfo } from "../sdk/clients/agent/schedule.js";
+export { SchedulerClient } from "../sdk/clients/scheduler/SchedulerClient.js";
 import * as schedules from "./schedules-api.js";
 export { schedules };
 

src/agents/runtime.ts

@@ -22,7 +22,8 @@ import { TERMINAL_STATUSES } from "./result.js";
 import type { TerminationCondition } from "./termination.js";
 import type { HandoffContext } from "./handoff.js";
 import { detectFramework } from "./frameworks/detect.js";
-import { Schedule, ScheduleClient } from "./schedule.js";
+import type { Schedule } from "../sdk/clients/agent/schedule.js";
+import type { SchedulerClient } from "../sdk/clients/scheduler/SchedulerClient.js";
 import { AgentClient } from "./agent-client.js";
 import { WorkflowClient } from "./workflow-client.js";
 import { serializeFrameworkAgent } from "./frameworks/serializer.js";
@@ -425,8 +426,8 @@ export class AgentRuntime {
     return info;
   }
 
-  /** `ScheduleClient` — shares the control-plane client's schedule surface. */
-  schedulesClient(): ScheduleClient {
+  /** `SchedulerClient` — shares the control-plane client's Conductor client. */
+  schedulesClient(): SchedulerClient {
     return this.client.schedules;
   }
 

src/agents/schedule.ts

@@ -14,7 +14,7 @@
  */
 
 import { getRuntime, AgentRuntime } from "./runtime.js";
-import type { Schedule as ScheduleClass, ScheduleInfo } from "./schedule.js";
+import type { Schedule as ScheduleClass, ScheduleInfo } from "../sdk/clients/agent/schedule.js";
 import type { AgentResult, Status } from "./types.js";
 import { makeAgentResult, TERMINAL_STATUSES } from "./result.js";