Method #pullResolved

packages/computer/src/workspace.ts:640–661

(resolvedId: string | undefined)

  }

  #pullResolved(resolvedId: string | undefined): Promise<ApplyResult> {
    return withSpan(
      this.#observer,
      "workspace.sync.pull",
      { "workspace.sync.backend": resolvedId },
      async () => {
        if (resolvedId === undefined || this.#moduleBackendsById.has(resolvedId)) {
          return { applied: 0, skipped: [] };
        }
        const handle = await this.#handleFor(resolvedId);
        if (handle.sync === "none") return { applied: 0, skipped: [] };
        return this.#runWithInvalidation(resolvedId, handle, () =>
          pullOnce(this.#db, handle.rpc.sync, resolvedId),
        );
      },
      (span, outcome) => {
        if (!outcome.ok) return;
        span.setAttribute("workspace.sync.applied", outcome.value.applied);
        span.setAttribute("workspace.sync.skipped", outcome.value.skipped.length);
      },
    );
  }

  async #schedulePendingSync(id: string): Promise<void> {
    const scheduler = this.#retryScheduler;