Merge pull request #9 from joshland/master

Patch: fix async for 3.7, running without async masks exceptions.
trallard · May 2, 2019 · 83380d8 · 83380d8
2 parents d8771a8 + 6c77569
commit 83380d8
Show file tree

Hide file tree

Showing 2 changed files with 30 additions and 4 deletions.
diff --git a/solutions/etl-basic/stream_twitter.py b/solutions/etl-basic/stream_twitter.py
@@ -5,6 +5,7 @@
 # ------------------------------------------------------------------
 
 # Import libraries needed
+import sys
 import json
 import time
 from configparser import ConfigParser
@@ -203,7 +204,6 @@ def start_stream(stream, **kwargs):
 
 
 if __name__ == "__main__":
-
     create_table(DATABASE, "tweets")
     # first we need to authenticate
     twitter = connectTwitter()
@@ -213,6 +213,18 @@ def start_stream(stream, **kwargs):
     myStream = tweepy.Stream(auth=twitter.auth, listener=myStreamListener, timeout=30)
 
     # stream tweets using the filter method
-    start_stream(myStream, track=["python", "pycon", "jupyter", "#pycon2019"], async=True)
-
+    version = float(f"{sys.version_info[0]}.{sys.version_info[1]}")
+    if version >= 3.7:
+        kwargs = {
+            'track': ["python", "pycon", "jupyter", "#pycon2019"],
+            'is_async': True
+        }
+    else:
+        kwargs = {
+            'track': ["python", "pycon", "jupyter", "#pycon2019"],
+            'async': True
+        }
+        pass
+    start_stream(myStream, **kwargs)
+    pass
 
diff --git a/solutions/etl-basic/stream_twitter_alt.py b/solutions/etl-basic/stream_twitter_alt.py
@@ -5,6 +5,7 @@
 # ------------------------------------------------------------------
 
 # Import libraries needed
+import sys
 import json
 import time
 from configparser import ConfigParser
@@ -255,4 +256,17 @@ def start_stream(stream, **kwargs):
     myStream = tweepy.Stream(auth=twitter.auth, listener=myStreamListener, timeout=30)
 
     # stream tweets using the filter method
-    start_stream(myStream, track=["python", "pycon", "jupyter", "#pycon2019"], async=True)
+    version = float(f"{sys.version_info[0]}.{sys.version_info[1]}")
+    if version >= 3.7:
+        kwargs = {
+            'track': ["python", "pycon", "jupyter", "#pycon2019"],
+            'is_async': True
+        }
+    else:
+        kwargs = {
+            'track': ["python", "pycon", "jupyter", "#pycon2019"],
+            'async': True
+        }
+        pass
+    start_stream(myStream, **kwargs)
+    pass