diff --git a/python/morpheus/morpheus/stages/input/autoencoder_source_stage.py b/python/morpheus/morpheus/stages/input/autoencoder_source_stage.py index b0529c7164..6675b3eacd 100644 --- a/python/morpheus/morpheus/stages/input/autoencoder_source_stage.py +++ b/python/morpheus/morpheus/stages/input/autoencoder_source_stage.py @@ -12,7 +12,6 @@ # See the License for the specific language governing permissions and # limitations under the License. -import logging import os import typing from abc import abstractmethod @@ -30,8 +29,6 @@ from morpheus.pipeline.stage_schema import StageSchema from morpheus.utils.directory_watcher import DirectoryWatcher -logger = logging.getLogger(__name__) - class AutoencoderSourceStage(PreallocatorMixin, SingleOutputSource): """ @@ -204,12 +201,6 @@ def batch_user_split(x: typing.List[pd.DataFrame], combined_df.index.name = saved_index_name - logger.debug( - "CloudTrail loading complete. Total rows: %d. Timespan: %s", - len(combined_df), - str(combined_df.loc[combined_df.index[-1], datetime_column_name] - - combined_df.loc[combined_df.index[0], datetime_column_name])) - # Get the users in this DF unique_users = combined_df[userid_column_name].unique()