Yükseltme

Önceki bir sürümün yazdığı depo, bu sürümün olduğu gibi okumadığı veri tutabilir. gnl upgrade (kodda storage.upgrade()) onu deponun adımlarını çalıştırarak yükseltir: biçim adımları run-status ve schema, sonra paketlerin kaydettiği adımlar. Her adım idempotenttir — yeniden çalıştırılınca bekleyen bir şey bulmaz.

Paketler adımlarını depoya registerUpgradeSteps(storage, factories) ile, depo kurulduğu yerde bir kez ekler; böylece storage.upgrade(), gnl upgrade ve gnl doctor tek bir liste görür. Bir paket adımı paket/adım diye adlandırılır. gnl upgrade kurulu @gnldev/queue ve @gnldev/scheduler'ı kendisi bulur (isteğe bağlı peer'lerdir) ve dışa aktardıkları adımları kaydeder — bayrak yok. gnl init --features job ya da schedule kaydı yeni projeye yazar.

import { registerUpgradeSteps } from '@gnldev/durable';
import { PostgresStorage } from '@gnldev/durable/postgres';
import { queueUpgrade } from '@gnldev/queue';
import { schedulerUpgrade } from '@gnldev/scheduler';

// once, where the store is built: storage.upgrade(), gnl upgrade and gnl doctor see one list
export const storage = registerUpgradeSteps(
  new PostgresStorage({ connectionString: process.env.DATABASE_URL! }),
  [queueUpgrade, schedulerUpgrade],
);

gnl upgrade --list ve --dry-run hiçbir şey yazmaz ve her adımı gösterir (--dry-run ayrıca verinin hangi sürümde olduğunu ve paketin ne beklediğini: "data vX → package vY"). Bayraksız her bekleyen adımı çalıştırır; --only adım yalnızca onları. ran (çalıştı), failed (başarısız), not attempted (after a failure) (hata sonrası denenmedi), pending (bekliyor), waits for older processes (eski süreçleri bekliyor), not registered (kayıtsız) ve done (tamam) olanları basar. Çıkış kodu, başarısız bir adımda ya da kayıtsız bir borçta 1; yalnızca eski süreçleri bekleyen adımlar kaldıysa 0.

afterOlderGone işaretli bir adım, önceki sürümün bir süreci hâlâ çalışırken çalışamaz. Düz bir gnl upgrade onu bekliyor diye bildirir ve çalıştırmaz; önceki süreçlerin gittiğini söylemenin yolu --only'dir. Biçim adımları eldeki işi bekler (gnl pending; --wait bunu gnl pending --wait gibi bekler); afterOlderGone olmayan bir paket adımı beklemez. gnl doctor kayıtlı paket adımlarını, bekleyenleri ve kayıtsız borçları listeler.

Sıra asıl nokta: kuyruğun verisi biçim değiştiriyor; onu taşıyan adım eski süreçler çalışırken güvenle çalıştırılabilir, eski biçimi silen adım değil.

1. Paketleri güncelleyin. Alt sınırlar ai 7.0.149, @ai-sdk/openai 4.0.100, @ai-sdk/anthropic 4.0.86 ve @ai-sdk/provider 4.0.32 — kesilen akışı interrupted olarak bildiren ilk sürümler. @gnldev/cli artık peer olarak @gnldev/durable ister: olmayan projeye npm onu kurar, pnpm ve yarn peer uyarısı verir.
2. Bu sürümün kuyruk worker'ları başlamadan önce gnl upgrade çalıştırın. Kuyruk artık işleri kuruluş başına şeritlerde tutuyor, 0.16'nın tek qjob günlüğünde değil. Adım queue/lanes: eski günlüğün işlerini şeritlerine taşır (biten iş biter kalır, bekleyen bir kez çalışır) ve eski günlüğe dokunmaz, yani 0.16 worker'ları ve üreticileri hâlâ çalışırken de güvenlidir. İşleri hâlâ o günlükte duran bir depoda bu sürümün worker'ı başlamaz ve neyi çalıştıracağınızı söyler.
3. Bu sürümü yayına alın, kademeli deploy olarak. Bir 0.16 süreci hâlâ iş ekliyorsa, bu sürümün worker'ları onun eklediklerini taşır; bir 0.16 worker'ının ve yeni bir worker'ın birlikte bulduğu iş bir kez çalışır, çünkü tek bir kiralama vardır.
4. Her 0.16 süreci gittiğinde gnl upgrade --only queue/lanes-cleanup çalıştırın. Eski günlüğü ve imleçlerini siler. Depoyu hâlâ poll ederken görülen bir 0.16 worker'ı varken reddeder: hata ve --dry-run kaç tane olduğunu, her birinin en son ne zaman görüldüğünü ve kaydının ne zaman sona ereceğini söyler. Durdurulmak yerine öldürülen bir worker, ttlMs'i geçene kadar temizliği tutar.
5. Zamanlayıcının adımı scheduler/misfire-default aynı şekilde: her 0.16 poller'ı gittiğinde, 0.16'nın misfire: 'skip' ile sakladığı tetikleyicileri "varsayılan"a yeniden yazar. O zamana kadar bu sürüm o kayıtları kendisi varsayılan olarak okur. Kodda upgradeTriggers(journal, opts)'tır; önce bakmak için dryRun verin.

gnl upgrade --dry-run                      # what would run: data vX → package vY; writes nothing
gnl upgrade                                # 1. runs queue/lanes (safe beside 0.16 workers and producers)
# ...deploy 0.17 as a rolling deploy; once every 0.16 process is gone:
gnl upgrade --only queue/lanes-cleanup     # 2. deletes the old qjob log (refuses while a 0.16 worker is seen)
gnl upgrade --only scheduler/misfire-default   # 3. once every 0.16 poller is gone

upgrade()'ı olmayan, kendi yazdığınız bir depoda adımları kaydedecek yer yoktur; her 0.16 süreci gidince onları kendiniz çalıştırın: queueUpgrade(storage)'ın adımları ve onların run()'ı.

Bunların her biri 0.17 için changelog'un Breaking bölümünde; ait olduğu sayfada ayrıntısı var.

• Canlılık depoya verilir. liveness'i createGnl'e ya da createWorker'a vermek yerleşik bir depoda LivenessConflictError fırlatır. Onu depoya verin: PostgresStorage bir liveness seçeneği alır, diğer dört depo da (SqliteStorage ikinci argüman olarak). Bkz. Depo adaptörleri.
• listJobs bir sayfa döndürür ve orgId olmadan yalnızca kuruluşu olmayan işleri listeler. .items'ı okuyun; listAllJobs operatörün her kuruluşun işlerini gördüğü görünümdür. Bkz. Arka plan işleri.
• misfire: 'skip' kalktı, takma adı yok ve varsayılan 'latest'. Bir tetikleyici kesintiden sonra artık en eski değil son kaçırılan oluşumu tetikler; eski davranış için misfire: 'earliest' verin. Zamanı gelen tetikleyiciler birbirini beklemez ve concurrency'nin varsayılan sınırı yoktur. Bkz. Arka plan işleri.
• Özel bir WorkStore read, appendMany ve ready set ister (appendReady, takeReady, heldReady, deferReady, dropReady); listNamespaces ve getMany isteğe bağlı kalır. Paketle gelen her depo bunları uygular ve uyum seti denetler.
• Bir handler'ın çalışma hakkı bir sinyaldir. Bir kuyruk işinin ctx.signal'i artık lease-lost ve timeout için de abort olur; bir olay handler'ı meta.signal alır, bu yüzden meta'yı toEqual ile karşılaştıran bir test toMatchObject ister. Bkz. Arka plan işleri.
• Kesilen bir model akışı run_unfinished, 502'dir — her akışı finish_reason olmadan bitiren bir OpenAI uyumlu uç nokta eskiden 200 cevaplardı. Bir executor'ın close()'da durdurduğu çalıştırma released biter. Bkz. REST API.
• acquireRunLock now almaz: kilit deponun saatiyle damgalanır, yani beşinci argüman gitti. storage.upgrade() bir adım hata verince UpgradeFailedError fırlatır, adımın kendi hatasını değil: .report ve .cause'u okuyun, nedeni düzeltin ve yeniden çalıştırın — çalışan adımlar idempotenttir. UpgradeOptions.only bir readonly string[]'dir.

import { UpgradeFailedError } from '@gnldev/durable';

try {
  await storage.upgrade();
} catch (e) {
  if (e instanceof UpgradeFailedError) {
    console.error(e.step, e.report, e.cause); // the steps that ran are idempotent: fix the cause, run it again
  }
  throw e;
}

Depo adımı yok. Kodda ve Studio'da kontrol edilecekler:

• replayCounterfactual, ReplaySourceError, DEFAULT_SUITE, runSuite, checkScenario ve normalizeAnswer @gnldev/optimizer'dan @gnldev/experiment'e taşındı, takma ad yok; optimizer ile birlikte kurulur. compareOnSuite kalır. Bkz. optimizer.
• Studio'nun Regression sekmesi, POST /runs/:id/regression ve regressionModel seçeneği kaldırıldı; yerlerini Lab'ın capsule'ü alır (POST /lab/capsule, Inspector'ın Try in a capsule düğmesi). İki çalıştırmanın salt okunur farkı olan GET /runs/:id/regression/:otherId kalır.
• Lab'ın üç sekmesi var — Improve, New agent, Scenarios — ve dört mod ile mode=capsule ve mode=thread URL'leri kalktı. Bir şeyi değiştirilmiş capsule oyunu artık çalıştırmayı değiştirilmiş hâliyle trials kez, değiştirilmemiş hâliyle trials kez oynar, yani eskisinin yaklaşık iki katını harcar.
• Hiçbir form tek bir senaryo çalıştırmasını geçmediyse BestFormResult.best yoktur ve hiçbir şey test etmeyen bir thread teşhisi not-found değil untested der.
• :memctx sayıları modele gönderileni anlatır ve :derived: bölümünü içeren bir run kimliği reddedilir. Bkz. Bellek.

@gnldev/lab deneyseldir; API'si değişecek.