mirror of
https://github.com/hibiken/asynq.git
synced 2024-12-26 07:42:17 +08:00
Minor fix
This commit is contained in:
parent
5d1ec70544
commit
aa936466b3
2
asynq.go
2
asynq.go
@ -138,7 +138,7 @@ func (opt RedisFailoverClientOpt) MakeRedisClient() interface{} {
|
||||
})
|
||||
}
|
||||
|
||||
// RedisFailoverClientOpt is used to creates a redis client that connects to
|
||||
// RedisClusterClientOpt is used to creates a redis client that connects to
|
||||
// redis cluster.
|
||||
type RedisClusterClientOpt struct {
|
||||
// A seed list of host:port addresses of cluster nodes.
|
||||
|
@ -70,7 +70,7 @@ func TestServerRun(t *testing.T) {
|
||||
go func() {
|
||||
select {
|
||||
case <-time.After(10 * time.Second):
|
||||
t.Fatal("server did not stop after receiving TERM signal")
|
||||
panic("server did not stop after receiving TERM signal")
|
||||
case <-done:
|
||||
}
|
||||
}()
|
||||
|
Loading…
Reference in New Issue
Block a user