[airflow] branch master updated: Fix spelling in CeleryExecutor (#11407)

[tu...@apache.org]

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

turbaszek 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 b786327  Fix spelling in CeleryExecutor (#11407)
b786327 is described below

commit b78632704124930eaf883142a0045a1ed348911c
Author: John Bampton <jb...@users.noreply.github.com>
AuthorDate: Mon Oct 12 02:06:26 2020 +1000

    Fix spelling in CeleryExecutor (#11407)
---
 airflow/executors/celery_executor.py    | 4 ++--
 tests/executors/test_celery_executor.py | 2 +-
 tests/utils/test_dag_processing.py      | 2 +-
 3 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/airflow/executors/celery_executor.py b/airflow/executors/celery_executor.py
index f77ea91..1bed9b1 100644
--- a/airflow/executors/celery_executor.py
+++ b/airflow/executors/celery_executor.py
@@ -82,7 +82,7 @@ def execute_command(command_to_exec: CommandType) -> None:
     log.info("Executing command in Celery: %s", command_to_exec)
 
     if settings.EXECUTE_TASKS_NEW_PYTHON_INTERPRETER:
-        _execute_in_subprocees(command_to_exec)
+        _execute_in_subprocess(command_to_exec)
     else:
         _execute_in_fork(command_to_exec)
 
@@ -118,7 +118,7 @@ def _execute_in_fork(command_to_exec: CommandType) -> None:
         os._exit(ret)  # pylint: disable=protected-access
 
 
-def _execute_in_subprocees(command_to_exec: CommandType) -> None:
+def _execute_in_subprocess(command_to_exec: CommandType) -> None:
     env = os.environ.copy()
     try:
         # pylint: disable=unexpected-keyword-arg
diff --git a/tests/executors/test_celery_executor.py b/tests/executors/test_celery_executor.py
index fcf0e36..c53b0e0 100644
--- a/tests/executors/test_celery_executor.py
+++ b/tests/executors/test_celery_executor.py
@@ -227,7 +227,7 @@ class TestCeleryExecutor(unittest.TestCase):
     ))
     def test_command_validation(self, command, expected_exception):
         # Check that we validate _on the receiving_ side, not just sending side
-        with mock.patch('airflow.executors.celery_executor._execute_in_subprocees') as mock_subproc, \
+        with mock.patch('airflow.executors.celery_executor._execute_in_subprocess') as mock_subproc, \
              mock.patch('airflow.executors.celery_executor._execute_in_fork') as mock_fork:
             if expected_exception:
                 with pytest.raises(expected_exception):
diff --git a/tests/utils/test_dag_processing.py b/tests/utils/test_dag_processing.py
index cc15143..26a441f 100644
--- a/tests/utils/test_dag_processing.py
+++ b/tests/utils/test_dag_processing.py
@@ -247,7 +247,7 @@ class TestDagFileProcessorManager(unittest.TestCase):
                 session.add(local_job)
                 session.commit()
 
-                # TODO: If there was an actual Relationshop between TI and Job
+                # TODO: If there was an actual Relationship between TI and Job
                 # we wouldn't need this extra commit
                 session.add(ti)
                 ti.job_id = local_job.id