Show More
@@ -255,7 +255,7 b' def after_update(mapper, connection, target):' | |||||
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 | Datastores.es.delete_by_query(target.partition_id, 'report', query, | |
258 |
|
|
258 | query_params={'routing':str(target.id)}) | |
259 | query = {'term': {'pg_id': target.id}} |
|
259 | query = {'term': {'pg_id': target.id}} | |
260 | Datastores.es.delete_by_query(target.partition_id, 'report_group', query) |
|
260 | Datastores.es.delete_by_query(target.partition_id, 'report_group', query) | |
261 |
|
261 |
General Comments 0
You need to be logged in to leave comments.
Login now