[airflow] branch main updated: Assert run_as_user in test_localtaskjob_heartbeat (#22743)

[potiuk]

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

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


The following commit(s) were added to refs/heads/main by this push:
     new 0f0dbdceb7 Assert run_as_user in test_localtaskjob_heartbeat (#22743)
0f0dbdceb7 is described below

commit 0f0dbdceb7b14800b70e0b3e00d6ef7941e83275
Author: Ping Zhang <pin...@umich.edu>
AuthorDate: Tue Apr 5 00:32:41 2022 -0700

    Assert run_as_user in test_localtaskjob_heartbeat (#22743)
---
 tests/jobs/test_local_task_job.py | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/tests/jobs/test_local_task_job.py 
b/tests/jobs/test_local_task_job.py
index cf508c4ff6..ac50868e2e 100644
--- a/tests/jobs/test_local_task_job.py
+++ b/tests/jobs/test_local_task_job.py
@@ -143,6 +143,8 @@ class TestLocalTaskJob:
         session.merge(ti)
         session.commit()
         assert ti.pid != os.getpid()
+        assert not ti.run_as_user
+        assert not job1.task_runner.run_as_user
         job1.heartbeat_callback(session=None)
 
         job1.task_runner.process.pid = 2