chore: upgrade moduleResolution to Node16 (#9269)
This commit is contained in:
@@ -92,7 +92,6 @@ export class WorkflowOrchestratorService {
|
||||
protected container_: MedusaContainer
|
||||
private subscribers: Subscribers = new Map()
|
||||
private activeStepsCount: number = 0
|
||||
private logger: Logger
|
||||
|
||||
protected redisDistributedTransactionStorage_: RedisDistributedTransactionStorage
|
||||
|
||||
@@ -101,7 +100,6 @@ export class WorkflowOrchestratorService {
|
||||
redisDistributedTransactionStorage,
|
||||
redisPublisher,
|
||||
redisSubscriber,
|
||||
logger,
|
||||
sharedContainer,
|
||||
}: {
|
||||
dataLoaderOnly: boolean
|
||||
@@ -115,7 +113,6 @@ export class WorkflowOrchestratorService {
|
||||
this.container_ = sharedContainer
|
||||
this.redisPublisher = redisPublisher
|
||||
this.redisSubscriber = redisSubscriber
|
||||
this.logger = logger
|
||||
|
||||
redisDistributedTransactionStorage.setWorkflowOrchestratorService(this)
|
||||
|
||||
@@ -263,7 +260,7 @@ export class WorkflowOrchestratorService {
|
||||
options?: WorkflowOrchestratorRunOptions<undefined>,
|
||||
@MedusaContext() sharedContext: Context = {}
|
||||
): Promise<DistributedTransactionType> {
|
||||
let { context, container } = options ?? {}
|
||||
let { context } = options ?? {}
|
||||
|
||||
if (!workflowId) {
|
||||
throw new Error("Workflow ID is required")
|
||||
|
||||
@@ -288,7 +288,7 @@ export class RedisDistributedTransactionStorage
|
||||
|
||||
async scheduleTransactionTimeout(
|
||||
transaction: DistributedTransactionType,
|
||||
timestamp: number,
|
||||
_: number,
|
||||
interval: number
|
||||
): Promise<void> {
|
||||
await this.queue.add(
|
||||
|
||||
Reference in New Issue
Block a user