Skip to content

Commit

Permalink
Rebase onto master (#3393)
Browse files Browse the repository at this point in the history
  • Loading branch information
khk-globus authored Jun 25, 2024
1 parent 81e457f commit a128fdc
Show file tree
Hide file tree
Showing 4 changed files with 23 additions and 47 deletions.
22 changes: 7 additions & 15 deletions parsl/tests/test_bash_apps/test_memoize_ignore_args.py
Original file line number Diff line number Diff line change
@@ -1,7 +1,5 @@
import os

import pytest

import parsl
from parsl.app.app import bash_app

Expand All @@ -23,24 +21,18 @@ def no_checkpoint_stdout_app_ignore_args(stdout=None):
return "echo X"


def test_memo_stdout():
def test_memo_stdout(tmpd_cwd):
path_x = tmpd_cwd / "test.memo.stdout.x"

# this should run and create a file named after path_x
path_x = "test.memo.stdout.x"
if os.path.exists(path_x):
os.remove(path_x)

no_checkpoint_stdout_app_ignore_args(stdout=path_x).result()
assert os.path.exists(path_x)

# this should be memoized, so not create benc.test.y
path_y = "test.memo.stdout.y"
no_checkpoint_stdout_app_ignore_args(stdout=str(path_x)).result()
assert path_x.exists()

if os.path.exists(path_y):
os.remove(path_y)
# this should be memoized, so should not get created
path_y = tmpd_cwd / "test.memo.stdout.y"

no_checkpoint_stdout_app_ignore_args(stdout=path_y).result()
assert not os.path.exists(path_y)
assert not path_y.exists(), "For memoization, expected NO file written"

# this should also be memoized, so not create an arbitrary name
z_fut = no_checkpoint_stdout_app_ignore_args(stdout=parsl.AUTO_LOGNAME)
Expand Down
17 changes: 6 additions & 11 deletions parsl/tests/test_bash_apps/test_memoize_ignore_args_regr.py
Original file line number Diff line number Diff line change
@@ -1,5 +1,4 @@
import copy
import os
from typing import List

import pytest
Expand Down Expand Up @@ -30,21 +29,17 @@ def no_checkpoint_stdout_app(stdout=None):
return "echo X"


def test_memo_stdout():

def test_memo_stdout(tmpd_cwd):
assert const_list_x == const_list_x_arg

path_x = "test.memo.stdout.x"
if os.path.exists(path_x):
os.remove(path_x)
path_x = tmpd_cwd / "test.memo.stdout.x"

# this should run and create a file named after path_x
no_checkpoint_stdout_app(stdout=path_x).result()
assert os.path.exists(path_x)
no_checkpoint_stdout_app(stdout=str(path_x)).result()
path_x.unlink(missing_ok=False)

os.remove(path_x)
no_checkpoint_stdout_app(stdout=path_x).result()
assert not os.path.exists(path_x)
no_checkpoint_stdout_app(stdout=str(path_x)).result()
assert not path_x.exists(), "For memoization, expected NO file written"

# this should also be memoized, so not create an arbitrary name
z_fut = no_checkpoint_stdout_app(stdout=parsl.AUTO_LOGNAME)
Expand Down
19 changes: 4 additions & 15 deletions parsl/tests/test_error_handling/test_retries.py
Original file line number Diff line number Diff line change
@@ -1,9 +1,7 @@
import argparse
import os

import pytest

import parsl
from parsl import bash_app, python_app
from parsl.tests.configs.local_threads import fresh_config

Expand Down Expand Up @@ -68,8 +66,6 @@ def test_fail_nowait(numtasks=10):
assert isinstance(
e, TypeError), "Expected a TypeError, got {}".format(e)

print("Done")


@pytest.mark.local
def test_fail_delayed(numtasks=10):
Expand All @@ -94,19 +90,12 @@ def test_fail_delayed(numtasks=10):
assert isinstance(
e, TypeError), "Expected a TypeError, got {}".format(e)

print("Done")


@pytest.mark.local
def test_retry():
def test_retry(tmpd_cwd):
"""Test retries via app that succeeds on the Nth retry.
"""

fname = "retry.out"
try:
os.remove(fname)
except OSError:
pass
fu = succeed_on_retry(fname)

fu.result()
fpath = tmpd_cwd / "retry.out"
sout = str(tmpd_cwd / "stdout")
succeed_on_retry(str(fpath), stdout=sout).result()
12 changes: 6 additions & 6 deletions parsl/tests/test_staging/test_file.py
Original file line number Diff line number Diff line change
Expand Up @@ -22,11 +22,11 @@ def test_files():


@pytest.mark.local
def test_open():
with open('test-open.txt', 'w') as tfile:
tfile.write('Hello')
def test_open(tmpd_cwd):
fpath = tmpd_cwd / 'test-open.txt'
fpath.write_text('Hello')

pfile = File('test-open.txt')
pfile = File(fpath)

with open(str(pfile), 'r') as opfile:
assert (opfile.readlines()[0] == 'Hello')
with open(pfile) as opfile:
assert (opfile.read() == 'Hello')

0 comments on commit a128fdc

Please sign in to comment.