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

feat: Add TelemetryService and start telemetry in main.py

Browse source 
The code changes in `main.py` add the `get_telemetry_service()` function call to start telemetry service. This change enables the application to collect and analyze telemetry data.
This commit is contained in:
Gabriel Luiz Freitas Almeida 2024-06-23 00:35:57 -03:00
commit f29dcb9489
1 changed files with 2 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

3
src/backend/base/langflow/main.py
View file

@ -23,7 +23,7 @@ from langflow.initial_setup.setup import (
) )
from langflow.interface.types import get_and_cache_all_types_dict from langflow.interface.types import get_and_cache_all_types_dict
from langflow.interface.utils import setup_llm_caching from langflow.interface.utils import setup_llm_caching
from langflow.services.deps import get_cache_service, get_settings_service from langflow.services.deps import get_cache_service, get_settings_service, get_telemetry_service
from langflow.services.plugins.langfuse_plugin import LangfuseInstance from langflow.services.plugins.langfuse_plugin import LangfuseInstance
from langflow.services.utils import initialize_services, teardown_services from langflow.services.utils import initialize_services, teardown_services
from langflow.utils.logger import configure from langflow.utils.logger import configure
@ -93,6 +93,7 @@ def get_lifespan(fix_migration=False, socketio_server=None, version=None):
initialize_super_user_if_needed() initialize_super_user_if_needed()
task = asyncio.create_task(get_and_cache_all_types_dict(get_settings_service(), get_cache_service())) task = asyncio.create_task(get_and_cache_all_types_dict(get_settings_service(), get_cache_service()))
await create_or_update_starter_projects(task) await create_or_update_starter_projects(task)
asyncio.create_task(get_telemetry_service().start())
load_flows_from_directory() load_flows_from_directory()
yield yield
except Exception as exc: except Exception as exc: