Fixing some typos and spelling errors

Author: didier-durand

contributing-docs/testing/task_sdk_integration_tests.rst

@@ -85,7 +85,7 @@ reproducibility:
    breeze testing task-sdk-integration-tests task_sdk_tests/test_task_sdk_health.py
 
    # Run with custom Docker image
-   DOCKER_IMAGE=my-custom-airflow-imahge:latest breeze testing task-sdk-integration-tests
+   DOCKER_IMAGE=my-custom-airflow-image:latest breeze testing task-sdk-integration-tests
 
 Running in Your Current Virtual Environment
 ...........................................

dev/breeze/src/airflow_breeze/commands/ci_image_commands.py

@@ -930,7 +930,7 @@ def export_mount_cache(
     cache_file: Path,
 ):
     """
-    Export content of the the mount cache to a directory.
+    Export content of the mount cache to a directory.
     """
     perform_environment_checks()
     make_sure_builder_configured(params=BuildCiParams(builder=builder))
@@ -995,7 +995,7 @@ def import_mount_cache(
     cache_file: Path,
 ):
     """
-    Export content of the the mount cache to a directory.
+    Export content of the mount cache to a directory.
     """
     perform_environment_checks()
     make_sure_builder_configured(params=BuildCiParams(builder=builder))

providers/amazon/src/airflow/providers/amazon/aws/hooks/base_aws.py

@@ -790,7 +790,7 @@ def async_conn(self):
     async def get_async_conn(self):
         """Get an aiobotocore client to use for async operations."""
         # We have to wrap the call `self.get_client_type` in another call `_get_async_conn`,
-        # because one of it's arguments `self.region_name` is a `@property` decorated function
+        # because one of its arguments `self.region_name` is a `@property` decorated function
         # calling the cached property `self.conn_config` at the end.
         return await sync_to_async(self._get_async_conn)()
 

providers/amazon/src/airflow/providers/amazon/aws/hooks/chime.py

@@ -33,7 +33,7 @@ class ChimeWebhookHook(HttpHook):
     """
     Interact with Amazon Chime Webhooks to create notifications.
 
-    .. warning:: This hook is only designed to work with web hooks and not chat bots.
+    .. warning:: This hook is only designed to work with web hooks and not chatbots.
 
     :param chime_conn_id: :ref:`Amazon Chime Connection ID <howto/connection:chime>`
         with Endpoint as `https://hooks.chime.aws` and the webhook token

providers/amazon/src/airflow/providers/amazon/aws/operators/cloud_formation.py

@@ -32,7 +32,7 @@
 
 class CloudFormationCreateStackOperator(AwsBaseOperator[CloudFormationHook]):
     """
-    An operator that creates a AWS CloudFormation stack.
+    An operator that creates an AWS CloudFormation stack.
 
     .. seealso::
         For more information on how to use this operator, take a look at the guide:
@@ -68,7 +68,7 @@ def execute(self, context: Context):
 
 class CloudFormationDeleteStackOperator(AwsBaseOperator[CloudFormationHook]):
     """
-    An operator that deletes a AWS CloudFormation stack.
+    An operator that deletes an AWS CloudFormation stack.
 
     .. seealso::
         For more information on how to use this operator, take a look at the guide:

providers/amazon/src/airflow/providers/amazon/aws/transfers/azure_blob_to_s3.py

@@ -49,12 +49,12 @@ class AzureBlobStorageToS3Operator(BaseOperator):
     :param prefix: Prefix string which filters objects whose name begin with
         this prefix. (templated)
     :param delimiter: The delimiter by which you want to filter the objects. (templated)
-        For e.g to lists the CSV files from in a directory in GCS you would use
+        For e.g. to lists the CSV files from in a directory in GCS you would use
         delimiter='.csv'.
     :param aws_conn_id: Connection id of the S3 connection to use
     :param dest_s3_key: The base S3 key to be used to store the files. (templated)
     :param dest_verify: Whether or not to verify SSL certificates for S3 connection.
-        By default SSL certificates are verified.
+        By default, SSL certificates are verified.
         You can provide the following values:
 
         - ``False``: do not validate SSL certificates. SSL will still be used

providers/apache/beam/src/airflow/providers/apache/beam/operators/beam.py

@@ -160,7 +160,7 @@ class BeamBasePipelineOperator(BaseOperator, BeamDataflowMixin, ABC):
     """
     Abstract base class for Beam Pipeline Operators.
 
-    :param runner: Runner on which pipeline will be run. By default "DirectRunner" is being used.
+    :param runner: Runner on which pipeline will be run. By default, "DirectRunner" is being used.
         Other possible options: DataflowRunner, SparkRunner, FlinkRunner, PortableRunner.
         See: :class:`~providers.apache.beam.hooks.beam.BeamRunnerType`
         See: https://beam.apache.org/documentation/runners/capability-matrix/

providers/celery/src/airflow/providers/celery/executors/celery_executor.py

@@ -350,7 +350,7 @@ def _process_workloads(self, workloads: Sequence[workloads.All]) -> None:
     def _send_tasks(self, task_tuples_to_send: Sequence[TaskInstanceInCelery]):
         first_task = next(t[-1] for t in task_tuples_to_send)
 
-        # Celery state queries will stuck if we do not use one same backend
+        # Celery state queries will be stuck if we do not use one same backend
         # for all tasks.
         cached_celery_backend = first_task.backend
 

providers/celery/src/airflow/providers/celery/executors/celery_executor_utils.py

@@ -111,7 +111,7 @@ def on_celery_import_modules(*args, **kwargs):
     """
     Preload some "expensive" airflow modules once, so other task processes won't have to import it again.
 
-    Loading these for each task adds 0.3-0.5s *per task* before the task can run. For long running tasks this
+    Loading these for each task adds 0.3-0.5s *per task* before the task can run. For long-running tasks this
     doesn't matter, but for short tasks this starts to be a noticeable impact.
     """
     import jinja2.ext  # noqa: F401

providers/google/src/airflow/providers/google/cloud/hooks/cloud_sql.py

@@ -508,7 +508,7 @@ class CloudSqlProxyRunner(LoggingMixin):
     :param project_id: Optional id of the Google Cloud project to connect to - it overwrites
         default project id taken from the Google Cloud connection.
     :param sql_proxy_version: Specific version of SQL proxy to download
-        (for example 'v1.13'). By default latest version is downloaded.
+        (for example 'v1.13'). By default, latest version is downloaded.
     :param sql_proxy_binary_path: If specified, then proxy will be
         used from the path specified rather than dynamically generated. This means
         that if the binary is not present in that path it will also be downloaded.
@@ -693,7 +693,7 @@ def stop_proxy(self) -> None:
             self.log.info("Skipped removing proxy - it was not downloaded: %s", self.sql_proxy_path)
         if os.path.isfile(self.credentials_path):
             self.log.info("Removing generated credentials file %s", self.credentials_path)
-            # Here file cannot be delete by concurrent task (each task has its own copy)
+            # Here file cannot be deleted by concurrent task (each task has its own copy)
             os.remove(self.credentials_path)
 
     def get_proxy_version(self) -> str | None: