2424def test_get_updated_package_requirements_no_extra_package ():
2525 """Tests with no extra package."""
2626 result = _utils .get_updated_package_requirements (capture_references = False )
27+
2728 assert result is None
2829
2930 initial_packages = ["xgboost" ]
3031 result = _utils .get_updated_package_requirements (
3132 initial_packages , capture_references = False
3233 )
34+
3335 assert result == initial_packages
3436
3537
@@ -46,6 +48,7 @@ def test_get_updated_package_requirements_is_row_processor_with_versions():
4648 "pyarrow==14.0.1" ,
4749 ]
4850 result = _utils .get_updated_package_requirements (is_row_processor = True )
51+
4952 assert result == expected
5053
5154
@@ -60,6 +63,7 @@ def test_get_updated_package_requirements_ignore_version(mock_warn):
6063 result = _utils .get_updated_package_requirements (
6164 is_row_processor = True , ignore_package_version = True
6265 )
66+
6367 assert result == expected
6468 # Verify that a warning was issued.
6569 mock_warn .assert_called_once ()
@@ -75,13 +79,15 @@ def test_get_updated_package_requirements_capture_references_false():
7579 """
7680 # Case 1: Only capture_references=False.
7781 result_1 = _utils .get_updated_package_requirements (capture_references = False )
82+
7883 assert result_1 is None
7984
8085 # Case 2: capture_references=False but is_row_processor=True.
8186 expected_2 = ["numpy==1.24.4" , "pandas==2.0.3" , "pyarrow==14.0.1" ]
8287 result_2 = _utils .get_updated_package_requirements (
8388 is_row_processor = True , capture_references = False
8489 )
90+
8591 assert result_2 == expected_2
8692
8793
@@ -103,6 +109,7 @@ def test_get_updated_package_requirements_non_overlapping_packages():
103109 result = _utils .get_updated_package_requirements (
104110 package_requirements = initial_packages , is_row_processor = True
105111 )
112+
106113 assert result == expected
107114
108115
@@ -123,6 +130,7 @@ def test_get_updated_package_requirements_overlapping_packages():
123130 result = _utils .get_updated_package_requirements (
124131 package_requirements = initial_packages , is_row_processor = True
125132 )
133+
126134 assert result == expected
127135
128136
@@ -134,12 +142,14 @@ def test_get_updated_package_requirements_with_existing_cloudpickle():
134142 result = _utils .get_updated_package_requirements (
135143 package_requirements = initial_packages
136144 )
145+
137146 assert result == expected
138147
139148
140149def test_package_existed_helper ():
141150 """Tests the _package_existed helper function directly."""
142151 reqs = ["pandas==1.0" , "numpy" , "scikit-learn>=1.2.0" ]
152+
143153 # Exact match
144154 assert _utils ._package_existed (reqs , "pandas==1.0" )
145155 # Different version
@@ -212,6 +222,7 @@ def _func_without_return_type(x):
212222 ),
213223)
214224def test_get_bigframes_metadata (metadata_options , metadata_string ):
225+
215226 assert _utils .get_bigframes_metadata (** metadata_options ) == metadata_string
216227
217228
@@ -230,6 +241,7 @@ def test_get_bigframes_metadata(metadata_options, metadata_string):
230241def test_get_bigframes_metadata_array_type_not_serializable (output_type ):
231242 with pytest .raises (ValueError ) as context :
232243 _utils .get_bigframes_metadata (python_output_type = output_type )
244+
233245 assert str (context .value ) == (
234246 f"python_output_type { output_type } is not serializable. { constants .FEEDBACK_LINK } "
235247 )
@@ -283,6 +295,7 @@ def test_get_bigframes_metadata_array_type_not_serializable(output_type):
283295def test_get_python_output_type_from_bigframes_metadata (
284296 metadata_string , python_output_type
285297):
298+
286299 assert (
287300 _utils .get_python_output_type_from_bigframes_metadata (metadata_string )
288301 == python_output_type
@@ -293,4 +306,5 @@ def test_metadata_roundtrip_supported_array_types():
293306 for array_of in function_typing .RF_SUPPORTED_ARRAY_OUTPUT_PYTHON_TYPES :
294307 ser = _utils .get_bigframes_metadata (python_output_type = list [array_of ]) # type: ignore
295308 deser = _utils .get_python_output_type_from_bigframes_metadata (ser )
309+
296310 assert deser == list [array_of ] # type: ignore
0 commit comments