This is an automated email from the ASF dual-hosted git repository.
potiuk pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new e5de5506d54 Fix the Show Down text (#44292)
e5de5506d54 is described below
commit e5de5506d54aeacbd78da319a5975411db4b03cd
Author: Jens Scheffler <[email protected]>
AuthorDate: Sat Nov 23 01:18:18 2024 +0100
Fix the Show Down text (#44292)
---
providers/src/airflow/providers/edge/cli/edge_command.py | 2 +-
providers/src/airflow/providers/edge/models/edge_worker.py | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/providers/src/airflow/providers/edge/cli/edge_command.py
b/providers/src/airflow/providers/edge/cli/edge_command.py
index 4d0b46d74e7..8cb19fb2da9 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 @@ class _EdgeWorkerCli:
@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 b65d9350388..7fdcb0cf3d4 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."""
