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