Skip to main content

executePostProcessing

API Docs


Function: executePostProcessing()

executePostProcessing(executionResults, _metrics, config, deps): Promise<PostProcessingResult>

Defined in: src/workers/eventGeneration/postProcessor.ts:30

Executes post-processing tasks after the materialization of event instances is complete. This includes operations like cleaning up old data and logging final statistics.

Parameters​

executionResults​

EventGenerationExecutionResult[]

An array of results from the materialization execution.

_metrics​

ProcessingMetrics

config​

PostProcessingConfig

The configuration for post-processing.

deps​

WorkerDependencies

The dependencies required for the worker.

Returns​

Promise<PostProcessingResult>

  • A promise that resolves to the result of the post-processing operations.