We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent fd63b16 commit 1e162b6Copy full SHA for 1e162b6
python/tests/engine/test_spark.py
@@ -1838,6 +1838,11 @@ def test_serialize_deserialize_avro(self, mocker):
1838
with pytest.raises(
1839
TypeError
1840
) as e_info: # todo look into this (to_avro from_avro has to be mocked)
1841
+ spark_engine._serialize_to_avro(
1842
+ feature_group=fg,
1843
+ dataframe=df,
1844
+ )
1845
+ '''
1846
serialized_df = spark_engine._serialize_to_avro(
1847
feature_group=fg,
1848
dataframe=df,
@@ -1847,6 +1852,7 @@ def test_serialize_deserialize_avro(self, mocker):
1852
1853
dataframe=serialized_df,
1849
1854
)
1855
1850
1856
1851
1857
# Assert
1858
assert str(e_info.value) == "'JavaPackage' object is not callable"
0 commit comments