@task(name='geonode.tasks.email.send_queued_notifications', queue='email')
def send_queued_notifications(*args):
 try:
  from notification.engine import send_all
 except ImportError:
  return
 if ((not args) and getattr(settings, 'NOTIFICATION_LOCK_LOCATION', None)):
  send_all(settings.NOTIFICATION_LOCK_LOCATION)
 else:
  send_all(*args)

@ task ( name = 'geonode.tasks.email.send_queued_notifications' , queue = 'email' ) def send_queued_notifications ( * args ) : try : from notification . engine import send_all except ImportError : return if ( ( not args ) and getattr ( settings , 'NOTIFICATION_LOCK_LOCATION' , None ) ) : send_all ( settings . NOTIFICATION_LOCK_LOCATION ) else : send_all ( * args )
sends queued notifications .