diff --git a/internal/worker/subreddits.go b/internal/worker/subreddits.go
index 6701e67..42814b4 100644
--- a/internal/worker/subreddits.go
+++ b/internal/worker/subreddits.go
@@ -202,6 +202,7 @@ func (sc *subredditsConsumer) Consume(delivery rmq.Delivery) {
 			reddit.WithQuery("before", before),
 			reddit.WithQuery("limit", "100"),
 			reddit.WithQuery("show", "all"),
+			reddit.WithQuery("always_show_media", "1"),
 		)
 
 		if err != nil {
@@ -268,6 +269,7 @@ func (sc *subredditsConsumer) Consume(delivery rmq.Delivery) {
 			subreddit.Name,
 			reddit.WithQuery("limit", "100"),
 			reddit.WithQuery("show", "all"),
+			reddit.WithQuery("always_show_media", "1"),
 		)
 
 		if err != nil {
diff --git a/internal/worker/trending.go b/internal/worker/trending.go
index efdd0d8..04554c5 100644
--- a/internal/worker/trending.go
+++ b/internal/worker/trending.go
@@ -222,7 +222,7 @@ func (tc *trendingConsumer) Consume(delivery rmq.Delivery) {
 	i = rand.Intn(len(watchers))
 	watcher = watchers[i]
 	rac = tc.reddit.NewAuthenticatedClient(watcher.Account.AccountID, watcher.Account.RefreshToken, watcher.Account.AccessToken)
-	hps, err := tc.reddit.SubredditHot(tc, subreddit.Name, reddit.WithQuery("show", "all"))
+	hps, err := tc.reddit.SubredditHot(tc, subreddit.Name, reddit.WithQuery("show", "all"), reddit.WithQuery("always_show_media", "1"))
 	if err != nil {
 		tc.logger.Error("failed to fetch hot posts",
 			zap.Error(err),