From 788811bf6c5ca8e9d3378bbab9fa6ec14b4adf29 Mon Sep 17 00:00:00 2001 From: Manuel Cortez Date: Sat, 3 Jul 2021 14:04:14 -0500 Subject: [PATCH] Ensure a tweet is reduced when sent by streaming API --- src/sessions/twitter/session.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/sessions/twitter/session.py b/src/sessions/twitter/session.py index 9ecf1d3f..98448c02 100644 --- a/src/sessions/twitter/session.py +++ b/src/sessions/twitter/session.py @@ -405,9 +405,9 @@ class Session(base.baseSession): """ Returns an user object associated with an ID. id str: User identifier, provided by Twitter. returns a tweepy user object.""" - if hasattr(id, "id_str"): - log.error("Called get_user function by passing a full user id as a parameter.") - id = id.id_str +# if hasattr(id, "id_str"): +# log.error("Called get_user function by passing a full user id as a parameter.") +# id = id.id_str # Check if the user has been added to the list of deleted users previously. if id in self.deleted_users: log.debug("Returning user {} from the list of deleted users.".format(id)) @@ -548,7 +548,7 @@ class Session(base.baseSession): if num == 0: buffers_to_send.remove(buffer) # However, we have to do the "reduce and change" process here because the status we sent to the db is going to be a different object that the one sent to database. - reduced_status = reduce.reduce_tweet(status) + status = reduce.reduce_tweet(status) status = self.check_quoted_status(status) status = self.check_long_tweet(status) # Send it to the main controller object.