code: def _create_model(sessionId, model_func, datatype, **kwargs):
      dask_worker = get_worker()
      handle = get_raft_comm_state(sessionId, dask_worker)["handle"]
      return model_func(handle, datatype, **kwargs)
  
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 3 for calling the DecompositionSyncFitMixin obj's underlying member method code with example usage: obj._create_model(sessionId, model_func, datatype) and returns: model_func