'Starts the TensorFlow main function on each node/executor (per cluster_spec) in a background thread on the driver.
DEPRECATED: use run() method instead of reserve/start.'

def start(self, map_fun, tf_args):

    logging.info('Starting    TensorFlow')
    def _start():
        self.nodeRDD.foreachPartition(TFSparkNode.start(map_fun, tf_args, self.cluster_info, self.defaultFS, self.working_dir, background=(self.input_mode == InputMode.SPARK)))
    t = threading.Thread(target=_start)
    t.start()
    time.sleep(5)
