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

The metrics collected during the materialization process.

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.