diff --git a/providers/neo4j/src/airflow/providers/neo4j/hooks/neo4j.py b/providers/neo4j/src/airflow/providers/neo4j/hooks/neo4j.py index e0bb6ab52c311..7f14bd44513f2 100644 --- a/providers/neo4j/src/airflow/providers/neo4j/hooks/neo4j.py +++ b/providers/neo4j/src/airflow/providers/neo4j/hooks/neo4j.py @@ -81,7 +81,10 @@ def _create_driver(self, conn: Connection, encrypted: bool, uri: str) -> Driver: kwargs: dict[str, Any] = {} if parsed_uri.scheme in ["bolt", "neo4j"]: kwargs["encrypted"] = encrypted - return GraphDatabase.driver(uri, auth=(conn.login, conn.password), **kwargs) + auth = None + if conn.login is not None and conn.password is not None: + auth = (conn.login, conn.password) + return GraphDatabase.driver(uri, auth=auth, **kwargs) def get_uri(self, conn: Connection) -> str: """ diff --git a/providers/neo4j/tests/unit/neo4j/operators/test_neo4j.py b/providers/neo4j/tests/unit/neo4j/operators/test_neo4j.py index dccfcb56c8210..3f9253fda925d 100644 --- a/providers/neo4j/tests/unit/neo4j/operators/test_neo4j.py +++ b/providers/neo4j/tests/unit/neo4j/operators/test_neo4j.py @@ -18,8 +18,8 @@ from unittest import mock +from airflow.providers.common.compat.lazy_compat import timezone from airflow.providers.neo4j.operators.neo4j import Neo4jOperator -from airflow.utils import timezone DEFAULT_DATE = timezone.datetime(2015, 1, 1) DEFAULT_DATE_ISO = DEFAULT_DATE.isoformat()