Skip to content

Commit d107995

Browse files
fix(telemetry): resolve cyclic import in telemetry service (#10598)
* fix(telemetry): resolve cyclic import by moving get_email_model * [autofix.ci] apply automated fixes * [autofix.ci] apply automated fixes (attempt 2/3) --------- Co-authored-by: autofix-ci[bot] <114827586+autofix-ci[bot]@users.noreply.github.com>
1 parent b5a6f39 commit d107995

1 file changed

Lines changed: 10 additions & 3 deletions

File tree

  • src/backend/base/langflow/services/telemetry

src/backend/base/langflow/services/telemetry/service.py

Lines changed: 10 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,6 @@
2525
ShutdownPayload,
2626
VersionPayload,
2727
)
28-
from langflow.utils.registered_email_util import get_email_model
2928
from langflow.utils.version import get_version_info
3029

3130
if TYPE_CHECKING:
@@ -129,6 +128,8 @@ def _get_client_type(self) -> str:
129128

130129
async def _send_email_telemetry(self) -> None:
131130
"""Send the telemetry event for the registered email address."""
131+
from langflow.utils.registered_email_util import get_email_model
132+
132133
payload: EmailPayload | None = get_email_model()
133134

134135
if not payload:
@@ -250,9 +251,15 @@ async def stop(self) -> None:
250251
if self.worker_task:
251252
await self._cancel_task(self.worker_task, "Cancel telemetry worker task")
252253
if self.log_package_version_task:
253-
await self._cancel_task(self.log_package_version_task, "Cancel telemetry log package version task")
254+
await self._cancel_task(
255+
self.log_package_version_task,
256+
"Cancel telemetry log package version task",
257+
)
254258
if self.log_package_email_task:
255-
await self._cancel_task(self.log_package_email_task, "Cancel telemetry log package email task")
259+
await self._cancel_task(
260+
self.log_package_email_task,
261+
"Cancel telemetry log package email task",
262+
)
256263
await self.client.aclose()
257264
except Exception: # noqa: BLE001
258265
await logger.aexception("Error stopping tracing service")

0 commit comments

Comments
 (0)