runMaterializationWorker
Function: runMaterializationWorker()
runMaterializationWorker(
config,drizzleClient,logger):Promise<WorkerResult>
Defined in: src/workers/eventGeneration/eventGenerationPipeline.ts:47
The main function for the materialization worker, orchestrating the entire pipeline from job discovery to execution and post-processing.
Parameters
config
The configuration for the worker.
drizzleClient
NodePgDatabase<API Docs>
The Drizzle ORM client for database access.
logger
FastifyBaseLogger
The logger for logging the worker's progress and any errors.
Returns
Promise<WorkerResult>
A promise that resolves to a summary result of the worker's run.