ports.tasks

readonly tasks: AgentHarnessTaskPort

​

On the Agent Runtime

// runtime-adapter.ts
const tasks = Object.freeze({
  delivery: "at-least-once",
  queue: async (method, payload, scheduleOptions) => host.queue(method, payload, scheduleOptions),
  schedule: async (delaySeconds, method, payload, scheduleOptions) => host.schedule(delaySeconds, method, payload, scheduleOptions),
  every: async (intervalSeconds, method, payload, scheduleOptions) => host.every(intervalSeconds, method, payload, scheduleOptions),
  cancel: (id) => host.cancelSchedule(id),
  list: () => host.listSchedules(),
});

• queue() calls queue(), for a task due at once.
• schedule() calls schedule(), for a task due after a delay.
• every() calls every(), for a task that recurs at an interval.
• cancel() calls cancelSchedule(), which removes a pending task.
• list() calls listSchedules(), which returns a TaskRecord for every pending task.
• With a stable id in its ScheduleOptions, a call to queue(), schedule() or every() replaces the pending task with that id.
• delivery declares the scheduler’s own guarantee. A task survives crashes and restarts. It can be delivered more than once.
• The harness’s task names begin with __telnyx_agent_harness_ and name no method of the class, so they reach onTask(). Its default does nothing and counts the task as delivered.

​

AgentHarnessTaskPort

readonly delivery: "at-least-once"

cancel(id): Promise<boolean>

every(intervalSeconds, method, payload?, options?): Promise<string>

list(): Promise<TaskRecord[]>

queue(method, payload?, options?): Promise<string>

schedule(delaySeconds, method, payload?, options?): Promise<string>