code: def _func_fit(m, dfs, M, N, partsToRanks, rank, _transform):
      return m.fit(dfs, M, N, partsToRanks, rank, _transform)
  
file_path: cuml/python/cuml/dask/decomposition/base.py
imports: from cuml.dask.common import raise_exception_from_futures
  from raft_dask.common.comms import get_raft_comm_state
  from raft_dask.common.comms import Comms
  from cuml.dask.common.input_utils import to_output
  from cuml.dask.common import parts_to_ranks
  from cuml.dask.common.part_utils import flatten_grouped_results
  from dask.distributed import wait, get_worker
  from cuml.dask.common.base import BaseEstimator
  from cuml.dask.common.input_utils import DistributedDataHandler
label_desc: Use image node_id 1 for calling the DecompositionSyncFitMixin obj's underlying member method code with example usage: obj._func_fit(m, dfs, M, N, partsToRanks, rank, _transform) and returns: m