External-Mirrors/awx
2
0
Fork 0
mirror of https://github.com/ansible/awx.git synced 2026-05-14 12:57:40 -02:30
Code Issues Packages Projects Releases Wiki Activity

Disable activity stream for updates in status handler

Browse Source
This commit is contained in:
Shane McDonald
2021-06-24 12:39:08 -04:00
parent 3be29d54ad
commit 397908543d
1 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
awx/main/tasks.py
View File

@@ -1268,11 +1268,17 @@ class BaseTask(object):
for k, v in self.safe_env.items(): for k, v in self.safe_env.items():
if k in job_env: if k in job_env:
job_env[k] = v job_env[k] = v
self.instance = self.update_model(self.instance.pk, job_args=json.dumps(runner_config.command), job_cwd=runner_config.cwd, job_env=job_env) from awx.main.signals import disable_activity_stream # Circular import
with disable_activity_stream():
self.instance = self.update_model(self.instance.pk, job_args=json.dumps(runner_config.command), job_cwd=runner_config.cwd, job_env=job_env)
elif status_data['status'] == 'error': elif status_data['status'] == 'error':
result_traceback = status_data.get('result_traceback', None) result_traceback = status_data.get('result_traceback', None)
if result_traceback: if result_traceback:
self.instance = self.update_model(self.instance.pk, result_traceback=result_traceback) from awx.main.signals import disable_activity_stream # Circular import
with disable_activity_stream():
self.instance = self.update_model(self.instance.pk, result_traceback=result_traceback)
@with_path_cleanup @with_path_cleanup
def run(self, pk, **kwargs): def run(self, pk, **kwargs):