Skip to content

Commit eebdc81

Browse files
Removed the async changes for agent eval
1 parent d6503cc commit eebdc81

2 files changed

Lines changed: 2 additions & 2 deletions

File tree

sygra/core/dataset/dataset_processor.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -441,7 +441,7 @@ async def _process_and_store_results(self):
441441
metadata = {"output_file": output_file}
442442
processor = utils.get_func_from_str(post_processor)
443443
processor_name = post_processor.split(".")[-1]
444-
processed_output_data = await processor().process(output_data, metadata)
444+
processed_output_data = processor().process(output_data, metadata)
445445
new_output_file = output_file[: output_file.rfind("/") + 1] + output_file[
446446
output_file.rfind("/") + 1 :
447447
].replace("output", processor_name, 1)

sygra/core/graph/graph_postprocessor.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,6 @@ class GraphPostProcessor(ABC):
88
"""
99

1010
@abstractmethod
11-
async def process(self, data: list, metadata: dict) -> list:
11+
def process(self, data: list, metadata: dict) -> list:
1212
# implement post processing logic with whole data, return the final data list
1313
pass

0 commit comments

Comments
 (0)