Skip to content

Commit d263482

Browse files
authored
Remove server ShutdownWait (#3351)
1 parent 27d7818 commit d263482

2 files changed

Lines changed: 0 additions & 6 deletions

File tree

cmd/hatchet-engine/engine/run.go

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -102,8 +102,6 @@ func Run(ctx context.Context, cf *loader.ConfigLoader, version string) error {
102102
return fmt.Errorf("could not run with config: %w", err)
103103
}
104104

105-
time.Sleep(server.Runtime.ShutdownWait)
106-
107105
l.Debug().Msgf("interrupt received, shutting down")
108106

109107
err = cleanup.Run()

pkg/config/server/server.go

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -196,9 +196,6 @@ type ConfigFileRuntime struct {
196196
// GRPCRateLimit is the rate limit for the grpc server. We count limits separately for the Workflow, Dispatcher and Events services. Workflow and Events service are set to this rate, Dispatcher is 10X this rate. The rate limit is per second, per engine, per api token.
197197
GRPCRateLimit float64 `mapstructure:"grpcRateLimit" json:"grpcRateLimit,omitempty" default:"1000"`
198198

199-
// ShutdownWait is the time between the readiness probe being offline when a shutdown is triggered and the actual start of cleaning up resources.
200-
ShutdownWait time.Duration `mapstructure:"shutdownWait" json:"shutdownWait,omitempty" default:"20s"`
201-
202199
// EnforceLimits controls whether the server enforces tenant limits
203200
EnforceLimits bool `mapstructure:"enforceLimits" json:"enforceLimits,omitempty" default:"false"`
204201

@@ -690,7 +687,6 @@ func BindAllEnv(v *viper.Viper) {
690687
_ = v.BindEnv("runtime.schedulerConcurrencyRateLimit", "SCHEDULER_CONCURRENCY_RATE_LIMIT")
691688
_ = v.BindEnv("runtime.schedulerConcurrencyPollingMinInterval", "SCHEDULER_CONCURRENCY_POLLING_MIN_INTERVAL")
692689
_ = v.BindEnv("runtime.schedulerConcurrencyPollingMaxInterval", "SCHEDULER_CONCURRENCY_POLLING_MAX_INTERVAL")
693-
_ = v.BindEnv("runtime.shutdownWait", "SERVER_SHUTDOWN_WAIT")
694690
_ = v.BindEnv("servicesString", "SERVER_SERVICES")
695691
_ = v.BindEnv("pausedControllers", "SERVER_PAUSED_CONTROLLERS")
696692
_ = v.BindEnv("enableDataRetention", "SERVER_ENABLE_DATA_RETENTION")

0 commit comments

Comments
 (0)