Removed unused variables in AzureBlobStorageToGCSOperator (#31765)

* removed unused variable

* removed unused variable

Author: Adaverse

airflow/providers/microsoft/azure/transfers/azure_blob_to_gcs.py

@@ -39,7 +39,6 @@ class AzureBlobStorageToGCSOperator(BaseOperator):
     :param wasb_conn_id: Reference to the wasb connection.
     :param gcp_conn_id: The connection ID to use when fetching connection info.
     :param blob_name: Name of the blob
-    :param file_path: Path to the file to download
     :param container_name: Name of the container
     :param bucket_name: The bucket to upload to
     :param object_name: The object name to set when uploading the file
@@ -61,7 +60,6 @@ def __init__(
         wasb_conn_id="wasb_default",
         gcp_conn_id: str = "google_cloud_default",
         blob_name: str,
-        file_path: str,
         container_name: str,
         bucket_name: str,
         object_name: str,
@@ -74,7 +72,6 @@ def __init__(
         self.wasb_conn_id = wasb_conn_id
         self.gcp_conn_id = gcp_conn_id
         self.blob_name = blob_name
-        self.file_path = file_path
         self.container_name = container_name
         self.bucket_name = bucket_name
         self.object_name = object_name
@@ -84,7 +81,6 @@ def __init__(
 
     template_fields: Sequence[str] = (
         "blob_name",
-        "file_path",
         "container_name",
         "bucket_name",
         "object_name",

tests/providers/microsoft/azure/transfers/test_azure_blob_to_gcs.py

@@ -23,7 +23,6 @@
 WASB_CONN_ID = "wasb_default"
 GCP_CONN_ID = "google_cloud_default"
 BLOB_NAME = "azure_blob"
-FILE_PATH = "/file/to/path"
 CONTAINER_NAME = "azure_container"
 BUCKET_NAME = "airflow"
 OBJECT_NAME = "file.txt"
@@ -39,7 +38,6 @@ def test_init(self):
             wasb_conn_id=WASB_CONN_ID,
             gcp_conn_id=GCP_CONN_ID,
             blob_name=BLOB_NAME,
-            file_path=FILE_PATH,
             container_name=CONTAINER_NAME,
             bucket_name=BUCKET_NAME,
             object_name=OBJECT_NAME,
@@ -50,7 +48,6 @@ def test_init(self):
         )
         assert operator.wasb_conn_id == WASB_CONN_ID
         assert operator.blob_name == BLOB_NAME
-        assert operator.file_path == FILE_PATH
         assert operator.container_name == CONTAINER_NAME
         assert operator.gcp_conn_id == GCP_CONN_ID
         assert operator.bucket_name == BUCKET_NAME
@@ -68,7 +65,6 @@ def test_execute(self, mock_temp, mock_hook_gcs, mock_hook_wasb):
             wasb_conn_id=WASB_CONN_ID,
             gcp_conn_id=GCP_CONN_ID,
             blob_name=BLOB_NAME,
-            file_path=FILE_PATH,
             container_name=CONTAINER_NAME,
             bucket_name=BUCKET_NAME,
             object_name=OBJECT_NAME,

tests/system/providers/microsoft/azure/example_azure_blob_to_gcs.py

@@ -45,7 +45,12 @@
     DAG_ID,
     schedule=None,
     start_date=datetime(2021, 1, 1),  # Override to match your needs
-    default_args={"container_name": AZURE_CONTAINER_NAME, "blob_name": BLOB_NAME, "prefix": PREFIX_NAME},
+    default_args={
+        # azure args
+        "container_name": AZURE_CONTAINER_NAME,
+        "blob_name": BLOB_NAME,
+        "prefix": PREFIX_NAME,
+    },
 ) as dag:
     wait_for_blob = WasbBlobSensor(task_id="wait_for_blob")
 
@@ -60,8 +65,6 @@
 
     transfer_files_to_gcs = AzureBlobStorageToGCSOperator(
         task_id="transfer_files_to_gcs",
-        # AZURE arg
-        file_path=GCP_OBJECT_NAME,
         # GCP args
         bucket_name=GCP_BUCKET_NAME,
         object_name=GCP_OBJECT_NAME,