After you created pipeline with setting specified 'n_jobs' values in params and trying to fit it, next method self.replace_n_jobs_in_nodes(n_jobs) in pipeline.fit() always change n_jobs to 1.
self.replace_n_jobs_in_nodes(n_jobs) requires to avoid nodes parallelization while fedot's composing, but in case with pipeline "handed" constructed it should work correctly. One of the possible solution is to adding a check to composition stage or fitting pipeline from builder.
After you created pipeline with setting specified 'n_jobs' values in params and trying to fit it, next method
self.replace_n_jobs_in_nodes(n_jobs)
inpipeline.fit()
always changen_jobs
to 1.self.replace_n_jobs_in_nodes(n_jobs)
requires to avoid nodes parallelization while fedot's composing, but in case with pipeline "handed" constructed it should work correctly. One of the possible solution is to adding a check to composition stage or fitting pipeline from builder.To reproduce the error: