@@ -41,7 +41,7 @@ def open_foam_simvue_demo(all_run_script: str, ci: bool) -> None:
41
41
uniq_id : str = f"{ uuid .uuid4 ()} " .split ("-" )[0 ]
42
42
43
43
@mp_tail_parse .log_parser
44
- def custom_parser (file_content : str , ** _ ) -> tuple [dict [str , Any ], dict [str , Any ]]:
44
+ def custom_parser (file_content : str , ** __ ) -> tuple [dict [str , Any ], dict [str , Any ]]:
45
45
exp1 : re .Pattern [str ] = re .compile (
46
46
"^(.+): Solving for (.+), Initial residual = (.+), Final residual = (.+), No Iterations (.+)$"
47
47
)
@@ -82,7 +82,7 @@ def custom_parser(file_content: str, **_) -> tuple[dict[str, Any], dict[str, Any
82
82
completion_callback = lambda * _ , ** __ : termination_trigger .set (),
83
83
)
84
84
with multiparser .FileMonitor (
85
- per_thread_callback = lambda metrics : run .log_metrics (metrics ),
85
+ per_thread_callback = lambda metrics , * _ : run .log_metrics (metrics ),
86
86
exception_callback = run .log_event ,
87
87
terminate_all_on_fail = True ,
88
88
plain_logging = True ,
@@ -94,6 +94,7 @@ def custom_parser(file_content: str, **_) -> tuple[dict[str, Any], dict[str, Any
94
94
parser_func = custom_parser ,
95
95
path_glob_exprs = [os .path .join (log_location , "log.pimpleFoam" )],
96
96
)
97
+ monitor .run ()
97
98
98
99
99
100
if __name__ in "__main__" :
0 commit comments