File tree Expand file tree Collapse file tree 1 file changed +0
-4
lines changed Expand file tree Collapse file tree 1 file changed +0
-4
lines changed Original file line number Diff line number Diff line change @@ -449,7 +449,6 @@ func (c *dbosContext) Shutdown(timeout time.Duration) {
449449 select {
450450 case <- c .queueRunner .completionChan :
451451 c .logger .Info ("Queue runner completed" )
452- c .queueRunner = nil
453452 case <- time .After (timeout ):
454453 c .logger .Warn ("Timeout waiting for queue runner to complete" , "timeout" , timeout )
455454 }
@@ -473,7 +472,6 @@ func (c *dbosContext) Shutdown(timeout time.Duration) {
473472 if c .conductor != nil {
474473 c .logger .Info ("Shutting down conductor" )
475474 c .conductor .Shutdown (timeout )
476- c .conductor = nil
477475 }
478476
479477 // Shutdown the admin server
@@ -485,14 +483,12 @@ func (c *dbosContext) Shutdown(timeout time.Duration) {
485483 } else {
486484 c .logger .Info ("Admin server shutdown complete" )
487485 }
488- c .adminServer = nil
489486 }
490487
491488 // Close the system database
492489 if c .systemDB != nil {
493490 c .logger .Info ("Shutting down system database" )
494491 c .systemDB .shutdown (c , timeout )
495- c .systemDB = nil
496492 }
497493
498494 c .launched .Store (false )
You can’t perform that action at this time.
0 commit comments