feat: add optional env var to skip starter project updates (#5193)

* Add optional env var to skip starter project updates

* [autofix.ci] apply automated fixes

---------

Co-authored-by: autofix-ci[bot] <114827586+autofix-ci[bot]@users.noreply.github.com>
This commit is contained in:
Jordan Frazier 2024-12-11 04:24:39 -08:00 • committed by GitHub
commit ebfce9d8ea
No known key found for this signature in database
GPG key ID: B5690EEEBB952194

View file

@ -1,6 +1,7 @@
import asyncio import asyncio
import copy import copy
import json import json
import os
import shutil import shutil
from collections import defaultdict from collections import defaultdict
from copy import deepcopy from copy import deepcopy
@ -628,15 +629,16 @@ async def create_or_update_starter_projects(all_types_dict: dict) -> None:
project_gradient, project_gradient,
project_tags, project_tags,
) = get_project_data(project) ) = get_project_data(project)
updated_project_data = update_projects_components_with_latest_component_versions( do_update_starter_projects = os.environ.get("LANGFLOW_UPDATE_STARTER_PROJECTS", "true").lower() == "true"
project_data.copy(), all_types_dict if do_update_starter_projects:
) updated_project_data = update_projects_components_with_latest_component_versions(
updated_project_data = update_edges_with_latest_component_versions(updated_project_data) project_data.copy(), all_types_dict
if updated_project_data != project_data: )
project_data = updated_project_data updated_project_data = update_edges_with_latest_component_versions(updated_project_data)
# We also need to update the project data in the file if updated_project_data != project_data:
project_data = updated_project_data
await update_project_file(project_path, project, updated_project_data) # We also need to update the project data in the file
await update_project_file(project_path, project, updated_project_data)
if project_name and project_data: if project_name and project_data:
for existing_project in await get_all_flows_similar_to_project(session, new_folder.id): for existing_project in await get_all_flows_similar_to_project(session, new_folder.id):
await session.delete(existing_project) await session.delete(existing_project)