simple test DAG

2024-03-18 01:11:10 +01:00 · 2024-03-18 01:11:10 +01:00 · cb4f9c838a
parent 47505e885f
commit cb4f9c838a
1 changed files with 1 additions and 1 deletions
--- 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