Skip to content

Commit

Permalink
Attempt at making test_child_raises_parent_exits_cleanly more reliabl…
Browse files Browse the repository at this point in the history
…e on macos
  • Loading branch information
ogrisel committed Sep 14, 2022
1 parent ac09691 commit 1e32cbf
Showing 1 changed file with 14 additions and 4 deletions.
18 changes: 14 additions & 4 deletions joblib/test/test_memmapping.py
Expand Up @@ -813,6 +813,7 @@ def test_child_raises_parent_exits_cleanly(backend):
# - the resource_tracker does not emit any warnings.
cmd = """if 1:
import os
from pathlib import Path
from time import sleep
import numpy as np
Expand All @@ -824,9 +825,9 @@ def test_child_raises_parent_exits_cleanly(backend):
def get_temp_folder(parallel_obj, backend):
if "{b}" == "loky":
return p._backend._workers._temp_folder
return Path(p._backend._workers._temp_folder)
else:
return p._backend._pool._temp_folder
return Path(p._backend._pool._temp_folder)
if __name__ == "__main__":
Expand All @@ -839,13 +840,22 @@ def get_temp_folder(parallel_obj, backend):
# the temporary folder should be deleted by the end of this
# call but apparently on some file systems, this takes
# some time to be visible.
#
# We attempt to write into the temporary folder to test for
# its existence and we wait for a maximum of 10 seconds.
for i in range(100):
if not os.path.exists(temp_folder):
try:
with open(temp_folder / "some_file.txt", "w") as f:
f.write("some content")
except FileNotFoundError:
# temp_folder has been deleted, all is fine
break
# ... else, wait a bit and try again
sleep(.1)
else:
raise AssertionError(
temp_folder + " was not deleted"
str(temp_folder) + " was not deleted"
) from e
""".format(b=backend)
env = os.environ.copy()
Expand Down

0 comments on commit 1e32cbf

Please sign in to comment.