External-Mirrors/awx
2
0
Fork 0
mirror of https://github.com/ansible/awx.git synced 2026-02-24 06:26:00 -03:30
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #11837 from AlanCoding/thread_key_error

Browse Source 
Move model and settings operations out of threaded code
This commit is contained in:
Alan Rominger
2022-03-05 14:55:13 -05:00
committed by GitHub
parent c6209df1e0 264c508c80
commit e02e91adaa
1 changed files with 8 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
awx/main/tasks/receptor.py
View File

@@ -286,19 +286,18 @@ class AWXReceptorJob:
# reading. # reading.
sockin, sockout = socket.socketpair() sockin, sockout = socket.socketpair()
# Prepare the submit_work kwargs before creating threads, because references to settings are not thread-safe
work_submit_kw = dict(worktype=self.work_type, params=self.receptor_params, signwork=self.sign_work)
if self.work_type == 'ansible-runner':
work_submit_kw['node'] = self.task.instance.execution_node
use_stream_tls = get_conn_type(work_submit_kw['node'], receptor_ctl).name == "STREAMTLS"
work_submit_kw['tlsclient'] = get_tls_client(use_stream_tls)
with concurrent.futures.ThreadPoolExecutor(max_workers=1) as executor: with concurrent.futures.ThreadPoolExecutor(max_workers=1) as executor:
transmitter_future = executor.submit(self.transmit, sockin) transmitter_future = executor.submit(self.transmit, sockin)
_kw = {}
if self.work_type == 'ansible-runner':
_kw['node'] = self.task.instance.execution_node
use_stream_tls = get_conn_type(_kw['node'], receptor_ctl).name == "STREAMTLS"
_kw['tlsclient'] = get_tls_client(use_stream_tls)
# submit our work, passing in the right side of our socketpair for reading. # submit our work, passing in the right side of our socketpair for reading.
result = receptor_ctl.submit_work( result = receptor_ctl.submit_work(payload=sockout.makefile('rb'), **work_submit_kw)
worktype=self.work_type, payload=sockout.makefile('rb'), params=self.receptor_params, signwork=self.sign_work, **_kw
)
sockin.close() sockin.close()
sockout.close() sockout.close()