From ebd1d2adbf912c8fbf1c700b16a91ffc1e5a7d77 Mon Sep 17 00:00:00 2001
From: Igor Ilic <30923996+dexters1@users.noreply.github.com>
Date: Tue, 11 Feb 2025 18:31:53 +0100
Subject: [PATCH] fix: Resolve issue with UUID in telemetry (#524)

<!-- .github/pull_request_template.md -->

## Description
Fixes sending of UUID through telemetry

## DCO Affirmation
I affirm that all code in every commit of this pull request conforms to
the terms of the Topoteretes Developer Certificate of Origin


<!-- This is an auto-generated comment: release notes by coderabbit.ai
-->

## Summary by CodeRabbit

- **Bug Fixes**
- Enhanced telemetry logging by ensuring identifiers are consistently
formatted. This improvement helps prevent type-related issues during
logging and boosts overall reliability without affecting task execution
or user-facing functionality.

<!-- end of auto-generated comment: release notes by coderabbit.ai -->
---
 cognee/modules/pipelines/operations/run_tasks.py | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/cognee/modules/pipelines/operations/run_tasks.py b/cognee/modules/pipelines/operations/run_tasks.py
index c0f22d4f4..b02288338 100644
--- a/cognee/modules/pipelines/operations/run_tasks.py
+++ b/cognee/modules/pipelines/operations/run_tasks.py
@@ -234,7 +234,7 @@ async def run_tasks_with_telemetry(tasks: list[Task], data, pipeline_name: str):
             "Pipeline Run Started",
             user.id,
             additional_properties={
-                "pipeline_name": pipeline_name,
+                "pipeline_name": str(pipeline_name),
             }
             | config,
         )
@@ -247,7 +247,7 @@ async def run_tasks_with_telemetry(tasks: list[Task], data, pipeline_name: str):
             "Pipeline Run Completed",
             user.id,
             additional_properties={
-                "pipeline_name": pipeline_name,
+                "pipeline_name": str(pipeline_name),
             },
         )
     except Exception as error:
@@ -261,7 +261,7 @@ async def run_tasks_with_telemetry(tasks: list[Task], data, pipeline_name: str):
             "Pipeline Run Errored",
             user.id,
             additional_properties={
-                "pipeline_name": pipeline_name,
+                "pipeline_name": str(pipeline_name),
             }
             | config,
         )