Skip to main content
Skip to main content

AbstractBatchJobStrategy

constructor

Parameters

__container__anyRequired
__configModule__Record<string, unknown>
__moduleDeclaration__Record<string, unknown>

Properties

__configModule__Record<string, unknown>
__container__anyRequired
__moduleDeclaration__Record<string, unknown>
batchJobService_BatchJobServiceRequired
manager_EntityManagerRequired
transactionManager_undefined | EntityManagerRequired
batchTypestringRequired
identifierstringRequired

Accessors

activeManager_

Returns

EntityManagerEntityManagerRequired

Methods

atomicPhase_

Wraps some work within a transactional block. If the service already has a transaction manager attached this will be reused, otherwise a new transaction manager is created.

Type Parameters

TResultobjectRequired
TErrorobjectRequired

Parameters

work(transactionManager: EntityManager) => Promise<TResult>Required
the transactional work to be done
isolationOrErrorHandlerIsolationLevel | (error: TError) => Promise<void | TResult>
the isolation level to be used for the work.
maybeErrorHandlerOrDontFail(error: TError) => Promise<void | TResult>
Potential error handler

Returns

PromisePromise<TResult>Required
the result of the transactional work

buildTemplate

Builds and returns a template file that can be downloaded and filled in

Returns

PromisePromise<string>Required

handleProcessingError

Type Parameters

TobjectRequired

Parameters

batchJobIdstringRequired
errunknownRequired
resultTRequired

Returns

PromisePromise<void>Required

preProcessBatchJob

Method for pre-processing a batch job

Parameters

batchJobIdstringRequired

Returns

PromisePromise<void>Required

prepareBatchJobForProcessing

Method for preparing a batch job for processing

Parameters

batchJobCreateBatchJobInputRequired
reqRequestRequired

Returns

PromisePromise<CreateBatchJobInput>Required

processJob

Method does the actual processing of the job. Should report back on the progress of the operation.

Parameters

batchJobIdstringRequired

Returns

PromisePromise<void>Required

shouldRetryOnProcessingError

Parameters

batchJobBatchJobRequired
A Batch Job indicates an asynchronus task stored in the Medusa backend. Its status determines whether it has been executed or not.
errunknownRequired

Returns

PromisePromise<boolean>Required

shouldRetryTransaction_

Parameters

errRecord<string, unknown> | objectRequired

Returns

booleanboolean

withTransaction

Parameters

transactionManagerEntityManager

Returns

constructor(__container__: any, __configModule__?: Record<string, unknown>, __moduleDeclaration__?: Record<string, unknown>) => AbstractBatchJobStrategyRequired
__configModule__Record<string, unknown>
__container__anyRequired
__moduleDeclaration__Record<string, unknown>
batchJobService_BatchJobServiceRequired
manager_EntityManagerRequired
transactionManager_undefined | EntityManagerRequired
batchTypestringRequired
identifierstringRequired
activeManager_objectRequired
atomicPhase_<TResult, TError>(work: (transactionManager: EntityManager) => Promise<TResult>, isolationOrErrorHandler?: IsolationLevel | (error: TError) => Promise<void | TResult>, maybeErrorHandlerOrDontFail?: (error: TError) => Promise<void | TResult>) => Promise<TResult>Required
buildTemplate() => Promise<string>Required
handleProcessingError<T>(batchJobId: string, err: unknown, result: T) => Promise<void>Required
preProcessBatchJob(batchJobId: string) => Promise<void>Required
prepareBatchJobForProcessing(batchJob: CreateBatchJobInput, req: Request) => Promise<CreateBatchJobInput>Required
processJob(batchJobId: string) => Promise<void>Required
shouldRetryOnProcessingError(batchJob: BatchJob, err: unknown) => Promise<boolean>Required
shouldRetryTransaction_(err: Record<string, unknown> | { code: string }) => booleanRequired
withTransaction(transactionManager?: EntityManager) => AbstractBatchJobStrategyRequired
Was this section helpful?