mirror of
https://github.com/wassname/catalyst.git
synced 2026-07-01 11:08:00 +08:00
Close the results socket to ensure messages are sent
This commit is contained in:
@@ -172,6 +172,8 @@ class SimulatedTrading(object):
|
||||
|
||||
def close(self):
|
||||
log.info("Closing Simulation: {id}".format(id=self.sim_id))
|
||||
if self.results_socket:
|
||||
self.results_socket.close()
|
||||
if self.proc and self.send_sighup:
|
||||
ppid = os.getppid()
|
||||
if self.success:
|
||||
|
||||
Reference in New Issue
Block a user