finish removing nvtabular related code

cwharris · Sep 9, 2024 · 769eba1 · 769eba1
1 parent 74402cf
commit 769eba1
Show file tree

Hide file tree

Showing 3 changed files with 0 additions and 3 deletions.
diff --git a/morpheus/utils/downloader.py b/morpheus/utils/downloader.py
@@ -66,7 +66,6 @@ def __init__(self,
                  download_method: typing.Union[DownloadMethods, str] = DownloadMethods.DASK_THREAD,
                  dask_heartbeat_interval: str = "30s"):
 
-        self._merlin_distributed = None
         self._dask_heartbeat_interval = dask_heartbeat_interval
 
         download_method = os.environ.get("MORPHEUS_FILE_DOWNLOAD_TYPE", download_method)

diff --git a/tests/examples/digital_fingerprinting/test_dfp_file_to_df.py b/tests/examples/digital_fingerprinting/test_dfp_file_to_df.py
@@ -110,7 +110,6 @@ def test_constructor(config: Config):
 @mock.patch('morpheus.utils.downloader.Distributed')
 @mock.patch('morpheus.controllers.file_to_df_controller.process_dataframe')
 def test_get_or_create_dataframe_from_batch_cache_miss(mock_proc_df: mock.MagicMock,
-                                                       mock_distributed: mock.MagicMock,
                                                        mock_obf_to_df: mock.MagicMock,
                                                        mock_dask_cluster: mock.MagicMock,
                                                        mock_dask_client: mock.MagicMock,

diff --git a/tests/test_column_info.py b/tests/test_column_info.py
@@ -35,7 +35,6 @@
 from morpheus.utils.column_info import RenameColumn
 from morpheus.utils.column_info import StringCatColumn
 from morpheus.utils.column_info import StringJoinColumn
-from morpheus.utils.nvt.schema_converters import create_and_attach_nvt_workflow
 from morpheus.utils.schema_transforms import process_dataframe