From 60e7b70271d07550428301ef638e562e73cb1ac4 Mon Sep 17 00:00:00 2001 From: Viraj Mehta Date: Thu, 11 Dec 2025 16:05:21 -0500 Subject: [PATCH 1/2] added create queue to quickstart --- README.md | 3 +++ 1 file changed, 3 insertions(+) diff --git a/README.md b/README.md index c8ee629..3ef1dcc 100644 --- a/README.md +++ b/README.md @@ -101,6 +101,9 @@ async fn main() -> anyhow::Result<()> { .build() .await?; + // Create the queue (idempotent - safe to call on every startup) + client.create_queue(None).await?; + // Register your task client.register::().await; From ade482d7881fb788e8686e79b477d35bbc515cbe Mon Sep 17 00:00:00 2001 From: Viraj Mehta Date: Thu, 11 Dec 2025 16:06:37 -0500 Subject: [PATCH 2/2] added migrations to readme --- README.md | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/README.md b/README.md index 3ef1dcc..3d55c5f 100644 --- a/README.md +++ b/README.md @@ -41,7 +41,7 @@ durable = "0.1" ## Quick Start ```rust -use durable::{Durable, Task, TaskContext, TaskResult, WorkerOptions, async_trait}; +use durable::{Durable, MIGRATOR, Task, TaskContext, TaskResult, WorkerOptions, async_trait}; use serde::{Deserialize, Serialize}; // Define your task parameters and output @@ -101,6 +101,9 @@ async fn main() -> anyhow::Result<()> { .build() .await?; + // Run migrations (idempotent - safe to call on every startup) + MIGRATOR.run(client.pool()).await?; + // Create the queue (idempotent - safe to call on every startup) client.create_queue(None).await?;