backend/invoke_worker/session.py

from django_thread import Thread
from time import sleep
from backend.module.utils import date_utils
import requests, environ
from core import settings

env = environ.Env()

class Delete(Thread):
    def run(self):
        while True: 
            try:
                requests.post(f'{settings.WORKER_SERVED_SCOPE}/worker/session/delete_outdated/', headers={"Worker-Token": env("WORKER_TOKEN")})
                print('[Worker] All expired sessions have been cleared successfully.')
                sleep(1.5 * 60 * 60)
            except Exception as e: 
                print(e) 
                sleep(10)

thread = Delete()
thread.daemon = True
thread.start()