mirror of
https://github.com/wassname/ray.git
synced 2026-06-27 23:23:15 +08:00
revert omp threads fix (#7288)
This commit is contained in:
@@ -13,6 +13,12 @@ if "pickle5" in sys.modules:
|
||||
"requires a specific version of pickle5 (which is "
|
||||
"packaged along with Ray).")
|
||||
|
||||
if "OMP_NUM_THREADS" not in os.environ:
|
||||
logger.debug("[ray] Forcing OMP_NUM_THREADS=1 to avoid performance "
|
||||
"degradation with many workers (issue #6998). You can "
|
||||
"override this by explicitly setting OMP_NUM_THREADS.")
|
||||
os.environ["OMP_NUM_THREADS"] = "1"
|
||||
|
||||
# Add the directory containing pickle5 to the Python path so that we find the
|
||||
# pickle5 version packaged with ray and not a pre-existing pickle5.
|
||||
pickle5_path = os.path.join(
|
||||
|
||||
@@ -38,6 +38,13 @@ def test_ignore_http_proxy(shutdown_only):
|
||||
assert ray.get(f.remote()) == 1
|
||||
|
||||
|
||||
# https://github.com/ray-project/ray/issues/7287
|
||||
def test_omp_threads_set(shutdown_only):
|
||||
ray.init(num_cpus=1)
|
||||
# Should have been auto set by ray init.
|
||||
assert os.environ["OMP_NUM_THREADS"] == "1"
|
||||
|
||||
|
||||
def test_simple_serialization(ray_start_regular):
|
||||
primitive_objects = [
|
||||
# Various primitive types.
|
||||
|
||||
Reference in New Issue
Block a user