diff --git a/python/morpheus_dfp/morpheus_dfp/modules/dfp_preproc.py b/python/morpheus_dfp/morpheus_dfp/modules/dfp_preproc.py
index f5c3a6cefb..294f2b7605 100644
--- a/python/morpheus_dfp/morpheus_dfp/modules/dfp_preproc.py
+++ b/python/morpheus_dfp/morpheus_dfp/modules/dfp_preproc.py
@@ -20,7 +20,6 @@
 from morpheus.utils.loader_ids import FILE_TO_DF_LOADER
 from morpheus.utils.module_ids import DATA_LOADER
 from morpheus.utils.module_ids import FILE_BATCHER
-from morpheus.utils.module_ids import FILTER_CONTROL_MESSAGE
 from morpheus.utils.module_ids import MORPHEUS_MODULE_NAMESPACE
 from morpheus.utils.module_utils import merge_dictionaries
 from morpheus.utils.module_utils import register_module
@@ -104,9 +103,6 @@ def dfp_preproc(builder: mrc.Builder):
     file_to_df_monitor_default = {"description": f"FileToDF [{task_type}_pipe]"}
     file_to_df_monitor_conf = merge_dictionaries(monitor_options, file_to_df_monitor_default)
 
-    pre_filter_default = {}
-    pre_filter_conf = merge_dictionaries(pre_filter_options, pre_filter_default)
-
     # Double check on how 'batcher_config' is used in the file_batcher module.
     batching_opts_default = {
         "file_type": "JSON",