From abadf395960d72b95634b3a07a1d3e504a9e3831 Mon Sep 17 00:00:00 2001 From: Gonzalo Zigaran Date: Sun, 19 Apr 2020 19:36:29 -0300 Subject: [PATCH 1/2] tweepy 3.7 support --- twitter_monitor/stream.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/twitter_monitor/stream.py b/twitter_monitor/stream.py index 7886b59..e6eefa4 100644 --- a/twitter_monitor/stream.py +++ b/twitter_monitor/stream.py @@ -114,10 +114,10 @@ def start_stream(self): logger.info(" %s", repr(tracking_terms)) # Launch it in a new thread - self.stream.filter(track=tracking_terms, async=True, languages=self.languages) + self.stream.filter(track=tracking_terms, is_async=True, languages=self.languages) else: logger.info("Starting new unfiltered stream") - self.stream.sample(async=True, languages=self.languages) + self.stream.sample(is_async=True, languages=self.languages) def stop_stream(self): """ From 36c73c011a5e4ac57d17752b57c42c76257835b8 Mon Sep 17 00:00:00 2001 From: Gonzalo Zigaran Date: Sun, 19 Apr 2020 19:43:37 -0300 Subject: [PATCH 2/2] tweepy 3.7 support for tests --- setup.py | 2 +- tests/test_stream.py | 6 +++--- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/setup.py b/setup.py index 468dd8b..53f5034 100644 --- a/setup.py +++ b/setup.py @@ -29,7 +29,7 @@ ], install_requires=[ - "tweepy >= 3.0" + "tweepy >= 3.7" ], test_suite="tests", tests_require=["mock == 1.0.1"], diff --git a/tests/test_stream.py b/tests/test_stream.py index 7b7904e..944e8e9 100644 --- a/tests/test_stream.py +++ b/tests/test_stream.py @@ -72,7 +72,7 @@ def test_start_unfiltered_no_terms(self): retry_count=self.retry_count) # It should be using the sample endpoint - self.tweepy_stream_instance.sample.assert_called_once_with(async=True, languages=None) + self.tweepy_stream_instance.sample.assert_called_once_with(is_async=True, languages=None) def test_start_with_languages(self): @@ -89,7 +89,7 @@ def test_start_with_languages(self): self.stream.start_stream() # It should be using the sample endpoint with languages - self.tweepy_stream_instance.sample.assert_called_once_with(async=True, languages=languages) + self.tweepy_stream_instance.sample.assert_called_once_with(is_async=True, languages=languages) def test_start_stream_with_terms(self): @@ -107,7 +107,7 @@ def test_start_stream_with_terms(self): timeout=90, retry_count=self.retry_count) # Should start the filter with the terms - self.tweepy_stream_instance.filter.assert_called_once_with(track=self.term_list, async=True, languages=None) + self.tweepy_stream_instance.filter.assert_called_once_with(track=self.term_list, is_async=True, languages=None) def test_stop_stream_not_started(self):