diff --git a/packages/discovery-provider/src/challenges/challenge_event_bus.py b/packages/discovery-provider/src/challenges/challenge_event_bus.py index f09f7371a2c..9ebbfd6e144 100644 --- a/packages/discovery-provider/src/challenges/challenge_event_bus.py +++ b/packages/discovery-provider/src/challenges/challenge_event_bus.py @@ -46,7 +46,6 @@ from src.challenges.tastemaker_challenge import tastemaker_challenge_manager from src.challenges.track_upload_challenge import track_upload_challenge_manager from src.challenges.trending_challenge import ( - trending_playlist_challenge_manager, trending_track_challenge_manager, trending_underground_track_challenge_manager, ) @@ -295,9 +294,6 @@ def setup_challenge_bus(): ChallengeEvent.trending_underground, trending_underground_track_challenge_manager, ) - bus.register_listener( - ChallengeEvent.trending_playlist, trending_playlist_challenge_manager - ) bus.register_listener(ChallengeEvent.send_tip, send_first_tip_challenge_manager) bus.register_listener( ChallengeEvent.first_playlist, first_playlist_challenge_manager diff --git a/packages/discovery-provider/src/tasks/calculate_trending_challenges.py b/packages/discovery-provider/src/tasks/calculate_trending_challenges.py index b92f1ab94bc..b9bbeebdebe 100644 --- a/packages/discovery-provider/src/tasks/calculate_trending_challenges.py +++ b/packages/discovery-provider/src/tasks/calculate_trending_challenges.py @@ -9,10 +9,6 @@ from src.challenges.challenge_event import ChallengeEvent from src.challenges.challenge_event_bus import ChallengeEventBus from src.models.core.core_indexed_blocks import CoreIndexedBlocks -from src.queries.get_trending_playlists import ( - GetTrendingPlaylistsArgs, - _get_trending_playlists_with_session, -) from src.queries.get_trending_tracks import _get_trending_tracks_with_session from src.queries.get_underground_trending import ( GetUndergroundTrendingTrackArgs, @@ -170,37 +166,6 @@ def enqueue_trending_challenges( TrendingType.UNDERGROUND_TRACKS, ) - trending_playlist_versions = trending_strategy_factory.get_versions_for_type( - TrendingType.PLAYLISTS - ).keys() - for version in trending_playlist_versions: - strategy = trending_strategy_factory.get_strategy( - TrendingType.PLAYLISTS, version - ) - playlists_args: GetTrendingPlaylistsArgs = { - "limit": TRENDING_LIMIT, - "offset": 0, - "time": time_range, - } - trending_playlists = _get_trending_playlists_with_session( - session, playlists_args, strategy, False - ) - for idx, playlist in enumerate(trending_playlists): - challenge_bus.dispatch( - ChallengeEvent.trending_playlist, - latest_blocknumber, - latest_block_datetime, - playlist["playlist_owner_id"], - { - "id": playlist["playlist_id"], - "user_id": playlist["playlist_owner_id"], - "rank": idx + 1, - "type": str(TrendingType.PLAYLISTS), - "version": str(version), - "week": date_to_week(date), - }, - ) - update_end = time.time() update_total = update_end - update_start logger.debug(