mirror of
https://github.com/wassname/catalyst.git
synced 2026-07-13 17:42:42 +08:00
Minor fix, lots of win.
This commit is contained in:
@@ -29,7 +29,7 @@ log = logbook.Logger('Component')
|
||||
from zipline.exceptions import ComponentNoInit
|
||||
from zipline.transitions import WorkflowMeta
|
||||
|
||||
# LOGBOOK - embed PID in log output
|
||||
log = logbook.Logger('Base')
|
||||
|
||||
class Component(object):
|
||||
|
||||
@@ -219,6 +219,7 @@ class Component(object):
|
||||
|
||||
self.loop()
|
||||
self.shutdown()
|
||||
log.info("Shutdown %r" % self)
|
||||
|
||||
self.stop_tic = time.time()
|
||||
|
||||
|
||||
@@ -631,11 +631,11 @@ class Controller(object):
|
||||
|
||||
self.alive = False
|
||||
|
||||
if hard:
|
||||
if hard and not self.devel:
|
||||
self.state = CONTROL_STATES.TERMINATE
|
||||
log.info('Hard Shutdown')
|
||||
|
||||
if soft:
|
||||
if soft and not self.devel:
|
||||
self.state = CONTROL_STATES.TERMINATE
|
||||
log.info('Soft Shutdown')
|
||||
self.send_softkill()
|
||||
|
||||
@@ -392,7 +392,6 @@ class SimulatedTrading(object):
|
||||
#print 'Waiting on %r' % thread
|
||||
thread.join()
|
||||
else:
|
||||
self.controller_process.join()
|
||||
for process in self.sim.subprocesses:
|
||||
process.join()
|
||||
|
||||
|
||||
Reference in New Issue
Block a user