Skip to content

Commit e86d1af

Browse files
committed
Updated log file
1 parent 6786c75 commit e86d1af

2 files changed

Lines changed: 11 additions & 7 deletions

File tree

‎examples/SU2/SU2.py‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -109,7 +109,7 @@ def metadata_parser(file_name: str, **_) -> tuple[dict[str, Any], dict[str, Any]
109109
executable="SU2_CFD",
110110
script=config_filename,
111111
env=environment,
112-
completion_callback=lambda *_, **__: termination_trigger.set()
112+
completion_callback=lambda *_, **__: termination_trigger.set(),
113113
)
114114
with multiparser.FileMonitor(
115115
# Metrics cannot have square brackets in their names so we remove

‎simvue/executor.py‎

Lines changed: 10 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -54,6 +54,7 @@ def _execute_process(
5454
)
5555

5656
if completion_callback or completion_trigger:
57+
5758
def trigger_check(
5859
completion_callback: typing.Optional[CompletionCallback],
5960
trigger_to_set: typing.Optional[multiprocessing.synchronize.Event],
@@ -77,7 +78,8 @@ def trigger_check(
7778
)
7879

7980
thread_out = threading.Thread(
80-
target=trigger_check, args=(completion_callback, completion_trigger, _result)
81+
target=trigger_check,
82+
args=(completion_callback, completion_trigger, _result),
8183
)
8284
thread_out.start()
8385

@@ -109,9 +111,7 @@ def __init__(self, simvue_runner: "simvue.Run", keep_logs: bool = True) -> None:
109111
self._completion_triggers: dict[
110112
str, typing.Optional[multiprocessing.synchronize.Event]
111113
] = {}
112-
self._completion_processes: dict[
113-
str, typing.Optional[threading.Thread]
114-
] = {}
114+
self._completion_processes: dict[str, typing.Optional[threading.Thread]] = {}
115115
self._alert_ids: dict[str, str] = {}
116116
self.command_str: dict[str, str] = {}
117117
self._processes: dict[str, subprocess.Popen] = {}
@@ -246,7 +246,12 @@ def callback_function(status_code: int, std_out: str, std_err: str) -> None:
246246

247247
self._processes[identifier], self._completion_processes[identifier] = (
248248
_execute_process(
249-
identifier, command, self._runner.name, completion_callback, completion_trigger, env
249+
identifier,
250+
command,
251+
self._runner.name,
252+
completion_callback,
253+
completion_trigger,
254+
env,
250255
)
251256
)
252257

@@ -409,7 +414,6 @@ def kill_process(
409414
process.kill()
410415
process.wait()
411416

412-
413417
def kill_all(self) -> None:
414418
"""Kill all running processes"""
415419
for process in self._processes.keys():

0 commit comments

Comments
 (0)