Remove waiting source for filtering

This commit is contained in:
hrsh7th
2021-09-09 10:54:07 +09:00
parent 201fa80452
commit 29679d493b

View File

@@ -259,7 +259,7 @@ core.filter = async.throttle(function()
-- To wait for processing source for that's timeout. -- To wait for processing source for that's timeout.
local sources = {} local sources = {}
for _, s in ipairs(core.get_sources()) do for _, s in ipairs(core.get_sources({ source.SourceStatus.FETCHING, source.SourceStatus.COMPLETED })) do
local time = core.SOURCE_TIMEOUT - s:get_fetching_time() local time = core.SOURCE_TIMEOUT - s:get_fetching_time()
if not s.incomplete and time > 0 then if not s.incomplete and time > 0 then
if #sources == 0 then if #sources == 0 then