Skip to content

fix(telemetry): resolve cyclic import in telemetry service #10598

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
ogabrielluiz merged 3 commits into from
Nov 14, 2025
Merged

fix(telemetry): resolve cyclic import in telemetry service #10598

Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
ef478fb
fix(telemetry): resolve cyclic import by moving get_email_model
ogabrielluiz Nov 14, 2025
d5ee981
[autofix.ci] apply automated fixes
autofix-ci[bot] Nov 14, 2025
4388852
[autofix.ci] apply automated fixes (attempt 2/3)
autofix-ci[bot] Nov 14, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
13 changes: 10 additions & 3 deletions src/backend/base/langflow/services/telemetry/service.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,6 @@
ShutdownPayload,
VersionPayload,
)
from langflow.utils.registered_email_util import get_email_model
from langflow.utils.version import get_version_info

if TYPE_CHECKING:
Expand Down Expand Up @@ -127,6 +126,8 @@ def _get_client_type(self) -> str:

async def _send_email_telemetry(self) -> None:
"""Send the telemetry event for the registered email address."""
from langflow.utils.registered_email_util import get_email_model

payload: EmailPayload | None = get_email_model()

if not payload:
Expand Down Expand Up @@ -235,9 +236,15 @@ async def stop(self) -> None:
if self.worker_task:
await self._cancel_task(self.worker_task, "Cancel telemetry worker task")
if self.log_package_version_task:
await self._cancel_task(self.log_package_version_task, "Cancel telemetry log package version task")
await self._cancel_task(
self.log_package_version_task,
"Cancel telemetry log package version task",
)
if self.log_package_email_task:
await self._cancel_task(self.log_package_email_task, "Cancel telemetry log package email task")
await self._cancel_task(
self.log_package_email_task,
"Cancel telemetry log package email task",
)
await self.client.aclose()
except Exception: # noqa: BLE001
await logger.aexception("Error stopping tracing service")
Expand Down
Loading