fix: worker start pattern

grutt · Feb 2, 2024 · 31be848 · 31be848
1 parent 0daabf8
commit 31be848
Show file tree

Hide file tree

Showing 4 changed files with 11 additions and 5 deletions.
diff --git a/typescript-sdk/examples/concurrency-worker.ts b/typescript-sdk/examples/concurrency-worker.ts
@@ -38,4 +38,6 @@ const workflow: Workflow = {
   ],
 };
 
-hatchet.run(workflow);
+const worker = hatchet.worker('example-worker');
+worker.registerWorkflow(workflow);
+worker.start();
diff --git a/typescript-sdk/examples/dag-worker.ts b/typescript-sdk/examples/dag-worker.ts
@@ -52,4 +52,6 @@ const workflow: Workflow = {
   ],
 };
 
-hatchet.run(workflow);
+const worker = hatchet.worker('example-worker');
+worker.registerWorkflow(workflow);
+worker.start();
diff --git a/typescript-sdk/examples/simple-worker.ts b/typescript-sdk/examples/simple-worker.ts
@@ -36,4 +36,6 @@ const workflow: Workflow = {
   ],
 };
 
-hatchet.run(workflow);
+const worker = hatchet.worker('example-worker');
+worker.registerWorkflow(workflow);
+worker.start();
diff --git a/typescript-sdk/src/clients/hatchet-client/hatchet-client.ts b/typescript-sdk/src/clients/hatchet-client/hatchet-client.ts
@@ -120,14 +120,14 @@ export class HatchetClient {
     return worker;
   }
 
-  async worker(workflow: string | Workflow): Promise<Worker> {
+  worker(workflow: string | Workflow): Worker {
     const name = typeof workflow === 'string' ? workflow : workflow.id;
     const worker = new Worker(this, {
       name,
     });
 
     if (typeof workflow !== 'string') {
-      await worker.registerWorkflow(workflow);
+      worker.registerWorkflow(workflow);
       return worker;
     }