From 6db76ed445733846743b147762aeed3b5542b769 Mon Sep 17 00:00:00 2001 From: Lord_dubious Date: Mon, 28 Apr 2025 14:32:39 +0100 Subject: [PATCH] Fix: prevent KeyError when removing 'content-type' header in media upload scheduling --- twikit/client/client.py | 14 ++++---------- 1 file changed, 4 insertions(+), 10 deletions(-) diff --git a/twikit/client/client.py b/twikit/client/client.py index 053f0087..948f5f68 100644 --- a/twikit/client/client.py +++ b/twikit/client/client.py @@ -2371,7 +2371,7 @@ async def edit_bookmark_folder( Returns ------- - :class:`BookmarkFolder` + :class:`BookmarkFolder` Updated bookmark folder. Examples @@ -3580,12 +3580,6 @@ async def get_list_tweets( ... >>> more_tweets = await tweets.next() # Retrieve more tweets - >>> for tweet in more_tweets: - ... print(tweet) - - - ... - ... """ response, _ = await self.gql.list_latest_tweets_timeline(list_id, count, cursor) @@ -4213,7 +4207,7 @@ async def _stream(self, topics: set[str]) -> AsyncGenerator[tuple[str, Payload]] url = f'https://api.{DOMAIN}/live_pipeline/events' params = {'topics': ','.join(topics)} headers = self._base_headers - headers.pop('content-type') + headers.pop('content-type', None) async with self.http.stream('GET', url, params=params, headers=headers, timeout=None) as response: self._remove_duplicate_ct0_cookie() @@ -4261,12 +4255,12 @@ async def get_streaming_session( ... user_id = payload.dm_update.user_id ... print(f'{conversation_id}: {user_id} sent a message') >>> - >>> if payload.dm_typing: + ... if payload.dm_typing: ... conversation_id = payload.dm_typing.conversation_id ... user_id = payload.dm_typing.user_id ... print(f'{conversation_id}: {user_id} is typing') >>> - >>> if payload.tweet_engagement: + ... if payload.tweet_engagement: ... like = payload.tweet_engagement.like_count ... retweet = payload.tweet_engagement.retweet_count ... view = payload.tweet_engagement.view_count