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.