Commit 8d557de8 authored by Yuxin Wu's avatar Yuxin Wu

fix staging callback blocking bug

parent 9ee5050e
...@@ -411,6 +411,7 @@ class StagingInputWrapper(FeedfreeInput): ...@@ -411,6 +411,7 @@ class StagingInputWrapper(FeedfreeInput):
def _before_train(self): def _before_train(self):
# pre-fill the staging area # pre-fill the staging area
logger.info("Pre-fillilng staging area ...")
for k in range(self.nr_stage): for k in range(self.nr_stage):
self.stage_op.run() self.stage_op.run()
......
...@@ -114,8 +114,7 @@ class Trainer(object): ...@@ -114,8 +114,7 @@ class Trainer(object):
""" """
input_source.setup(self.model.get_inputs_desc()) input_source.setup(self.model.get_inputs_desc())
cbs = input_source.get_callbacks() cbs = input_source.get_callbacks()
for cb in cbs: self.config.callbacks.extend(cbs)
self.register_callback(cb)
def setup(self): def setup(self):
""" """
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment