You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by ka...@apache.org on 2020/08/08 12:35:01 UTC

[airflow] branch master updated: Replace remaining uses of "bail" (#10217)

This is an automated email from the ASF dual-hosted git repository.

kaxilnaik pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/airflow.git


The following commit(s) were added to refs/heads/master by this push:
     new 0d8bc95  Replace remaining uses of "bail" (#10217)
0d8bc95 is described below

commit 0d8bc95ad643924ebcad4da0d9ea36416e05d5e3
Author: Joe Lyman <Ly...@users.noreply.github.com>
AuthorDate: Sat Aug 8 13:33:39 2020 +0100

    Replace remaining uses of "bail" (#10217)
---
 airflow/cli/commands/dag_command.py | 2 +-
 airflow/cli/commands/db_command.py  | 2 +-
 airflow/models/dag.py               | 6 +++---
 3 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/airflow/cli/commands/dag_command.py b/airflow/cli/commands/dag_command.py
index e003f16..13dd351 100644
--- a/airflow/cli/commands/dag_command.py
+++ b/airflow/cli/commands/dag_command.py
@@ -176,7 +176,7 @@ def dag_delete(args):
         except OSError as err:
             raise AirflowException(err)
     else:
-        print("Bail.")
+        print("Cancelled")
 
 
 @cli_utils.action_logging
diff --git a/airflow/cli/commands/db_command.py b/airflow/cli/commands/db_command.py
index e384c4e..6ba5b37 100644
--- a/airflow/cli/commands/db_command.py
+++ b/airflow/cli/commands/db_command.py
@@ -40,7 +40,7 @@ def resetdb(args):
                          "(y/n)").upper() == "Y":
         db.resetdb()
     else:
-        print("Bail.")
+        print("Cancelled")
 
 
 @cli_utils.action_logging
diff --git a/airflow/models/dag.py b/airflow/models/dag.py
index 222910a..172ca19 100644
--- a/airflow/models/dag.py
+++ b/airflow/models/dag.py
@@ -929,7 +929,7 @@ class DAG(BaseDag, LoggingMixin):
             # graph as we move through it. We also keep a flag for
             # checking that that graph is acyclic, which is true if any
             # nodes are resolved during each pass through the graph. If
-            # not, we need to bail out as the graph therefore can't be
+            # not, we need to exit as the graph therefore can't be
             # sorted.
             acyclic = False
             for node in list(graph_unsorted.values()):
@@ -1154,7 +1154,7 @@ class DAG(BaseDag, LoggingMixin):
             )
         else:
             count = 0
-            print("Bail. Nothing was cleared.")
+            print("Cancelled, nothing was cleared.")
 
         session.commit()
         return count
@@ -1215,7 +1215,7 @@ class DAG(BaseDag, LoggingMixin):
                           )
         else:
             count = 0
-            print("Bail. Nothing was cleared.")
+            print("Cancelled, nothing was cleared.")
         return count
 
     def __deepcopy__(self, memo):