From 63c3c62305a8c9c52d02ff5524301b7d45eb5724 Mon Sep 17 00:00:00 2001
From: Andrey Rakhmatullin <wrar@wrar.name>
Date: Tue, 30 Jul 2019 19:45:56 +0500
Subject: [PATCH] Add utils.deferred_from_coro.

---
 scrapy/utils/defer.py | 22 ++++++++++++++++++++++
 1 file changed, 22 insertions(+)

diff --git a/scrapy/utils/defer.py b/scrapy/utils/defer.py
index c5916c21c..1f6a2584c 100644
--- a/scrapy/utils/defer.py
+++ b/scrapy/utils/defer.py
@@ -1,10 +1,14 @@
 """
 Helper functions for dealing with Twisted deferreds
 """
+import asyncio
+import asyncio.futures
+import inspect
 
 from twisted.internet import defer, reactor, task
 from twisted.python import failure
 
+from scrapy import asyncio_supported
 from scrapy.exceptions import IgnoreRequest
 
 
@@ -113,3 +117,21 @@ def iter_errback(iterable, errback, *a, **kw):
             break
         except Exception:
             errback(failure.Failure(), *a, **kw)
+
+
+def isfuture(o):
+    # workaround for Python before 3.5.3 not having asyncio.isfuture
+    if hasattr(asyncio, 'isfuture'):
+        return asyncio.isfuture(o)
+    return isinstance(o, asyncio.futures.Future)
+
+
+def deferred_from_coro(o):
+    """Converts a coroutine into a Deferred, or returns the object as is if it isn't a coroutine"""
+    if isinstance(o, defer.Deferred):
+        return o
+    if asyncio.iscoroutine(o) or isfuture(o) or inspect.isawaitable(o):
+        if not asyncio_supported:
+            raise TypeError('Using coroutines requires installing AsyncioSelectorReactor')
+        return defer.Deferred.fromFuture(asyncio.ensure_future(o))
+    return o