'Install monitor on all executors.'

def install_monitor(self, monitor):

    if (self.sym_gen is not None):
        raise NotImplementedError('Monitoring    is    not    implemented    for    bucketing')
    for train_exec in self.execgrp.train_execs:
        monitor.install(train_exec)
