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

Merge branch 'send_done_to_db_container' into 'master'

[executor] Send done to db if connected

See merge request !20
parents 4f08e817 32b1681d
No related branches found
No related tags found
1 merge request!20[executor] Send done to db if connected
Pipeline #23882 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