diff --git a/src/if-run/lib/compute.ts b/src/if-run/lib/compute.ts index 81bc768e..497d0b5e 100644 --- a/src/if-run/lib/compute.ts +++ b/src/if-run/lib/compute.ts @@ -184,7 +184,6 @@ const computeNode = async (node: Node, params: ComputeParams): Promise => { debugLogger.setExecutingPluginName(pluginName); outputStorage = await plugin.execute(outputStorage, nodeConfig); - console.log(outputStorage); debugLogger.setExecutingPluginName(); node.outputs = outputStorage; 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;