🔁: Updated plugins loading workflow to be able to store them o…

taskweaver/code_interpreter/code_executor.py

@@ -131,7 +131,7 @@ def _save_file(
     def load_plugin(self):
         for p in self.plugin_registry.get_list():
             try:
-                src_file = f"{self.config.app_base_path}/plugins/{p.impl}.py"
+                src_file = f"{self.config.app_base_path}/plugins/{p.impl}/{p.impl}.py"
                 with open(src_file, "r") as f:
                     plugin_code = f.read()
                 self.exec_client.load_plugin(

taskweaver/memory/plugin.py

@@ -297,7 +297,7 @@ def provide_plugin_registry(
     ) -> PluginRegistry:
         import os
 
-        file_glob = os.path.join(config.base_path, "*.yaml")
+        file_glob = os.path.join(config.base_path, '**',"*.yaml")
         return PluginRegistry(
             file_glob=file_glob,
             ttl=timedelta(minutes=10),

taskweaver/misc/component_registry.py

@@ -1,3 +1,4 @@
+import os
 from abc import ABC, abstractmethod
 from datetime import datetime, timedelta
 from typing import Dict, Generic, List, Optional, Tuple, TypeVar, Union
@@ -33,6 +34,15 @@ def is_available(self, freshness: Optional[timedelta] = None) -> bool:
             return False
         return True
 
+    def _should_skip_plugin_file(self, path):
+        splitted_path = path.split(os.sep)
+        is_plugin = os.path.join('plugins','project') in path
+        is_plugin_yaml = splitted_path[-2] == splitted_path[-1].split('.')[0]
+        if is_plugin:
+            if not is_plugin_yaml:
+                return True
+        return False
+
     def get_registry(
         self,
         force_reload: bool = False,
@@ -45,6 +55,8 @@ def get_registry(
 
         registry: Dict[str, component_type] = {}
         for path in glob_files(self._file_glob):
+            if self._should_skip_plugin_file(path):
+                continue
             try:
                 name, component = self._load_component(path)
             except ComponentDisabledException: