Celery. Reduce risk of idle connections by closing connections.

celery.py

from celery import Celery
from celery.signals import worker_shutdown, task_postrun
from django.db import connections

app = Celery()


...


@worker_shutdown.connect
def close_db_connections(sender, **kwargs):
    for conn in connections.all(initialized_only=True):
        conn.close()


@task_postrun.connect
def close_db_connections_after_task_completed(sender, **kwargs):
    for conn in connections.all(initialized_only=True):
        conn.close()


# This is will be call on Forced Stops
def handle_sigterm(signum, frame):
    for conn in connections.all(initialized_only=True):
        conn.close()


signal.signal(signal.SIGTERM, handle_sigterm)