diff --git a/providers/src/airflow/providers/edge/cli/edge_command.py b/providers/src/airflow/providers/edge/cli/edge_command.py index 4d0b46d74e79c..8cb19fb2da9df 100644 --- a/providers/src/airflow/providers/edge/cli/edge_command.py +++ b/providers/src/airflow/providers/edge/cli/edge_command.py @@ -156,7 +156,7 @@ def __init__( @staticmethod def signal_handler(sig, frame): - logger.info("Request to show down Edge Worker received, waiting for jobs to complete.") + logger.info("Request to shut down Edge Worker received, waiting for jobs to complete.") _EdgeWorkerCli.drain = True def shutdown_handler(self, sig, frame): diff --git a/providers/src/airflow/providers/edge/models/edge_worker.py b/providers/src/airflow/providers/edge/models/edge_worker.py index b65d935038854..7fdcb0cf3d413 100644 --- a/providers/src/airflow/providers/edge/models/edge_worker.py +++ b/providers/src/airflow/providers/edge/models/edge_worker.py @@ -62,7 +62,7 @@ class EdgeWorkerState(str, Enum): TERMINATING = "terminating" """Edge Worker is completing work and stopping.""" OFFLINE = "offline" - """Edge Worker was show down.""" + """Edge Worker was shut down.""" UNKNOWN = "unknown" """No heartbeat signal from worker for some time, Edge Worker probably down."""