wehub-resource-sync
e768098d0e
Flake8 Lint / flake8 (push) Waiting to run
Publish Promptflow Doc / Build (push) Waiting to run
Publish Promptflow Doc / Deploy (push) Blocked by required conditions
Spell check CI / Spell_Check (push) Waiting to run
tools_continuous_delivery / Private PyPI non-main branch release (push) Has been skipped
tools_continuous_delivery / Private PyPI main branch release (push) Failing after 2m42s
25 lines
714 B
Python
25 lines
714 B
Python
from typing import List
|
|
|
|
from promptflow.core import tool
|
|
|
|
|
|
@tool
|
|
def aggregate(processed_results: List[str]):
|
|
"""
|
|
This tool aggregates the processed result of all lines to the variant level and log metric for each variant.
|
|
|
|
:param processed_results: List of the output of line_process node.
|
|
"""
|
|
|
|
# Add your aggregation logic here
|
|
# aggregated_results should be a dictionary with the metric name as the key and the metric value as the value.
|
|
results_num = len(processed_results)
|
|
print(results_num)
|
|
print(processed_results)
|
|
|
|
# Log metric for each variant
|
|
from promptflow.core import log_metric
|
|
log_metric(key="results_num", value=results_num)
|
|
|
|
return results_num
|