changed module fucntion name to align with filename

examples/digital_fingerprinting/production/morpheus/dfp/modules/dfp_data_prep.py

@@ -31,9 +31,9 @@
 
 
 @register_module(DFP_DATA_PREP, MODULE_NAMESPACE)
-def dfp_preprocessing(builder: mrc.Builder):
+def dfp_data_prep(builder: mrc.Builder):
     """
-    Preprocessed data are produced by this module function for either inference or model training.
+    This module function prepares data for either inference or model training.
 
     Parameters
     ----------

examples/digital_fingerprinting/production/morpheus/dfp/modules/dfp_preprocessing.py

@@ -23,7 +23,7 @@
 import morpheus.modules.file_batcher  # noqa: F401
 import morpheus.modules.file_to_df  # noqa: F401
 from morpheus.utils.module_ids import FILE_BATCHER
-from morpheus.utils.module_ids import FILE_TO_DATAFRAME
+from morpheus.utils.module_ids import FILE_TO_DF
 from morpheus.utils.module_ids import MODULE_NAMESPACE
 from morpheus.utils.module_utils import get_module_config
 from morpheus.utils.module_utils import load_module
@@ -38,7 +38,7 @@
 
 
 @register_module(DFP_PREPROCESSING, MODULE_NAMESPACE)
-def dfp_pipeline_preprocessing(builder: mrc.Builder):
+def dfp_preprocessing(builder: mrc.Builder):
     """
     This module function allows for the consolidation of multiple dfp pipeline preprocessing modules
     into a single module.
@@ -52,7 +52,7 @@ def dfp_pipeline_preprocessing(builder: mrc.Builder):
     config = get_module_config(DFP_PREPROCESSING, builder)
 
     file_batcher_conf = config.get(FILE_BATCHER, None)
-    file_to_df_conf = config.get(FILE_TO_DATAFRAME, None)
+    file_to_df_conf = config.get(FILE_TO_DF, None)
     dfp_split_users_conf = config.get(DFP_SPLIT_USERS, None)
     dfp_rolling_window_conf = config.get(DFP_ROLLING_WINDOW, None)
     dfp_data_prep_conf = config.get(DFP_DATA_PREP, None)

examples/digital_fingerprinting/production/morpheus/dfp_azure_modules_pipeline.py

@@ -59,7 +59,7 @@
 from morpheus.utils.logger import get_log_levels
 from morpheus.utils.logger import parse_log_level
 from morpheus.utils.module_ids import FILE_BATCHER
-from morpheus.utils.module_ids import FILE_TO_DATAFRAME
+from morpheus.utils.module_ids import FILE_TO_DF
 from morpheus.utils.module_ids import MLFLOW_MODEL_WRITER
 from morpheus.utils.module_ids import MODULE_NAMESPACE
 
@@ -261,9 +261,9 @@ def run_pipeline(train_users,
             "end_time": end_time,
             "iso_date_regex_pattern": iso_date_regex_pattern
         },
-        FILE_TO_DATAFRAME: {
-            "module_id": FILE_TO_DATAFRAME,
-            "module_name": "file_to_dataframe",
+        FILE_TO_DF: {
+            "module_id": FILE_TO_DF,
+            "module_name": "FILE_TO_DF",
             "namespace": MODULE_NAMESPACE,
             "timestamp_column_name": config.ae.timestamp_column_name,
             "userid_column_name": config.ae.userid_column_name,

examples/digital_fingerprinting/production/morpheus/dfp_duo_modules_pipeline.py

@@ -60,7 +60,7 @@
 from morpheus.utils.logger import get_log_levels
 from morpheus.utils.logger import parse_log_level
 from morpheus.utils.module_ids import FILE_BATCHER
-from morpheus.utils.module_ids import FILE_TO_DATAFRAME
+from morpheus.utils.module_ids import FILE_TO_DF
 from morpheus.utils.module_ids import MLFLOW_MODEL_WRITER
 from morpheus.utils.module_ids import MODULE_NAMESPACE
 
@@ -259,9 +259,9 @@ def run_pipeline(train_users,
             "end_time": end_time,
             "iso_date_regex_pattern": iso_date_regex_pattern
         },
-        FILE_TO_DATAFRAME: {
-            "module_id": FILE_TO_DATAFRAME,
-            "module_name": "file_to_dataframe",
+        FILE_TO_DF: {
+            "module_id": FILE_TO_DF,
+            "module_name": "FILE_TO_DF",
             "namespace": MODULE_NAMESPACE,
             "timestamp_column_name": config.ae.timestamp_column_name,
             "userid_column_name": config.ae.userid_column_name,

morpheus/modules/file_to_df.py

@@ -34,16 +34,16 @@
 from morpheus.cli.utils import str_to_file_type
 from morpheus.io.deserializers import read_file_to_df
 from morpheus.utils.column_info import process_dataframe
-from morpheus.utils.module_ids import FILE_TO_DATAFRAME
+from morpheus.utils.module_ids import FILE_TO_DF
 from morpheus.utils.module_ids import MODULE_NAMESPACE
 from morpheus.utils.module_utils import get_module_config
 from morpheus.utils.module_utils import register_module
 
 logger = logging.getLogger(__name__)
 
 
-@register_module(FILE_TO_DATAFRAME, MODULE_NAMESPACE)
-def file_to_dataframe(builder: mrc.Builder):
+@register_module(FILE_TO_DF, MODULE_NAMESPACE)
+def file_to_df(builder: mrc.Builder):
     """
     This module reads data from the batched files into a dataframe after receiving input from the "FileBatcher" module.
     In addition to loading data from the disk, it has ability to load the file content from S3 buckets.
@@ -54,7 +54,7 @@ def file_to_dataframe(builder: mrc.Builder):
         mrc Builder object.
     """
 
-    config = get_module_config(FILE_TO_DATAFRAME, builder)
+    config = get_module_config(FILE_TO_DF, builder)
 
     schema_config = config.get("schema", None)
     schema_str = schema_config.get("schema_str", None)
@@ -254,7 +254,7 @@ def node_fn(obs: mrc.Observable, sub: mrc.Subscriber):
     if (download_method.startswith("dask")):
         dask_cluster = get_dask_cluster()
 
-    node = builder.make_node_full(FILE_TO_DATAFRAME, node_fn)
+    node = builder.make_node_full(FILE_TO_DF, node_fn)
 
     # Register input and output port for a module.
     builder.register_module_input("input", node)

morpheus/modules/mlflow_model_writer.py

@@ -44,7 +44,7 @@
 
 
 @register_module(MLFLOW_MODEL_WRITER, MODULE_NAMESPACE)
-def module_init(builder: mrc.Builder):
+def mlflow_model_writer(builder: mrc.Builder):
     """
     This module uploads trained models to the mlflow server.
 

morpheus/utils/module_ids.py

@@ -15,5 +15,5 @@
 MODULE_NAMESPACE = "morpheus_modules"
 
 FILE_BATCHER = "FileBatcher"
-FILE_TO_DATAFRAME = "FileToDataFrame"
+FILE_TO_DF = "FileToDataFrame"
 MLFLOW_MODEL_WRITER = "MLFlowModelWriter"