Remove unused import

src/wazuh_testing/modules/aws/utils.py

@@ -278,3 +278,29 @@ def path_exist(path: Path) -> bool:
         bool: True if exist else False
     """
     return path.exists()
+
+    # Call the module with the same parameters in and check there were no duplicates
+    expected_skipped_logs_step_3 = metadata.get('expected_skipped_logs_step_3', 1)
+    event_monitor.check_non_processed_logs_from_output(
+        command_output=call_aws_module(*base_parameters, ONLY_LOGS_AFTER_PARAM, '2022-NOV-20'),
+        bucket_type=bucket_type,
+        expected_results=expected_skipped_logs_step_3
+    )
+
+    # Call the module with only_logs_after set with an early date than setted previously and check that no logs
+    # were processed, there were no duplicates
+    event_monitor.check_non_processed_logs_from_output(
+        command_output=call_aws_module(*base_parameters, ONLY_LOGS_AFTER_PARAM, '2022-NOV-22'),
+        bucket_type=bucket_type,
+        expected_results=expected_skipped_logs_step_3 - 1 if expected_skipped_logs_step_3 > 1 else 1
+    )
+
+    # Upload a log file for the day of the test execution and call the module without only_logs_after and check that
+    # only the uploaded logs were processed and the last marker is specified in the DB.
+    last_marker_key = get_last_file_key(bucket_type, bucket_name, datetime.utcnow())
+    metadata['filename'] = upload_file(bucket_type, bucket_name)
+
+    event_monitor.check_marker_from_output(
+        command_output=call_aws_module(*base_parameters),
+        file_key=last_marker_key
+    )

src/wazuh_testing/utils/db_queries/aws_db.py

@@ -8,7 +8,6 @@
 
 # Local imports
 from wazuh_testing.utils.database import get_query_result, get_fetch_one_query_result
-from wazuh_testing.constants.aws import SELECT_QUERY_TEMPLATE
 from wazuh_testing.constants.paths.aws import S3_CLOUDTRAIL_DB_PATH, AWS_SERVICES_DB_PATH
 
 """ Database data structures  """