File tree Expand file tree Collapse file tree 2 files changed +7
-6
lines changed Expand file tree Collapse file tree 2 files changed +7
-6
lines changed Original file line number Diff line number Diff line change 16
16
import multiprocessing
17
17
import os
18
18
import subprocess
19
+ import pathlib
19
20
import time
20
21
import typing
21
22
@@ -100,13 +101,13 @@ def add_process(
100
101
identifier : str ,
101
102
* args ,
102
103
executable : typing .Optional [str ] = None ,
103
- script : typing .Optional [str ] = None ,
104
- input_file : typing .Optional [str ] = None ,
104
+ script : typing .Optional [pathlib . Path ] = None ,
105
+ input_file : typing .Optional [pathlib . Path ] = None ,
105
106
env : typing .Optional [typing .Dict [str , str ]] = None ,
106
107
completion_callback : typing .Optional [
107
108
typing .Callable [[int , str , str ], None ]
108
109
] = None ,
109
- completion_trigger : multiprocessing .synchronize .Event ,
110
+ completion_trigger : typing . Optional [ multiprocessing .synchronize .Event ] = None ,
110
111
** kwargs ,
111
112
) -> None :
112
113
"""Add a process to be executed to the executor.
Original file line number Diff line number Diff line change @@ -618,9 +618,9 @@ def add_process(
618
618
self ,
619
619
identifier : str ,
620
620
* cmd_args ,
621
- executable : typing .Optional [str ] = None ,
622
- script : typing .Optional [str ] = None ,
623
- input_file : typing .Optional [str ] = None ,
621
+ executable : typing .Optional [typing . Union [ str ] ] = None ,
622
+ script : typing .Optional [pydantic . FilePath ] = None ,
623
+ input_file : typing .Optional [pydantic . FilePath ] = None ,
624
624
completion_callback : typing .Optional [
625
625
typing .Callable [[int , str , str ], None ]
626
626
] = None ,
You can’t perform that action at this time.
0 commit comments