From 8ce08baf01d7757c6fdcab0333405787c67d2dbc Mon Sep 17 00:00:00 2001 From: Marco Vinciguerra Date: Sun, 22 Sep 2024 22:25:01 +0200 Subject: [PATCH] fix: graph Iterator node --- scrapegraphai/graphs/smart_scraper_multi_concat_graph.py | 4 ++-- scrapegraphai/nodes/graph_iterator_node.py | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/scrapegraphai/graphs/smart_scraper_multi_concat_graph.py b/scrapegraphai/graphs/smart_scraper_multi_concat_graph.py index 1ee2c56e..2097e1ca 100644 --- a/scrapegraphai/graphs/smart_scraper_multi_concat_graph.py +++ b/scrapegraphai/graphs/smart_scraper_multi_concat_graph.py @@ -66,8 +66,8 @@ class SmartScraperMultiConcatGraph(AbstractGraph): node_config={ "graph_instance": SmartScraperGraph, "scraper_config": self.copy_config, - "scraper_schema": self.copy_schema, - } + }, + schema=self.copy_schema, ) concat_answers_node = ConcatAnswersNode( diff --git a/scrapegraphai/nodes/graph_iterator_node.py b/scrapegraphai/nodes/graph_iterator_node.py index e38461f1..f7fd944f 100644 --- a/scrapegraphai/nodes/graph_iterator_node.py +++ b/scrapegraphai/nodes/graph_iterator_node.py @@ -130,7 +130,7 @@ class GraphIteratorNode(BaseNode): if url.startswith("http"): graph.input_key = "url" participants.append(graph) - + futures = [_async_run(graph) for graph in participants] answers = await tqdm.gather(