diff --git a/src/if-run/lib/initialize.ts b/src/if-run/lib/initialize.ts index 554b4f9c..5ae3787f 100644 --- a/src/if-run/lib/initialize.ts +++ b/src/if-run/lib/initialize.ts @@ -3,6 +3,8 @@ import * as path from 'node:path'; import {ERRORS} from '@grnsft/if-core/utils'; import {PluginInterface} from '@grnsft/if-core/types'; +import {storeAggregationMetrics} from './aggregate'; + import {logger} from '../../common/util/logger'; import {memoizedLog} from '../util/log-memoize'; import {pluginStorage} from '../util/plugin-storage'; @@ -11,7 +13,6 @@ import {CONFIG, STRINGS} from '../config'; import {Context, PluginOptions} from '../../common/types/manifest'; import {PluginStorageInterface} from '../types/plugin-storage'; -import {storeAggregationMetrics} from './aggregate'; const { PluginInitializationError, diff --git a/src/if-run/util/aggregation-helper.ts b/src/if-run/util/aggregation-helper.ts index defa7172..6e9f4e07 100644 --- a/src/if-run/util/aggregation-helper.ts +++ b/src/if-run/util/aggregation-helper.ts @@ -39,12 +39,12 @@ export const aggregateOutputsIntoOne = ( const aggregationType = isTemporal ? 'component' : 'time'; if (aggregationParams[aggregationType] === 'none') { - return acc; + continue; } if (aggregationParams[aggregationType] === 'copy') { acc[metric] = output[metric]; - return acc; + continue; } acc[metric] = acc[metric] ?? 0;