File tree Expand file tree Collapse file tree 3 files changed +10
-4
lines changed Expand file tree Collapse file tree 3 files changed +10
-4
lines changed Original file line number Diff line number Diff line change @@ -32,6 +32,7 @@ const runWorker = async (args: CliArgs) => {
32
32
}
33
33
34
34
process . once ( 'SIGINT' , async ( ) => {
35
+ logger . info ( 'SIGINT received in CLI' ) ;
35
36
// allow C-c C-c for force interrupt
36
37
process . once ( 'SIGINT' , ( ) => {
37
38
logger . info ( 'worker closed forcefully' ) ;
@@ -46,6 +47,7 @@ const runWorker = async (args: CliArgs) => {
46
47
} ) ;
47
48
48
49
process . once ( 'SIGTERM' , async ( ) => {
50
+ logger . info ( 'SIGTERM received in CLI' ) ;
49
51
if ( args . production ) {
50
52
await worker . drain ( ) ;
51
53
}
Original file line number Diff line number Diff line change @@ -12,11 +12,15 @@ const ORPHANED_TIMEOUT = 15 * 1000;
12
12
if ( process . send ) {
13
13
// don't do anything on C-c
14
14
// this is handled in cli, triggering a termination of all child processes at once.
15
- process . on ( 'SIGINT' , ( ) => { } ) ;
15
+ process . on ( 'SIGINT' , ( ) => {
16
+ logger . info ( 'SIGINT received in inference proc' ) ;
17
+ } ) ;
16
18
17
19
// don't do anything on SIGTERM
18
20
// Render uses SIGTERM in autoscale, this ensures the processes are properly drained if needed
19
- process . on ( 'SIGTERM' , ( ) => { } ) ;
21
+ process . on ( 'SIGTERM' , ( ) => {
22
+ logger . info ( 'SIGTERM received in inference proc' ) ;
23
+ } ) ;
20
24
21
25
await once ( process , 'message' ) . then ( ( [ msg ] : IPCMessage [ ] ) => {
22
26
msg = msg ! ;
Original file line number Diff line number Diff line change @@ -139,13 +139,13 @@ const startJob = (
139
139
// don't do anything on C-c
140
140
// this is handled in cli, triggering a termination of all child processes at once.
141
141
process . on ( 'SIGINT' , ( ) => {
142
- logger . debug ( 'SIGINT received' ) ;
142
+ logger . info ( 'SIGINT received in job proc ' ) ;
143
143
} ) ;
144
144
145
145
// don't do anything on SIGTERM
146
146
// Render uses SIGTERM in autoscale, this ensures the processes are properly drained if needed
147
147
process . on ( 'SIGTERM' , ( ) => {
148
- logger . debug ( 'SIGTERM received' ) ;
148
+ logger . info ( 'SIGTERM received in job proc ' ) ;
149
149
} ) ;
150
150
151
151
await once ( process , 'message' ) . then ( ( [ msg ] : IPCMessage [ ] ) => {
You can’t perform that action at this time.
0 commit comments