removed apply_aggregation check [aggregator cannot be ready if apply_aggregation is False]

This commit is contained in:
2024-08-30 17:38:16 +02:00
parent 7a05d8f095
commit a65553e13a

View File

@ -51,12 +51,7 @@ def calc_aggregate(results, data, aggregator):
def calc_aggregation_ready(results, aggregator): def calc_aggregation_ready(results, aggregator):
apply_aggregation = results.get("apply_aggregation", False)
if not apply_aggregation:
return False
aggregation_max = results.get("aggregation_max") aggregation_max = results.get("aggregation_max")
if not aggregator.is_ready(aggregation_max): if not aggregator.is_ready(aggregation_max):
return False return False