code: def reconst_flow_core(flow):
      with TemporaryDirectory() as out_dir:
          data_path, bval_path, bvec_path = get_fnames("small_64D")
          volume, affine = load_nifti(data_path)
          mask = np.ones_like(volume[:, :, :, 0])
          mask_path = pjoin(out_dir, "tmp_mask.nii.gz")
          save_nifti(mask_path, mask.astype(np.uint8), affine)
  
          reconst_flow = flow()
          for sh_order in [
              8,
          ]:
              reconst_flow.run(
                  data_path,
                  bval_path,
                  bvec_path,
                  mask_path,
                  sh_order=sh_order,
                  out_dir=out_dir,
                  extract_pam_values=True,
              )
  
file_path: dipy/dipy/workflows/tests/test_reconst_rumba.py
imports: import logging
  from os.path import join
  from tempfile import TemporaryDirectory
  import warnings
  import numpy
  from dipy.data import get_fnames
  from dipy.io.image import load_nifti, save_nifti
  from dipy.workflows.reconst import ReconstRUMBAFlow
  from dipy.reconst.shm import descoteaux07_legacy_msg
label_desc: Use image node_id 2 for calling a global function with example usage: reconst_flow_core(flow) without return types