Commit 4dbfb6bc authored by nanahira's avatar nanahira

fix request conflict

parent 30260494
Pipeline #20898 passed with stages
in 23 seconds
...@@ -551,6 +551,8 @@ class Checker { ...@@ -551,6 +551,8 @@ class Checker {
good ? ConnectResult.Good : ConnectResult.CDNBad, good ? ConnectResult.Good : ConnectResult.CDNBad,
); );
} }
private requestQueue = new PQueue({ concurrency: 1 });
async handleRecordResult(recordInfo: DomainRecordInfo, good: ConnectResult) { async handleRecordResult(recordInfo: DomainRecordInfo, good: ConnectResult) {
const record = recordInfo.record; const record = recordInfo.record;
const status = record.Status; const status = record.Status;
...@@ -565,13 +567,15 @@ class Checker { ...@@ -565,13 +567,15 @@ class Checker {
recordInfo, recordInfo,
)} from ${status} to ${targetStatus}.`, )} from ${status} to ${targetStatus}.`,
); );
await this.client.request( await this.requestQueue.add(() =>
'SetDomainRecordStatus', this.client.request(
{ 'SetDomainRecordStatus',
RecordId: record.RecordId, {
Status: targetStatus, RecordId: record.RecordId,
}, Status: targetStatus,
requestOption, },
requestOption,
),
); );
} }
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment