def METHOD_NAME(*args, **kwargs):
    try:
        with transaction.atomic(using or router.db_for_write(Organization)):
            return func(*args, **kwargs)
    except (ProgrammingError, OperationalError):
        logging.exception("Failed processing signal %s", func.__name__)
        return