def run_changed(drain=False, min_size=500, limit=1000, sleep_time=10, use_safe_get=False, verbose=False):
 if use_safe_get:
  CloudSearchUploader.use_safe_get = True
 amqp.handle_items('cloudsearch_changes', _run_changed, min_size=min_size, limit=limit, drain=drain, sleep_time=sleep_time, verbose=verbose)

def run_changed ( drain = False , min_size = 500 , limit = 1000 , sleep_time = 10 , use_safe_get = False , verbose = False ) : if use_safe_get : CloudSearchUploader . use_safe_get = True amqp . handle_items ( 'cloudsearch_changes' , _run_changed , min_size = min_size , limit = limit , drain = drain , sleep_time = sleep_time , verbose = verbose )
run by cron on a schedule to send things to amazon cloudsearch .