Method retryPendingSync

packages/computer/src/workspace.ts:595–638

* Run a host-scheduled pending pull from its persisted cursor. * * The call shares the backend's mutation FIFO with push, pull, and * command brackets. A successful pull clears the host's durable * intent. A failed pull advances bounded exponential backoff; the * last failed attempt r

(id?: string)

   * last failed attempt remains stored and is reported as exhausted.
   */
  retryPendingSync(id?: string): Promise<WorkspaceRetryPendingSyncResult> {
    return this.#serialize(id, async (resolvedId) => {
      if (resolvedId === undefined) {
        throw new Error("Workspace has no backend configured for pending sync retry");
      }
      const scheduler = this.#retryScheduler;
      if (scheduler === undefined) {
        throw new Error("Workspace has no retryScheduler configured");
      }
      const intent = await scheduler.get(resolvedId);
      if (intent === undefined) return { status: "idle", backend: resolvedId };
      if (intent.attempt > this.#retryMaxAttempts) {
        return {
          status: "exhausted",
          backend: resolvedId,
          attempt: intent.attempt,
          error: "pending sync retry attempts exhausted",
        };
      }
      try {
        const result = await this.#pullResolved(resolvedId);
        await scheduler.clear(resolvedId);
        return {
          status: "complete",
          backend: resolvedId,
          applied: result.applied,
          skipped: result.skipped,
        };
      } catch (error) {
        const message = safeErrorMessage(error);
        if (intent.attempt >= this.#retryMaxAttempts) {
          return {
            status: "exhausted",
            backend: resolvedId,
            attempt: intent.attempt,
            error: message,
          };
        }
        const next = this.#retryIntent(resolvedId, intent.attempt + 1);
        await scheduler.schedule(next);
        return { status: "pending", ...next, error: message };
      }
    });
  }

  #pullResolved(resolvedId: string | undefined): Promise<ApplyResult> {
    return withSpan(