Skip to content

Commit 7a7f0fe

Browse files
committed
fix flake8
1 parent bc9ebbf commit 7a7f0fe

File tree

2 files changed

+6
-3
lines changed

2 files changed

+6
-3
lines changed

executor/engine/job/base.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -256,7 +256,8 @@ def process_func(self):
256256
change the dir, redirect the stdout and stderr
257257
before the actual run."""
258258
cache_dir = self.cache_dir.resolve()
259-
if (self.redirect_out_err is not False) and (not isinstance(self.func, CaptureOut)):
259+
if (self.redirect_out_err is not False) and \
260+
(not isinstance(self.func, CaptureOut)):
260261
if isinstance(self.redirect_out_err, str):
261262
path_stdout = Path(self.redirect_out_err)
262263
path_stderr = Path(self.redirect_out_err)

executor/engine/middle/capture.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -54,9 +54,11 @@ def __init__(
5454

5555
def __call__(self, *args, **kwargs) -> T.Any:
5656
if not self.stdout_file.parent.exists():
57-
self.stdout_file.parent.mkdir(parents=True, exist_ok=True) # pragma: no cover
57+
self.stdout_file.parent.mkdir(
58+
parents=True, exist_ok=True) # pragma: no cover
5859
if not self.stderr_file.parent.exists():
59-
self.stderr_file.parent.mkdir(parents=True, exist_ok=True) # pragma: no cover
60+
self.stderr_file.parent.mkdir(
61+
parents=True, exist_ok=True) # pragma: no cover
6062

6163
if self.stdout_file == self.stderr_file:
6264
outf = open(self.stdout_file, 'a')

0 commit comments

Comments
 (0)