diff --git a/docker/kafka/neo4j-consumer/consumer.py b/docker/kafka/neo4j-consumer/consumer.py index bff39119eecc6ff78b439bdffe9c0f651c048a0e..852ae7bfc91d3b5c2fa124cc5c0e2c0956738256 100644 --- a/docker/kafka/neo4j-consumer/consumer.py +++ b/docker/kafka/neo4j-consumer/consumer.py @@ -87,13 +87,13 @@ def store_message(db_driver, key, value): except KeyError: logging.error('Catching errors currently not implemented') elif key in ['DELETE']: - try: - result = db_session.run('MATCH (o:Object {name: {oname}})' - 'DETACH DELETE o', - {'oname': value[u'Object']}) - logging.info('Ran %s', result.statement) - except KeyError: - logging.error('Catching errors currently not implemented') + try: + result = db_session.run('MATCH (o:Object {name: {oname}})' + 'DETACH DELETE o', + {'oname': value[u'Object']}) + logging.info('Ran %s', result.statement) + except KeyError: + logging.error('Catching errors currently not implemented') else: logging.info('Unsupported method %s', key) db_session.close()