This is an automated email from the ASF dual-hosted git repository.

potiuk pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git


The following commit(s) were added to refs/heads/main by this push:
     new f47a2a8af6 Refactor: Consolidate "import numpy as np" (#34111)
f47a2a8af6 is described below

commit f47a2a8af682d39085b0cd4f086300226f1a50e0
Author: Miroslav Šedivý <[email protected]>
AuthorDate: Thu Sep 7 02:10:04 2023 +0000

    Refactor: Consolidate "import numpy as np" (#34111)
---
 airflow/providers/oracle/hooks/oracle.py            |  6 +++---
 tests/providers/oracle/hooks/test_oracle.py         | 10 +++++-----
 tests/providers/salesforce/hooks/test_salesforce.py |  4 ++--
 tests/serialization/serializers/test_serializers.py |  4 ++--
 4 files changed, 12 insertions(+), 12 deletions(-)

diff --git a/airflow/providers/oracle/hooks/oracle.py 
b/airflow/providers/oracle/hooks/oracle.py
index 2b6bfdb009..bbf98fb405 100644
--- a/airflow/providers/oracle/hooks/oracle.py
+++ b/airflow/providers/oracle/hooks/oracle.py
@@ -275,9 +275,9 @@ class OracleHook(DbApiHook):
         :param replace: Whether to replace instead of insert
         """
         try:
-            import numpy
+            import numpy as np
         except ImportError:
-            numpy = None  # type: ignore
+            np = None  # type: ignore
 
         if target_fields:
             target_fields = ", ".join(target_fields)
@@ -297,7 +297,7 @@ class OracleHook(DbApiHook):
                     lst.append("'" + str(cell).replace("'", "''") + "'")
                 elif cell is None or isinstance(cell, float) and 
math.isnan(cell):  # coerce numpy NaN to NULL
                     lst.append("NULL")
-                elif numpy and isinstance(cell, numpy.datetime64):
+                elif np and isinstance(cell, np.datetime64):
                     lst.append("'" + str(cell) + "'")
                 elif isinstance(cell, datetime):
                     lst.append(f"to_date('{cell:%Y-%m-%d 
%H:%M:%S}','YYYY-MM-DD HH24:MI:SS')")
diff --git a/tests/providers/oracle/hooks/test_oracle.py 
b/tests/providers/oracle/hooks/test_oracle.py
index 9f49618b45..fa40ffcccb 100644
--- a/tests/providers/oracle/hooks/test_oracle.py
+++ b/tests/providers/oracle/hooks/test_oracle.py
@@ -21,7 +21,7 @@ import json
 from datetime import datetime
 from unittest import mock
 
-import numpy
+import numpy as np
 import oracledb
 import pytest
 
@@ -290,8 +290,8 @@ class TestOracleHook:
             (
                 "'basestr_with_quote",
                 None,
-                numpy.NAN,
-                numpy.datetime64("2019-01-24T01:02:03"),
+                np.NAN,
+                np.datetime64("2019-01-24T01:02:03"),
                 datetime(2019, 1, 24),
                 1,
                 10.24,
@@ -321,8 +321,8 @@ class TestOracleHook:
             (
                 "'basestr_with_quote",
                 None,
-                numpy.NAN,
-                numpy.datetime64("2019-01-24T01:02:03"),
+                np.NAN,
+                np.datetime64("2019-01-24T01:02:03"),
                 datetime(2019, 1, 24),
                 1,
                 10.24,
diff --git a/tests/providers/salesforce/hooks/test_salesforce.py 
b/tests/providers/salesforce/hooks/test_salesforce.py
index b670856a4a..2c437fdcb2 100644
--- a/tests/providers/salesforce/hooks/test_salesforce.py
+++ b/tests/providers/salesforce/hooks/test_salesforce.py
@@ -21,9 +21,9 @@ import os
 from unittest import mock
 from unittest.mock import Mock, patch
 
+import numpy as np
 import pandas as pd
 import pytest
-from numpy import nan
 from pytest import param
 from requests import Session as request_session
 from simple_salesforce import Salesforce, api
@@ -340,7 +340,7 @@ class TestSalesforceHook:
 
     @patch(
         "pandas.DataFrame.from_records",
-        return_value=pd.DataFrame({"test": [1, 2, 3], "dict": [nan, nan, 
{"foo": "bar"}]}),
+        return_value=pd.DataFrame({"test": [1, 2, 3], "dict": [np.nan, np.nan, 
{"foo": "bar"}]}),
     )
     def test_write_object_to_file_csv(self, mock_data_frame):
         mock_data_frame.return_value.to_csv = Mock()
diff --git a/tests/serialization/serializers/test_serializers.py 
b/tests/serialization/serializers/test_serializers.py
index 66f142e0ac..62ec8f3d9f 100644
--- a/tests/serialization/serializers/test_serializers.py
+++ b/tests/serialization/serializers/test_serializers.py
@@ -19,7 +19,7 @@ from __future__ import annotations
 import datetime
 import decimal
 
-import numpy
+import numpy as np
 import pendulum.tz
 import pytest
 from pendulum import DateTime
@@ -81,7 +81,7 @@ class TestSerializers:
         }
 
     def test_numpy(self):
-        i = numpy.int16(10)
+        i = np.int16(10)
         e = serialize(i)
         d = deserialize(e)
         assert i == d

Reply via email to