File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -5,6 +5,7 @@ import { consola } from "consola";
55import { readFileSync , writeFileSync } from "node:fs" ;
66import path from "node:path" ;
77import { addDependency , detectPackageManager } from "nypm" ;
8+ import { OpenWorkflow } from "openworkflow" ;
89
910/** Initialize OpenWorkflow in the current project. */
1011export async function init ( ) : Promise < void > {
@@ -82,7 +83,9 @@ export async function workerStart(cliOptions: WorkerConfig): Promise<void> {
8283 consola . start ( "Starting worker..." ) ;
8384
8485 const { config } = await loadConfig ( ) ;
85- const worker = config . ow . newWorker ( { ...config . worker , ...cliOptions } ) ;
86+
87+ const ow = new OpenWorkflow ( { backend : config . backend } ) ;
88+ const worker = ow . newWorker ( { ...config . worker , ...cliOptions } ) ;
8689
8790 let shuttingDown = false ;
8891 /** Stop the worker on process shutdown. */
Original file line number Diff line number Diff line change 11import { loadConfig as loadC12Config } from "c12" ;
2- import type { OpenWorkflow , WorkerOptions } from "openworkflow" ;
2+ import type { Backend , WorkerOptions } from "openworkflow" ;
33
44export interface OpenWorkflowConfig {
5- ow : OpenWorkflow ;
5+ backend : Backend ;
66 worker ?: WorkerConfig ;
77}
88
Original file line number Diff line number Diff line change 11import { BackendPostgres } from "@openworkflow/backend-postgres" ;
22import { BackendSqlite } from "@openworkflow/backend-sqlite" ;
3- import { OpenWorkflow } from "openworkflow" ;
43
54const isProduction = process . env [ "NODE_ENV" ] === "production" ;
65const databaseUrl = process . env [ "DATABASE_URL" ] ;
@@ -12,6 +11,4 @@ const backend =
1211 ? await BackendPostgres . connect ( databaseUrl )
1312 : BackendSqlite . connect ( ":memory:" ) ;
1413
15- const ow = new OpenWorkflow ( { backend } ) ;
16-
17- export default { ow } ;
14+ export default { backend } ;
You can’t perform that action at this time.
0 commit comments