Class TasksAbstract

Example

class SyncTool extends Tool {
  async startBatchSync(totalItems: number) {
    // Store initial state using built-in set method
    await this.set("sync_progress", { processed: 0, total: totalItems });

    // Create callback and queue first batch using built-in methods
    const callback = await this.callback("processBatch", { batchNumber: 1 });
    await this.runTask(callback);
  }

  async processBatch(args: any, context: { batchNumber: number }) {
    // Process one batch of items
    const progress = await this.get("sync_progress");

    // ... process items ...

    if (progress.processed < progress.total) {
      // Queue next batch using built-in methods
      const callback = await this.callback("processBatch", {
        batchNumber: context.batchNumber + 1
      });
      await this.runTask(callback);
    }
  }

  async scheduleCleanup() {
    const tomorrow = new Date();
    tomorrow.setDate(tomorrow.getDate() + 1);

    const callback = await this.callback("cleanupOldData");
    return await this.run(callback, { runAt: tomorrow });
  }
}
Copy