def METHOD_NAME(celery_app):
    """
    Close outbound connections and remove custom celery_app state.
    This is executed inside each forked worker process.
    """
    celery_app.db.close()
    del celery_app.db
    del celery_app.raven_client
    celery_app.redis_client.close()
    del celery_app.redis_client
    celery_app.geoip_db.close()
    del celery_app.geoip_db
    del celery_app.all_queues
    del celery_app.data_queues