1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
|
import pytest
from parsl import AUTO_LOGNAME, Config, bash_app, python_app
from parsl.executors import ThreadPoolExecutor
def local_config():
return Config(executors=[ThreadPoolExecutor()])
@pytest.mark.local
def test_default_inputs():
@python_app
def identity(inp):
return inp
@bash_app
def sum_inputs(inputs=[identity(1), identity(2)], stdout=AUTO_LOGNAME):
calc = sum(inputs)
return f"echo {calc}"
fut = sum_inputs()
fut.result()
with open(fut.stdout, 'r') as f:
assert int(f.read()) == 3
|
