##// END OF EJS Templates
appenlight
RSS

Clone from https://github.com/Appenlight/appenlight.git

delete-by-query: test the non-routing version of the code, turns out one of the slaves didn't have the plugin installed that was the real issue probably
ergo -
Show More
Show file before | Show file after | Hide comments
@@ -254,8 +254,10 b' def after_update(mapper, connection, target):'
254
254
255 def after_delete(mapper, connection, target):
255 def after_delete(mapper, connection, target):
256 query = {'term': {'group_id': target.id}}
256 query = {'term': {'group_id': target.id}}
257 Datastores.es.delete_by_query(target.partition_id, 'report', query,
257 # TODO: routing seems unnecessary, need to test a bit more
258 query_params={'routing':str(target.id)})
258 #Datastores.es.delete_by_query(target.partition_id, 'report', query,
259 # query_params={'routing':str(target.id)})
260 Datastores.es.delete_by_query(target.partition_id, 'report', query)
259 query = {'term': {'pg_id': target.id}}
261 query = {'term': {'pg_id': target.id}}
260 Datastores.es.delete_by_query(target.partition_id, 'report_group', query)
262 Datastores.es.delete_by_query(target.partition_id, 'report_group', query)
261
263
General Comments 0
You need to be logged in to leave comments. Login now