Skip to content
Merged
Show file tree
Hide file tree
Changes from 1 commit
Commits
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
Prev Previous commit
Next Next commit
fix: coderabbit issues
  • Loading branch information
borisarzentar committed Apr 2, 2025
commit 84194444cc263ee6700e24a40c8dd7edb774ace6
10 changes: 10 additions & 0 deletions cognee/modules/pipelines/exceptions.py
Original file line number Diff line number Diff line change
@@ -1,8 +1,18 @@
class WrongTaskOrderException(Exception):
message: str

def __init__(self, message: str):
self.message = message
super().__init__(message)


class TaskExecutionException(Exception):
type: str
message: str
traceback: str

def __init__(self, type: str, message: str, traceback: str):
self.message = message
self.type = type
self.traceback = traceback
super().__init__(message)
2 changes: 1 addition & 1 deletion cognee/modules/pipelines/operations/run_tasks.py
Original file line number Diff line number Diff line change
Expand Up @@ -107,7 +107,7 @@ async def run_tasks_with_telemetry(

async def run_tasks(
tasks: list[Task],
dataset_id: UUID,
dataset_id: UUID = None,
data: Any = None,
pipeline_name: str = "unknown_pipeline",
context: dict = None,
Expand Down
10 changes: 5 additions & 5 deletions cognee/modules/pipelines/tasks/Task.py
Original file line number Diff line number Diff line change
Expand Up @@ -124,11 +124,11 @@ async def run(self, *args, **kwargs):
except Exception as error:
import traceback

error_details = {
"type": type(error).__name__,
"message": str(error),
"traceback": traceback.format_exc(),
}
error_details = TaskExecutionException(
type=type(error).__name__,
message=str(error),
traceback=traceback.format_exc(),
)

yield TaskExecutionErrored(
task=self.executable,
Expand Down