From 3f07ae5961083c956daa7ef0d58122a846554e7c Mon Sep 17 00:00:00 2001 From: maxdml Date: Tue, 30 Sep 2025 14:43:29 -0700 Subject: [PATCH] update readme --- README.md | 8 ++++---- dbos/doc.go | 4 ++-- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/README.md b/README.md index b011ebee..acdf692f 100644 --- a/README.md +++ b/README.md @@ -82,11 +82,11 @@ func main() { dbos.RegisterWorkflow(ctx, workflow) // Launch DBOS - err = ctx.Launch() + err = dbos.Launch(ctx) if err != nil { panic(err) } - defer ctx.Shutdown(2 * time.Second) + defer dbos.Shutdown(ctx, 2 * time.Second) // Run a durable workflow and get its result handle, err := dbos.RunWorkflow(ctx, workflow, "") @@ -157,11 +157,11 @@ func main() { queue := dbos.NewWorkflowQueue(ctx, "queue") // Launch DBOS - err = ctx.Launch() + err = dbos.Launch(ctx) if err != nil { panic(err) } - defer ctx.Shutdown(2 * time.Second) + defer dbos.Shutdown(ctx, 2 * time.Second) // Enqueue tasks and gather results fmt.Println("Enqueuing workflows") diff --git a/dbos/doc.go b/dbos/doc.go index a501f3c0..292252ae 100644 --- a/dbos/doc.go +++ b/dbos/doc.go @@ -12,13 +12,13 @@ // AppName: "my-app", // DatabaseURL: os.Getenv("DBOS_SYSTEM_DATABASE_URL"), // }) -// defer dbosContext.Shutdown(5 * time.Second) +// defer dbos.Shutdown(dbosContext, 5 * time.Second) // // // Register workflows before launching // dbos.RegisterWorkflow(dbosContext, myWorkflow) // // // Launch the context to start processing -// err = dbosContext.Launch() +// err = dbos.Launch(dbosContext) // // # Workflows //