From 1cd0fe0dcf5fb4f6ec8dfaa6177331b0a7f2c9d4 Mon Sep 17 00:00:00 2001
From: vasilije <vas.markovic@gmail.com>
Date: Sat, 19 Jul 2025 14:24:55 +0200
Subject: [PATCH] check if base new workflow works

---
 cognee/api/v1/add/add.py | 44 ++++++++++++++++++++--------------------
 1 file changed, 22 insertions(+), 22 deletions(-)

diff --git a/cognee/api/v1/add/add.py b/cognee/api/v1/add/add.py
index 70b0d27a8..ce0b93fea 100644
--- a/cognee/api/v1/add/add.py
+++ b/cognee/api/v1/add/add.py
@@ -171,30 +171,30 @@ async def add(
     """
 
     # Determine which ingestion system to use
-    use_plugin_system = preferred_loaders is not None or loader_config is not None
+    # use_plugin_system = preferred_loaders is not None or loader_config is not None
 
-    if use_plugin_system:
-        # Use new plugin-based ingestion system
-        from cognee.tasks.ingestion.plugin_ingest_data import plugin_ingest_data
+    # if use_plugin_system:
+    #     # Use new plugin-based ingestion system
+    from cognee.tasks.ingestion.plugin_ingest_data import plugin_ingest_data
 
-        tasks = [
-            Task(resolve_data_directories, include_subdirectories=True),
-            Task(
-                plugin_ingest_data,
-                dataset_name,
-                user,
-                node_set,
-                dataset_id,
-                preferred_loaders,
-                loader_config,
-            ),
-        ]
-    else:
-        # Use existing ingestion system for backward compatibility
-        tasks = [
-            Task(resolve_data_directories, include_subdirectories=True),
-            Task(ingest_data, dataset_name, user, node_set, dataset_id),
-        ]
+    tasks = [
+        Task(resolve_data_directories, include_subdirectories=True),
+        Task(
+            plugin_ingest_data,
+            dataset_name,
+            user,
+            node_set,
+            dataset_id,
+            preferred_loaders,
+            loader_config,
+        ),
+    ]
+    # else:
+    #     # Use existing ingestion system for backward compatibility
+    #     tasks = [
+    #         Task(resolve_data_directories, include_subdirectories=True),
+    #         Task(ingest_data, dataset_name, user, node_set, dataset_id),
+    #     ]
 
     pipeline_run_info = None