diff --git a/internal/db/queries.sql b/internal/db/queries.sql
index 4117aab..5b7e1b0 100644
--- a/internal/db/queries.sql
+++ b/internal/db/queries.sql
@@ -212,7 +212,7 @@ ORDER BY related.id DESC;
 
 -- name: GetJikanCache :one
 SELECT data FROM jikan_cache
-WHERE key = ? AND expires_at > CURRENT_TIMESTAMP LIMIT 1;
+WHERE key = ? AND datetime(expires_at) > CURRENT_TIMESTAMP LIMIT 1;
 
 -- name: GetJikanCacheStale :one
 SELECT data FROM jikan_cache
@@ -227,7 +227,7 @@ ON CONFLICT (key) DO UPDATE SET
     created_at = CURRENT_TIMESTAMP;
 
 -- name: DeleteExpiredJikanCache :exec
-DELETE FROM jikan_cache WHERE expires_at <= CURRENT_TIMESTAMP;
+DELETE FROM jikan_cache WHERE datetime(expires_at) <= CURRENT_TIMESTAMP;
 
 -- name: EnqueueAnimeFetchRetry :exec
 INSERT INTO anime_fetch_retry (anime_id, attempts, next_retry_at, last_error, updated_at)
diff --git a/internal/db/queries.sql.go b/internal/db/queries.sql.go
index f36957d..b64cfff 100644
--- a/internal/db/queries.sql.go
+++ b/internal/db/queries.sql.go
@@ -107,7 +107,7 @@ func (q *Queries) DeleteContinueWatchingEntry(ctx context.Context, arg DeleteCon
 }
 
 const deleteExpiredJikanCache = `-- name: DeleteExpiredJikanCache :exec
-DELETE FROM jikan_cache WHERE expires_at <= CURRENT_TIMESTAMP
+DELETE FROM jikan_cache WHERE datetime(expires_at) <= CURRENT_TIMESTAMP
 `
 
 func (q *Queries) DeleteExpiredJikanCache(ctx context.Context) error {
@@ -443,7 +443,7 @@ func (q *Queries) GetEpisodeProviderMapping(ctx context.Context, arg GetEpisodeP
 
 const getJikanCache = `-- name: GetJikanCache :one
 SELECT data FROM jikan_cache
-WHERE key = ? AND expires_at > CURRENT_TIMESTAMP LIMIT 1
+WHERE key = ? AND datetime(expires_at) > CURRENT_TIMESTAMP LIMIT 1
 `
 
 func (q *Queries) GetJikanCache(ctx context.Context, key string) (string, error) {