Skip to content

Applied permissions to self._error_file #15947

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
ashb merged 8 commits into from
Sep 3, 2021
Merged

Applied permissions to self._error_file #15947

Changes from all commits
Commits
Show all changes
8 commits
Select commit Hold shift + click to select a range
e2feb29
Applied permissions to self._error_file
kevinbsilva May 19, 2021
39a2745
Changed os.chmod to os.chown
kevinbsilva Jun 7, 2021
99462d2
Added exception to avoid erros at the os.chown, if receive something …
kevinbsilva Jul 22, 2021
30fd2e6
Ordered imports in alphabetical order
kevinbsilva Jul 23, 2021
53cb6dc
Adjusted code format to black
kevinbsilva Jul 23, 2021
aa129c0
Fixed ordering group of imports
kevinbsilva Jul 23, 2021
90a2797
Removed blank line from import. Applied isort
kevinbsilva Jul 23, 2021
8f20361
Update airflow/task/task_runner/base_task_runner.py
ashb Sep 3, 2021
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 4 additions & 0 deletions airflow/task/task_runner/base_task_runner.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -19,6 +19,7 @@
import os
import subprocess
import threading
from pwd import getpwnam
from tempfile import NamedTemporaryFile
from typing import Optional, Union

Expand Down Expand Up @@ -85,6 +86,9 @@ def __init__(self, local_task_job):
cfg_path = tmp_configuration_copy(chmod=0o600)

self._error_file = NamedTemporaryFile(delete=True)
if self.run_as_user:
os.chown(self._error_file.name, getpwnam(self.run_as_user).pw_uid, -1)

self._cfg_path = cfg_path
self._command = (
popen_prepend
Expand Down