mirror of
https://github.com/wassname/catalyst.git
synced 2026-07-14 11:15:09 +08:00
BUG: fix label array code dtype condense
This commit is contained in:
+45
-22
@@ -341,25 +341,30 @@ class LabelArrayTestCase(ZiplineTestCase):
|
||||
arr[:] = orig_arr
|
||||
check_arrays(arr, orig_arr)
|
||||
|
||||
def test_narrow_code_storage(self):
|
||||
def check_roundtrip(arr):
|
||||
assert_equal(
|
||||
@staticmethod
|
||||
def check_roundtrip(arr):
|
||||
assert_equal(
|
||||
arr.as_string_array(),
|
||||
LabelArray(
|
||||
arr.as_string_array(),
|
||||
LabelArray(
|
||||
arr.as_string_array(),
|
||||
arr.missing_value,
|
||||
).as_string_array(),
|
||||
)
|
||||
arr.missing_value,
|
||||
).as_string_array(),
|
||||
)
|
||||
|
||||
def create_categories(width, plus_one):
|
||||
length = int(width / 8) + plus_one
|
||||
return [
|
||||
''.join(cs)
|
||||
for cs in take(
|
||||
2 ** width + plus_one,
|
||||
product([chr(c) for c in range(256)], repeat=length),
|
||||
)
|
||||
]
|
||||
@staticmethod
|
||||
def create_categories(width, plus_one):
|
||||
length = int(width / 8) + plus_one
|
||||
return [
|
||||
''.join(cs)
|
||||
for cs in take(
|
||||
2 ** width + plus_one,
|
||||
product([chr(c) for c in range(256)], repeat=length),
|
||||
)
|
||||
]
|
||||
|
||||
def test_narrow_code_storage(self):
|
||||
create_categories = self.create_categories
|
||||
check_roundtrip = self.check_roundtrip
|
||||
|
||||
# uint8
|
||||
categories = create_categories(8, plus_one=False)
|
||||
@@ -386,11 +391,6 @@ class LabelArrayTestCase(ZiplineTestCase):
|
||||
self.assertEqual(arr.itemsize, 2)
|
||||
check_roundtrip(arr)
|
||||
|
||||
# uint16 inference
|
||||
arr = LabelArray(categories, missing_value=categories[0])
|
||||
self.assertEqual(arr.itemsize, 2)
|
||||
check_roundtrip(arr)
|
||||
|
||||
# fits in uint16
|
||||
categories = create_categories(16, plus_one=False)
|
||||
arr = LabelArray(
|
||||
@@ -422,3 +422,26 @@ class LabelArrayTestCase(ZiplineTestCase):
|
||||
|
||||
# NOTE: we could do this for 32 and 64; however, no one has enough RAM
|
||||
# or time for that.
|
||||
|
||||
def test_narrow_condense_back_to_valid_size(self):
|
||||
categories = ['a'] * (2 ** 8 + 1)
|
||||
arr = LabelArray(categories, missing_value=categories[0])
|
||||
assert_equal(arr.itemsize, 1)
|
||||
self.check_roundtrip(arr)
|
||||
|
||||
# longer than int16 but still fits when deduped
|
||||
categories = self.create_categories(16, plus_one=False)
|
||||
categories.append(categories[0])
|
||||
arr = LabelArray(categories, missing_value=categories[0])
|
||||
assert_equal(arr.itemsize, 2)
|
||||
self.check_roundtrip(arr)
|
||||
|
||||
def manual_narrow_condense_back_to_valid_size_slow(self):
|
||||
"""This test is really slow so we don't want it run by default.
|
||||
"""
|
||||
# tests that we don't try to create an 'int24' (which is meaningless)
|
||||
categories = self.create_categories(24, plus_one=False)
|
||||
categories.append(categories[0])
|
||||
arr = LabelArray(categories, missing_value=categories[0])
|
||||
assert_equal(arr.itemsize, 4)
|
||||
self.check_roundtrip(arr)
|
||||
|
||||
Reference in New Issue
Block a user