Use deferred_from_coro in asyncio test

This commit is contained in:
Eugenio Lacuesta 2020-11-09 12:17:15 -03:00
parent 114229eb4a
commit 7e98a76ac4
No known key found for this signature in database
GPG Key ID: DA3EF2D0913E9810
1 changed files with 4 additions and 4 deletions

View File

@ -1,9 +1,9 @@
import asyncio
import sys
import scrapy
from scrapy import Spider
from scrapy.crawler import CrawlerProcess
from scrapy.utils.defer import deferred_from_coro
from twisted.internet.defer import Deferred
@ -14,13 +14,13 @@ class UppercasePipeline:
def open_spider(self, spider):
loop = asyncio.get_event_loop()
return Deferred.fromFuture(loop.create_task(self._open_spider(spider)))
return deferred_from_coro(self._open_spider(spider))
def process_item(self, item, spider):
return {"url": item["url"].upper()}
class UrlSpider(scrapy.Spider):
class UrlSpider(Spider):
name = "url_spider"
start_urls = ["data:,"]
custom_settings = {