diff --git a/ml/digest-score/auth.py b/ml/digest-score/auth.py
index 7dbfcf5ca..d4876bb0d 100644
--- a/ml/digest-score/auth.py
+++ b/ml/digest-score/auth.py
@@ -2,10 +2,23 @@ import os
 import jwt
 from flask import request, jsonify
 from functools import wraps
+from datetime import datetime, timedelta
+
 
 SECRET_KEY = os.getenv('JWT_SECRET')
 ADMIN_SECRET_KEY = os.getenv('JWT_ADMIN_SECRET_KEY')
 
+def generate_admin_token():
+  expiration_time = datetime.utcnow() + timedelta(minutes=5)
+  payload = {
+      'role': 'admin',
+      'exp': expiration_time
+  }
+
+  token = jwt.encode(payload, ADMIN_SECRET_KEY, algorithm="HS256")
+  return token
+
+
 def user_token_required(f):
     @wraps(f)
     def decorated(*args, **kwargs):
diff --git a/ml/digest-score/features.py b/ml/digest-score/features.py
index 21d961ed6..32e6af60c 100644
--- a/ml/digest-score/features.py
+++ b/ml/digest-score/features.py
@@ -17,10 +17,15 @@ from features.extract import extract_and_upload_raw_data
 from features.user_history import generate_and_upload_user_history
 
 from datetime import datetime, timezone
+from auth import generate_admin_token
+
 
 def call_refresh_api(api):
+  headers = {
+    'Authorization': f'Bearer {generate_admin_token()}'
+  }
   try:
-    response = requests.get(api, timeout=10)
+    response = requests.get(api, headers=headers, timeout=10)
     if response.status_code == 200:
         print("scoring service refreshed")
     else: