diff --git a/nodescraper/interfaces/dataplugin.py b/nodescraper/interfaces/dataplugin.py index 21d81b8e..1b18df28 100644 --- a/nodescraper/interfaces/dataplugin.py +++ b/nodescraper/interfaces/dataplugin.py @@ -65,7 +65,8 @@ class DataPlugin( - PluginInterface, Generic[TConnectionManager, TConnectArg, TDataModel, TCollectArg, TAnalyzeArg] + PluginInterface, + Generic[TConnectionManager, TConnectArg, TDataModel, TCollectArg, TAnalyzeArg], ): """Plugin used to collect and analyze data""" @@ -325,7 +326,7 @@ def collect( return self.collection_result self.logger.info("No connection manager provide, initializing connection manager") self.connection_manager = self.CONNECTION_TYPE( - system_info=self.system_info, + system_info=self.system_info.model_copy(), logger=self.logger, parent=self.__class__.__name__, task_result_hooks=self.task_result_hooks, @@ -357,7 +358,7 @@ def collect( for collector_cls in collector_classes: collector_args = self._resolve_collector_args(collector_cls, collection_args) collection_task = collector_cls( - system_info=self.system_info, + system_info=self.system_info.model_copy(), logger=self.logger, system_interaction_level=system_interaction_level, connection=self.connection_manager.connection, @@ -448,7 +449,7 @@ def analyze( analysis_args = self.ANALYZER_ARGS.model_validate(analysis_args) analyzer_task = self.ANALYZER( - self.system_info, + system_info=self.system_info.model_copy(), logger=self.logger, max_event_priority_level=max_event_priority_level, parent=self.__class__.__name__, diff --git a/nodescraper/interfaces/plugin.py b/nodescraper/interfaces/plugin.py index 9e22d346..9fe998d9 100644 --- a/nodescraper/interfaces/plugin.py +++ b/nodescraper/interfaces/plugin.py @@ -95,7 +95,7 @@ def __init__( if connection_args and self.CONNECTION_TYPE and not self.connection_manager: self.connection_manager = self.CONNECTION_TYPE( - system_info=self.system_info, + system_info=self.system_info.model_copy(), logger=logger, connection_args=connection_args, parent=self.__class__.__name__, diff --git a/nodescraper/pluginexecutor.py b/nodescraper/pluginexecutor.py index bb22b8a9..772f3662 100644 --- a/nodescraper/pluginexecutor.py +++ b/nodescraper/pluginexecutor.py @@ -111,7 +111,7 @@ def __init__( connection_manager = self.plugin_registry.connection_managers[connection] self.connection_library[connection_manager] = connection_manager( - system_info=self.system_info, + system_info=self.system_info.model_copy(), logger=self.logger, connection_args=connection_args, task_result_hooks=self.connection_result_hooks,