multi_client_exception_test.sh

#!/bin/bash
set -xe

export PYTHONUNBUFFERED=1

src_dir=${ONEFLOW_SRC_DIR:-"$PWD"}
test_dir="$PWD/python/oneflow/test/exceptions"
test_tmp_dir=${ONEFLOW_TEST_TMP_DIR:-"./test_tmp_dir"}
export ONEFLOW_TEST_UTILS_DIR=$src_dir/python/oneflow/test_utils


rm -rf $test_tmp_dir
mkdir -p $test_tmp_dir
cp -r $test_dir $test_tmp_dir
cd ${test_tmp_dir}/$(basename $test_dir)

export ONEFLOW_DEBUG_MODE=1

for file in $(ls ${PWD}/test_*.py)
do
    if test -f $file
    then
        export ONEFLOW_TEST_DEVICE_NUM=1
        python3 $file --failfast --verbose
        if [[ "$(python3 -c 'import oneflow.sysconfig;print(oneflow.sysconfig.has_rpc_backend_grpc())')" == *"True"* ]]; then
            export ONEFLOW_TEST_DEVICE_NUM=2
            python3 -m oneflow.distributed.launch --nproc_per_node 2 $file --failfast --verbose

            export ONEFLOW_TEST_DEVICE_NUM=4
            python3 -m oneflow.distributed.launch --nproc_per_node 4 $file --failfast --verbose
        else
            python3 -c 'import oneflow.sysconfig;assert(oneflow.sysconfig.has_rpc_backend_grpc() == False)'
        fi
    fi
done

unset ONEFLOW_DEBUG_MODE