@@ -21,23 +21,16 @@ const shutdown = async (opts) => {
21
21
RUNNER_SHUTTING_DOWN = true ;
22
22
23
23
const { error, cloud } = opts ;
24
- const {
25
- name,
26
- workdir = '' ,
27
- tfResource,
28
- noRetry,
29
- reason,
30
- destroyDelay
31
- } = opts ;
24
+ const { name, workdir = '' , tfResource, noRetry, reason } = opts ;
32
25
const tfPath = workdir ;
33
26
34
27
const unregisterRunner = async ( ) => {
35
28
if ( ! RUNNER ) return ;
36
29
37
30
try {
38
31
winston . info ( `Unregistering runner ${ name } ...` ) ;
39
- RUNNER && RUNNER . kill ( 'SIGINT' ) ;
40
32
await cml . unregisterRunner ( { name } ) ;
33
+ RUNNER && RUNNER . kill ( 'SIGINT' ) ;
41
34
winston . info ( '\tSuccess' ) ;
42
35
} catch ( err ) {
43
36
winston . error ( `\tFailed: ${ err . message } ` ) ;
@@ -81,9 +74,6 @@ const shutdown = async (opts) => {
81
74
winston . info ( 'runner status' , { reason, status : 'terminated' } ) ;
82
75
}
83
76
84
- winston . info ( `waiting ${ destroyDelay } seconds before exiting...` ) ;
85
- await sleep ( destroyDelay ) ;
86
-
87
77
if ( ! cloud ) {
88
78
try {
89
79
await unregisterRunner ( ) ;
@@ -413,6 +403,7 @@ exports.command = 'runner';
413
403
exports . description = 'Launch and register a self-hosted runner' ;
414
404
415
405
exports . handler = async ( opts ) => {
406
+ const { destroyDelay } = opts ;
416
407
if ( process . env . RUNNER_NAME ) {
417
408
winston . warn (
418
409
'ignoring RUNNER_NAME environment variable, use CML_RUNNER_NAME or --name instead'
@@ -421,6 +412,8 @@ exports.handler = async (opts) => {
421
412
try {
422
413
await run ( opts ) ;
423
414
} catch ( error ) {
415
+ winston . info ( `waiting ${ destroyDelay } seconds before exiting...` ) ;
416
+ await sleep ( destroyDelay ) ;
424
417
await shutdown ( { ...opts , error } ) ;
425
418
throw error ;
426
419
}
0 commit comments