Fix AsyncStream.task assignment
authorHarmon <Harmon758@gmail.com>
Mon, 11 Jan 2021 16:00:38 +0000 (10:00 -0600)
committerHarmon <Harmon758@gmail.com>
Mon, 11 Jan 2021 16:01:45 +0000 (10:01 -0600)
tweepy/asynchronous/streaming.py

index 225b8f64f0ba380d9cb7138d227afa411d0333db..39b391332a0e142cea3e31d4c5a597fd97341ddd 100644 (file)
@@ -192,7 +192,7 @@ class AsyncStream:
         if stall_warnings:
             body["stall_warnings"] = "true"
 
-        self.task = await asyncio.create_task(
+        self.task = asyncio.create_task(
             self._connect("POST", endpoint, headers=headers, body=body or None)
         )
         return self.task
@@ -221,7 +221,7 @@ class AsyncStream:
         if stall_warnings:
             params["stall_warnings"] = "true"
 
-        self.task = await asyncio.create_task(
+        self.task = asyncio.create_task(
             self._connect("GET", endpoint, params=params)
         )
         return self.task