fix test
This commit is contained in:
parent
25d5a8cb7e
commit
2dde845738
|
@ -51,7 +51,8 @@ export class FetchInstanceMetadataService {
|
||||||
}
|
}
|
||||||
|
|
||||||
@bindThis
|
@bindThis
|
||||||
private async tryLock(host: string): Promise<string | null> {
|
// public for test
|
||||||
|
public async tryLock(host: string): Promise<string | null> {
|
||||||
// TODO: マイグレーションなのであとで消す (2024.3.1)
|
// TODO: マイグレーションなのであとで消す (2024.3.1)
|
||||||
this.redisClient.del(`fetchInstanceMetadata:mutex:${host}`);
|
this.redisClient.del(`fetchInstanceMetadata:mutex:${host}`);
|
||||||
|
|
||||||
|
@ -63,7 +64,8 @@ export class FetchInstanceMetadataService {
|
||||||
}
|
}
|
||||||
|
|
||||||
@bindThis
|
@bindThis
|
||||||
private unlock(host: string): Promise<number> {
|
// public for test
|
||||||
|
public unlock(host: string): Promise<number> {
|
||||||
return this.redisClient.del(`fetchInstanceMetadata:mutex:v2:${host}`);
|
return this.redisClient.del(`fetchInstanceMetadata:mutex:v2:${host}`);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue