Skip to content

Commit e7f7023

Browse files
committed
fix stderr issue with psij
1 parent 1c83646 commit e7f7023

File tree

2 files changed

+8
-8
lines changed

2 files changed

+8
-8
lines changed

.github/workflows/testflux.yml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,7 @@ jobs:
3434
apt-get update && apt-get install -y python3-venv
3535
export PATH=$PWD/bin:$PATH
3636
ln -s /usr/bin/python3 /usr/bin/python
37-
python3 -m pip install --upgrade pip && pip install -e ".[test]" && python -c 'import pydra; print(pydra.__version__)'
37+
python -m pip install --upgrade pip && pip install -e ".[test]" && python -c 'import pydra; print(pydra.__version__)'
3838
pip install -e "git+https://github.com/adi611/psij-python.git@adi611-patch-2#egg=psij-python"
3939
- name: Start Flux and Run Test
4040
run: |

pydra/engine/workers.py

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1016,18 +1016,18 @@ async def exec_psij(self, runnable, rerun=False):
10161016
spec.arguments.append("--rerun")
10171017

10181018
spec.stdout_path = cache_dir / "demo.stdout"
1019-
# spec.stderr_path = cache_dir / "demo.stderr"
1019+
spec.stderr_path = cache_dir / "demo.stderr"
10201020

10211021
job = self.make_job(spec, None)
10221022
jex.submit(job)
10231023
job.wait()
10241024

1025-
# if spec.stderr_path.stat().st_size > 0:
1026-
# with open(spec.stderr_path, "r") as stderr_file:
1027-
# stderr_contents = stderr_file.read()
1028-
# raise Exception(
1029-
# f"stderr_path '{spec.stderr_path}' is not empty. Contents:\n{stderr_contents}"
1030-
# )
1025+
if spec.stderr_path.stat().st_size > 0:
1026+
with open(spec.stderr_path, "r") as stderr_file:
1027+
stderr_contents = stderr_file.read()
1028+
raise Exception(
1029+
f"stderr_path '{spec.stderr_path}' is not empty. Contents:\n{stderr_contents}"
1030+
)
10311031

10321032
return
10331033

0 commit comments

Comments
 (0)