[GitHub] feng-tao closed pull request #4346: [AIRFLOW-3546] Fix typos in jobs.py logs

[GitBox <gi...@apache.org>]

feng-tao closed pull request #4346: [AIRFLOW-3546] Fix typos in jobs.py logs
URL: https://github.com/apache/incubator-airflow/pull/4346
 
 
   

This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:

As this is a foreign pull request (from a fork), the diff is supplied
below (as it won't show otherwise due to GitHub magic):

diff --git a/airflow/jobs.py b/airflow/jobs.py
index e60f135972..8472ecd383 100644
--- a/airflow/jobs.py
+++ b/airflow/jobs.py
@@ -1213,7 +1213,7 @@ def _find_executable_task_instances(self, simple_dag_bag, states, session=None):
         task_instance_str = "\n\t".join(
             ["{}".format(x) for x in executable_tis])
         self.log.info(
-            "Setting the follow tasks to queued state:\n\t%s", task_instance_str)
+            "Setting the following tasks to queued state:\n\t%s", task_instance_str)
         # so these dont expire on commit
         for ti in executable_tis:
             copy_dag_id = ti.dag_id
@@ -1408,7 +1408,7 @@ def _change_state_for_tasks_failed_to_execute(self, session):
                 ["{}".format(x) for x in tis_to_set_to_scheduled])
 
             session.commit()
-            self.log.info("Set the follow tasks to scheduled state:\n\t{}"
+            self.log.info("Set the following tasks to scheduled state:\n\t{}"
                           .format(task_instance_str))
 
     def _process_dags(self, dagbag, dags, tis_out):


 

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services