(f)
return wrapped
Ensures Django discards any broken database connections

    Django normally cleans up connections once a web request has
    been processed. However, here we are not serving web requests
    and are outside of Django's request handling logic. We therefore
    need to make sure we cleanup any broken database connections.
Ensures Django discards any broken database connections
Ensures Django discards any broken database connections
def uses_django_db(f):
    """Ensures Django discards any broken database connections

    Django normally cleans up connections once a web request has
    been processed. However, here we are not serving web requests
    and are outside of Django's request handling logic. We therefore
    need to make sure we cleanup any broken database connections.
    """
    # TODO: Move this into middleware
    #       (Tracked in: https://github.com/adamcharnock/lightbus/issues/6)

    # Import Django locally as it is not a dependency of Lightbus.
    # This will only get run on startup anyway, and we will assume that
    # if someone uses this decorator then they have Django installed.
    from django.db import reset_queries, close_old_connections

    @wraps(f)
    def wrapped(*args, **kwargs):
        reset_queries()
        close_old_connections()

        try:
            return f(*args, **kwargs)
        finally:
            close_old_connections()

    return wrapped
def uses_django_db ( f ) : # TODO: Move this into middleware #       (Tracked in: https://github.com/adamcharnock/lightbus/issues/6) # Import Django locally as it is not a dependency of Lightbus. # This will only get run on startup anyway, and we will assume that # if someone uses this decorator then they have Django installed. from django . db import reset_queries , close_old_connections @ wraps ( f ) def wrapped ( * args , * * kwargs ) : reset_queries ( ) close_old_connections ( ) try : return f ( * args , * * kwargs ) finally : close_old_connections ( ) return wrapped