[autofix.ci] apply automated fixes

src/backend/base/langflow/components/data/s3_bucket uploader.py

@@ -1,36 +1,30 @@
 import os
-import boto3
-import tempfile
 from typing import Any
 
-from langflow.base.data import BaseFileComponent
-from langflow.base.data.utils import TEXT_FILE_TYPES, parallel_load_data, parse_text_file_to_data
+import boto3
+
 from langflow.custom import Component
 from langflow.io import (
-    BoolInput,
-    DataInput,
     DropdownInput,
-    FloatInput,
-    IntInput,
-    MessageTextInput,
-    MultilineInput,
+    HandleInput,
     Output,
     StrInput,
-    HandleInput
 )
-from langflow.schema import Data
+
 
 class S3BucketUploaderComponent(Component):
     """S3BucketUploaderComponent is a component responsible for uploading files to an S3 bucket.
     It provides two strategies for file upload: "By Data" and "By File Name". The component
     requires AWS credentials and bucket details as inputs and processes files accordingly.
+
     Attributes:
         display_name (str): The display name of the component.
         description (str): A brief description of the components functionality.
         icon (str): The icon representing the component.
         name (str): The internal name of the component.
         inputs (list): A list of input configurations required by the component.
         outputs (list): A list of output configurations provided by the component.
+
     Methods:
         process_files() -> None:
             Processes files based on the selected strategy. Calls the appropriate method
@@ -47,14 +41,15 @@ class S3BucketUploaderComponent(Component):
         _s3_client() -> Any:
             Creates and returns an S3 client using the provided AWS access key ID and secret
             access key.
-            
+
         Please note that this component requires the boto3 library to be installed. It is designed to work with File and Director components as inputs
     """
+
     display_name = "S3 Bucket Uploader"
     description = "Uploads files to S3 bucket."
     icon = "Globe"
     name = "s3bucketuploader"
-        
+
     inputs = [
         SecretStrInput(
             name="aws_access_key_id",
@@ -91,79 +86,75 @@ class S3BucketUploaderComponent(Component):
             is_list=True,
             required=True,
         ),
-
     ]
-     
+
     outputs = [
         Output(display_name="Writes to AWS Bucket", name="data", method="process_files"),
     ]
-    
+
     def process_files(self) -> None:
-        """
-        Process files based on the selected strategy.
+        """Process files based on the selected strategy.
         This method uses a strategy pattern to process files. The strategy is determined
         by the `self.strategy` attribute, which can be either "By Data" or "By File Name".
-        Depending on the strategy, the corresponding method (`process_files_by_data` or 
-        `process_files_by_name`) is called. If an invalid strategy is provided, an error 
+        Depending on the strategy, the corresponding method (`process_files_by_data` or
+        `process_files_by_name`) is called. If an invalid strategy is provided, an error
         is logged.
+
         Returns:
             None
-        """        
+        """
         strategy_methods = {
             "By Data": self.process_files_by_data,
             "By File Name": self.process_files_by_name,
         }
         strategy_methods.get(self.strategy, lambda: self.log("Invalid strategy"))()
 
     def process_files_by_data(self) -> None:
-        """
-        Processes and uploads files to an S3 bucket based on the data inputs.
+        """Processes and uploads files to an S3 bucket based on the data inputs.
         This method iterates over the data inputs, logs the file path and text content,
         and uploads each file to the specified S3 bucket if both file path and text content
         are available.
+
         Args:
             None
         Returns:
             None
-        """        
-        for data_item in self.data_inputs:      
+        """
+        for data_item in self.data_inputs:
+            file_path = data_item.data.get("file_path")
+            text_content = data_item.data.get("text")
 
-            file_path = data_item.data.get('file_path')
-            text_content = data_item.data.get('text')
-
-            if file_path and text_content:                   
+            if file_path and text_content:
                 self._s3_client().put_object(Bucket=self.bucket_name, Key=file_path, Body=text_content)
                 try:
                     os.remove(file_path)
                 except OSError as e:
                     self.log(f"Error deleting file {file_path}: {e}", level="error")
 
     def process_files_by_name(self) -> None:
-        """
-        Processes and uploads files to an S3 bucket based on their names.
+        """Processes and uploads files to an S3 bucket based on their names.
         Iterates through the list of data inputs, retrieves the file path from each data item,
         and uploads the file to the specified S3 bucket if the file path is available.
         Logs the file path being uploaded.
+
         Returns:
             None
-        """        
-        for data_item in self.data_inputs:      
-            logger.info(f"Uploading file to S3 bucket: {data_item.data.get('file_path')} ")  
-            file_path = data_item.data.get('file_path')
-            
-            if file_path:      
+        """
+        for data_item in self.data_inputs:
+            logger.info(f"Uploading file to S3 bucket: {data_item.data.get('file_path')} ")
+            file_path = data_item.data.get("file_path")
+
+            if file_path:
                 self._s3_client().upload_file(file_path, Bucket=self.bucket_name, Key=file_path)
-                
+
     def _s3_client(self) -> Any:
-        """
-        Creates and returns an S3 client using the provided AWS access key ID and secret access key.
+        """Creates and returns an S3 client using the provided AWS access key ID and secret access key.
 
         Returns:
             Any: A boto3 S3 client instance.
         """
         return boto3.client(
-            's3',
+            "s3",
             aws_access_key_id=self.aws_access_key_id,
             aws_secret_access_key=self.aws_secret_access_key,
         )
-