Skip to content
Snippets Groups Projects
Commit 32b1681d authored by Samuel GAIST's avatar Samuel GAIST
Browse files

[executor] Send done to db if connected

parent 4f08e817
No related branches found
No related tags found
1 merge request!20[executor] Send done to db if connected
Pipeline #23850 passed
......@@ -218,6 +218,14 @@ class Executor(object):
def done(self, statistics):
"""Indicates the infrastructure the execution is done"""
if self.db_socket:
logger.debug('send to db: (don) done')
self.db_socket.send_string('don', zmq.SNDMORE)
self.db_socket.send_string(simplejson.dumps(statistics))
answer = self.db_socket.recv() # ack
logger.debug('recv from db: %s', answer)
logger.debug('send: (don) done')
self.socket.send_string('don', zmq.SNDMORE)
self.socket.send_string(simplejson.dumps(statistics))
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment