From cb4f9c838aff0d1750eec3fa42f1c09c005ded83 Mon Sep 17 00:00:00 2001
From: Giambattista Bloisi <giambattista.bloisi@openaire.eu>
Date: Mon, 18 Mar 2024 01:11:10 +0100
Subject: [PATCH] simple test DAG

---
 airflow/dags/import_raw_graph.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/airflow/dags/import_raw_graph.py b/airflow/dags/import_raw_graph.py
index 30ce7cc..22873cd 100644
--- a/airflow/dags/import_raw_graph.py
+++ b/airflow/dags/import_raw_graph.py
@@ -150,7 +150,7 @@ def import_raw_graph():
                     if failed > 0:
                         print(f"There were {failed} errors:")
 
-                    if len(succeeded) > 0:
+                    if succeeded > 0:
                         print(f"Bulk-inserted {succeeded} items (streaming_bulk).")
 
     @task