Skip to content

Commit e047d54

Browse files
committed
Don't use local function
1 parent 10dac67 commit e047d54

File tree

1 file changed

+4
-5
lines changed

1 file changed

+4
-5
lines changed

python/pyarrow/tests/test_serialization.py

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -932,7 +932,10 @@ def test_serialize_read_concatenated_records():
932932
pa.read_serialized(f).deserialize()
933933

934934

935-
@pytest.mark.skipif(os.name == 'nt', reason="deserialize_regex not pickleable")
935+
def deserialize_regex(serialized, q):
936+
import pyarrow as pa
937+
q.put(pa.deserialize(serialized))
938+
936939
def test_deserialize_in_different_process():
937940
from multiprocessing import Process, Queue
938941
import re
@@ -945,10 +948,6 @@ def test_deserialize_in_different_process():
945948
serialized = pa.serialize(regex, serialization_context)
946949
serialized_bytes = serialized.to_buffer().to_pybytes()
947950

948-
def deserialize_regex(serialized, q):
949-
import pyarrow as pa
950-
q.put(pa.deserialize(serialized))
951-
952951
q = Queue()
953952
p = Process(target=deserialize_regex, args=(serialized_bytes, q))
954953
p.start()

0 commit comments

Comments
 (0)