fix comments

examples/digital_fingerprinting/production/morpheus/dfp/messages/dfp_message_meta.py

@@ -40,9 +40,3 @@ class DFPMessageMeta(MessageMeta, cpp_class=None):
     def __init__(self, df: pd.DataFrame, user_id: str) -> None:
         super().__init__(df)
         self.user_id = user_id
-
-    def get_df(self):
-        return self.df
-
-    def set_df(self, df):
-        self._df = df

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

@@ -99,7 +99,6 @@ def get_user_cache(user_id: str):
     def try_build_window(message: MessageMeta, user_id: str) -> typing.Union[MessageMeta, None]:
         with get_user_cache(user_id) as user_cache:
 
-            # incoming_df = message.get_df()
             with message.mutable_dataframe() as dfm:
                 incoming_df = dfm.to_pandas()
 

examples/digital_fingerprinting/production/morpheus/dfp/stages/dfp_postprocessing_stage.py

@@ -63,9 +63,6 @@ def _process_events(self, message: ControlMessage):
         with message.payload().mutable_dataframe() as df:
             df['event_time'] = datetime.now().strftime('%Y-%m-%dT%H:%M:%SZ')
 
-            # cudf does not support replacing values with different types
-            # df.replace(np.nan, 'NaN', regex=False, inplace=True)
-
     def on_data(self, message: ControlMessage):
         """Process a message."""
         if (not message or message.payload().count == 0):

examples/digital_fingerprinting/production/morpheus/dfp/stages/dfp_preprocessing_stage.py

@@ -63,7 +63,7 @@ def process_features(self, message: ControlMessage):
         start_time = time.time()
 
         # Process the columns
-        df_processed = process_dataframe(message.payload().df, self._input_schema)
+        df_processed = process_dataframe(message.payload().get_data(), self._input_schema)
 
         # Apply the new dataframe, only the rows in the offset
         with message.payload().mutable_dataframe() as df:

examples/digital_fingerprinting/production/morpheus/dfp/stages/dfp_rolling_window_stage.py

@@ -122,7 +122,7 @@ def _build_window(self, message: DFPMessageMeta) -> ControlMessage:
 
         with self._get_user_cache(user_id) as user_cache:
 
-            incoming_df = message.get_df()
+            incoming_df = message.get_data()
             # existing_df = user_cache.df
 
             if (not user_cache.append_dataframe(incoming_df=incoming_df)):