alikia2x/cvsa
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

test: looser rate limits for snapshot

Browse Source
This commit is contained in:
alikia2x (寒寒) 2025-03-25 04:57:24 +08:00
parent a178b7fc16
commit 76c9256662
Signed by: alikia2x
GPG Key ID: 56209E0CCD8420C6
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
lib/mq/scheduler.ts
View File

@ -333,6 +333,9 @@ const biliLimiterConfig: RateLimiterConfig[] = [
}, },
]; ];
const bili_test = biliLimiterConfig;
bili_test[3].max = 500
/* /*
Execution order for setup: Execution order for setup:
@ -364,7 +367,7 @@ for (const region of regions) {
netScheduler.addTask("getVideoInfo", "bilibili", "all"); netScheduler.addTask("getVideoInfo", "bilibili", "all");
netScheduler.addTask("getLatestVideos", "bilibili", "all"); netScheduler.addTask("getLatestVideos", "bilibili", "all");
netScheduler.addTask("snapshotMilestoneVideo", "bilibili", regions.map((region) => `alicloud-${region}`)); netScheduler.addTask("snapshotMilestoneVideo", "bilibili", regions.map((region) => `alicloud-${region}`));
netScheduler.addTask("snapshotVideo", "bilibili", [ netScheduler.addTask("snapshotVideo", "bili_test", [
"alicloud-qingdao", "alicloud-qingdao",
"alicloud-shanghai", "alicloud-shanghai",
"alicloud-zhangjiakou", "alicloud-zhangjiakou",
@ -375,7 +378,8 @@ netScheduler.addTask("snapshotVideo", "bilibili", [
netScheduler.setTaskLimiter("getVideoInfo", videoInfoRateLimiterConfig); netScheduler.setTaskLimiter("getVideoInfo", videoInfoRateLimiterConfig);
netScheduler.setTaskLimiter("getLatestVideos", null); netScheduler.setTaskLimiter("getLatestVideos", null);
netScheduler.setTaskLimiter("snapshotMilestoneVideo", null); netScheduler.setTaskLimiter("snapshotMilestoneVideo", null);
netScheduler.setTaskLimiter("snapshotVideo", videoInfoRateLimiterConfig); netScheduler.setTaskLimiter("snapshotVideo", null);
netScheduler.setProviderLimiter("bilibili", biliLimiterConfig); netScheduler.setProviderLimiter("bilibili", biliLimiterConfig);
netScheduler.setProviderLimiter("bili_test", bili_test);
export default netScheduler; export default netScheduler;