FM / tests

/usr/local/lib64/python3.6/site-packages/pyarrow/tests/

/usr/local/lib64/python3.6/site-packages/pyarrow/tests

Name	Size	Mode	Actions
data/	-	0755	rm
parquet/	-	0755	rm
__pycache__/	-	0755	rm
arrow_7980.py	1094	0644	edit dl rm
bound_function_visit_strings.pyx	2047	0644	edit dl rm
conftest.py	7982	0644	edit dl rm
deserialize_buffer.py	961	0644	edit dl rm
pandas_examples.py	5115	0644	edit dl rm
pandas_threaded_import.py	1429	0644	edit dl rm
pyarrow_cython_example.pyx	1951	0644	edit dl rm
strategies.py	12525	0644	edit dl rm
test_adhoc_memory_leak.py	1410	0644	edit dl rm
test_array.py	100157	0644	edit dl rm
test_builder.py	2184	0644	edit dl rm
test_cffi.py	13090	0644	edit dl rm
test_compute.py	83551	0644	edit dl rm
test_convert_builtin.py	71768	0644	edit dl rm
test_csv.py	68943	0644	edit dl rm
test_cuda.py	27863	0644	edit dl rm
test_cuda_numba_interop.py	8730	0644	edit dl rm
test_cython.py	5948	0644	edit dl rm
test_dataset.py	143023	0644	edit dl rm
test_deprecations.py	891	0644	edit dl rm
test_extension_type.py	24437	0644	edit dl rm
test_feather.py	23209	0644	edit dl rm
test_filesystem.py	2106	0644	edit dl rm
test_flight.py	73715	0644	edit dl rm
test_fs.py	54133	0644	edit dl rm
test_gandiva.py	14385	0644	edit dl rm
test_hdfs.py	13452	0644	edit dl rm
test_io.py	53066	0644	edit dl rm
test_ipc.py	31267	0644	edit dl rm
test_json.py	11325	0644	edit dl rm
test_jvm.py	15471	0644	edit dl rm
test_memory.py	4928	0644	edit dl rm
test_misc.py	4927	0644	edit dl rm
test_orc.py	9221	0644	edit dl rm
test_pandas.py	157909	0644	edit dl rm
test_plasma.py	44011	0644	edit dl rm
test_plasma_tf_op.py	3523	0644	edit dl rm
test_scalars.py	21074	0644	edit dl rm
test_schema.py	21282	0644	edit dl rm
test_serialization.py	42026	0644	edit dl rm
test_serialization_deprecated.py	1775	0644	edit dl rm
test_sparse_tensor.py	17436	0644	edit dl rm
test_strategies.py	1739	0644	edit dl rm
test_table.py	53168	0644	edit dl rm
test_tensor.py	6270	0644	edit dl rm
test_types.py	31487	0644	edit dl rm
test_util.py	1791	0644	edit dl rm
util.py	9011	0644	edit dl rm
__init__.py	0	0644	edit dl rm

Edit: /usr/local/lib64/python3.6/site-packages/pyarrow/tests/test_plasma_tf_op.py (3523B)

# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements.  See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership.  The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License.  You may obtain a copy of the License at
#
#   http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
# KIND, either express or implied.  See the License for the
# specific language governing permissions and limitations
# under the License.

import numpy as np
import pytest

def run_tensorflow_test_with_dtype(tf, plasma, plasma_store_name,
                                   client, use_gpu, dtype):
    FORCE_DEVICE = '/gpu' if use_gpu else '/cpu'

object_id = np.random.bytes(20)

data = np.random.randn(3, 244, 244).astype(dtype)
    ones = np.ones((3, 244, 244)).astype(dtype)

sess = tf.Session(config=tf.ConfigProto(
        allow_soft_placement=True, log_device_placement=True))

def ToPlasma():
        data_tensor = tf.constant(data)
        ones_tensor = tf.constant(ones)
        return plasma.tf_plasma_op.tensor_to_plasma(
            [data_tensor, ones_tensor],
            object_id,
            plasma_store_socket_name=plasma_store_name)

def FromPlasma():
        return plasma.tf_plasma_op.plasma_to_tensor(
            object_id,
            dtype=tf.as_dtype(dtype),
            plasma_store_socket_name=plasma_store_name)

with tf.device(FORCE_DEVICE):
        to_plasma = ToPlasma()
        from_plasma = FromPlasma()

z = from_plasma + 1

sess.run(to_plasma)
    # NOTE(zongheng): currently it returns a flat 1D tensor.
    # So reshape manually.
    out = sess.run(from_plasma)

out = np.split(out, 2)
    out0 = out[0].reshape(3, 244, 244)
    out1 = out[1].reshape(3, 244, 244)

sess.run(z)

assert np.array_equal(data, out0), "Data not equal!"
    assert np.array_equal(ones, out1), "Data not equal!"

# Try getting the data from Python
    plasma_object_id = plasma.ObjectID(object_id)
    obj = client.get(plasma_object_id)

# Deserialized Tensor should be 64-byte aligned.
    assert obj.ctypes.data % 64 == 0

result = np.split(obj, 2)
    result0 = result[0].reshape(3, 244, 244)
    result1 = result[1].reshape(3, 244, 244)

assert np.array_equal(data, result0), "Data not equal!"
    assert np.array_equal(ones, result1), "Data not equal!"

@pytest.mark.plasma
@pytest.mark.tensorflow
@pytest.mark.skip(reason='Until ARROW-4259 is resolved')
def test_plasma_tf_op(use_gpu=False):
    import pyarrow.plasma as plasma
    import tensorflow as tf

plasma.build_plasma_tensorflow_op()

if plasma.tf_plasma_op is None:
        pytest.skip("TensorFlow Op not found")

with plasma.start_plasma_store(10**8) as (plasma_store_name, p):
        client = plasma.connect(plasma_store_name)
        for dtype in [np.float32, np.float64,
                      np.int8, np.int16, np.int32, np.int64]:
            run_tensorflow_test_with_dtype(tf, plasma, plasma_store_name,
                                           client, use_gpu, dtype)

# Make sure the objects have been released.
        for _, info in client.list().items():
            assert info['ref_count'] == 0

cmd: