jyapayne/langflow
1
0
Fork 0
Code Issues Pull requests Projects Releases 1 Packages Wiki Activity Actions

🐛 fix(settings.py): fix issue with extending components_path list with duplicate paths

Browse source 
✨ feat(settings.py): add logging of components_path and updated settings values for debugging purposes
This commit is contained in:
Gabriel Luiz Freitas Almeida 2023-08-04 09:51:41 -03:00
commit 56dfa2015c
1 changed files with 21 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

25
src/backend/langflow/settings.py
View file

@ -1,3 +1,5 @@
import contextlib
import json
import os import os
from typing import Optional, List from typing import Optional, List
from pathlib import Path from pathlib import Path
@ -58,10 +60,17 @@ class Settings(BaseSettings):
and langflow_component_path not in value and langflow_component_path not in value
): ):
if isinstance(langflow_component_path, list): if isinstance(langflow_component_path, list):
value.extend(langflow_component_path) for path in langflow_component_path:
else: if path not in value:
value.append(path)
logger.debug(
f"Extending {langflow_component_path} to components_path"
)
elif langflow_component_path not in value:
value.append(langflow_component_path) value.append(langflow_component_path)
logger.debug(f"Adding {langflow_component_path} to components_path") logger.debug(
f"Appending {langflow_component_path} to components_path"
)
if not value: if not value:
value = [BASE_COMPONENTS_PATH] value = [BASE_COMPONENTS_PATH]
@ -70,6 +79,7 @@ class Settings(BaseSettings):
value.append(BASE_COMPONENTS_PATH) value.append(BASE_COMPONENTS_PATH)
logger.debug("Adding default components path to components_path") logger.debug("Adding default components path to components_path")
logger.debug(f"Components path: {value}")
return value return value
class Config: class Config:
@ -114,15 +124,22 @@ class Settings(BaseSettings):
continue continue
logger.debug(f"Updating {key}") logger.debug(f"Updating {key}")
if isinstance(getattr(self, key), list): if isinstance(getattr(self, key), list):
# value might be a '[something]' string
with contextlib.suppress(json.decoder.JSONDecodeError):
value = json.loads(str(value))
if isinstance(value, list): if isinstance(value, list):
getattr(self, key).extend(value) for item in value:
if item not in getattr(self, key):
getattr(self, key).append(item)
logger.debug(f"Extended {key}") logger.debug(f"Extended {key}")
else: else:
getattr(self, key).append(value) getattr(self, key).append(value)
logger.debug(f"Appended {key}") logger.debug(f"Appended {key}")
else: else:
setattr(self, key, value) setattr(self, key, value)
logger.debug(f"Updated {key}") logger.debug(f"Updated {key}")
logger.debug(f"{key}: {getattr(self, key)}")
def save_settings_to_yaml(settings: Settings, file_path: str): def save_settings_to_yaml(settings: Settings, file_path: str):