Commit 91aa07b3 authored by Amir MOHAMMADI's avatar Amir MOHAMMADI

Machines are not thread safe?

parent d8eb5517
Pipeline #29923 passed with stage
in 12 minutes and 11 seconds
......@@ -124,7 +124,7 @@ def train(trainer, machine, data, max_iterations=50, convergence_threshold=None,
# create trainers for each process
trainers = [trainer.__class__(trainer) for p in range(n_processes)]
# no need to copy the machines
machines = [machine for p in range(n_processes)]
machines = [machine.__class__(machine) for p in range(n_processes)]
# call the parallel processes
pool.map(_parallel_e_step, zip(trainers, machines, split_data))
# update the trainer with the data of the other trainers
......
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