Remove not needed deferred_from_coro call.

This commit is contained in:
Andrey Rakhmatullin 2021-03-23 22:47:48 +05:00
parent a6034f942b
commit 0596f2bf6e
1 changed files with 2 additions and 3 deletions

View File

@ -16,7 +16,6 @@ from scrapy.utils.defer import (
aiter_errback,
defer_fail,
defer_succeed,
deferred_from_coro,
iter_errback,
parallel,
parallel_async,
@ -191,8 +190,8 @@ class Scraper:
return defer_succeed(None)
if isinstance(result, collections.abc.AsyncIterable):
it = aiter_errback(result, self.handle_spider_error, request, response, spider)
dfd = deferred_from_coro(parallel_async(it, self.concurrent_items, self._process_spidermw_output,
request, response, spider))
dfd = parallel_async(it, self.concurrent_items, self._process_spidermw_output,
request, response, spider)
else:
it = iter_errback(result, self.handle_spider_error, request, response, spider)
dfd = parallel(it, self.concurrent_items, self._process_spidermw_output,