code: def test_ingestion_manager_run_multi_process_with_multi_thread_success(
      fs_runtime_client_config_mock,
  ):
      df = pd.DataFrame({"float": pd.Series([2.0], dtype="float64")})
      manager = IngestionManagerPandas(
          feature_group_name="MyGroup",
          sagemaker_session=sagemaker_session_mock,
          sagemaker_fs_runtime_client_config=fs_runtime_client_config_mock,
          max_workers=2,
          max_processes=2,
      )
      manager.run(df)
  
imports: from __future__ import absolute_import
  import pandas
  import pytest
  from mock import Mock, patch, MagicMock
  from botocore.exceptions import ProfileNotFound
  from sagemaker.feature_store.feature_definition import FractionalFeatureDefinition, IntegralFeatureDefinition, StringFeatureDefinition, FeatureTypeEnum, VectorCollectionType, SetCollectionType, ListCollectionType
  from sagemaker.feature_store.feature_group import FeatureGroup, IngestionManagerPandas, AthenaQuery, IngestionError
  from sagemaker.feature_store.inputs import FeatureParameter, DeletionModeEnum, TtlDuration, OnlineStoreConfigUpdate, OnlineStoreStorageTypeEnum
  from tests.unit import SAGEMAKER_CONFIG_FEATURE_GROUP
label_desc: Use image node_id 38 for calling a global function with example usage: test_ingestion_manager_run_multi_process_with_multi_thread_success(fs_runtime_client_config_mock) without return types