pingzh commented on a change in pull request #21877:
URL: https://github.com/apache/airflow/pull/21877#discussion_r832462832
##########
File path: airflow/models/taskinstance.py
##########
@@ -1410,18 +1410,7 @@ def _execute_task_with_callbacks(self, context,
test_mode=False):
"""Prepare Task for Execution"""
from airflow.models.renderedtifields import RenderedTaskInstanceFields
- parent_pid = os.getpid()
Review comment:
@potiuk this check is no needed since the `TaskInstance#_run_raw_task`
is always in separated process as this PR removes the process fork from the
`LocalTaskJob`. Forking from the `LocalTaskJob` might have security issues when
there is run_as_user for the task.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
