diff --git a/awx/main/tasks.py b/awx/main/tasks.py index c2b4af4b77..a64c06dae9 100644 --- a/awx/main/tasks.py +++ b/awx/main/tasks.py @@ -773,7 +773,6 @@ class BaseTask(Task): self.final_run_hook(instance, status, **kwargs) instance.websocket_emit_status(status) if status != 'successful' and not hasattr(settings, 'CELERY_UNIT_TEST'): - print("Status is not successful!") # Raising an exception will mark the job as 'failed' in celery # and will stop a task chain from continuing to execute if status == 'canceled': @@ -1858,7 +1857,6 @@ class RunInventoryUpdate(BaseTask): raise def final_run_hook(self, instance, status, **kwargs): - print("In final run hook") if self.custom_dir_path: for p in self.custom_dir_path: try: diff --git a/awx/main/tests/unit/models/test_jobs.py b/awx/main/tests/unit/models/test_jobs.py index 69c5f262a2..5592407013 100644 --- a/awx/main/tests/unit/models/test_jobs.py +++ b/awx/main/tests/unit/models/test_jobs.py @@ -87,7 +87,7 @@ def test_start_job_fact_cache(hosts, job, inventory, mocker): job.start_job_fact_cache() - job._get_memcache_connection().set.assert_any_call('{}'.format(5), [h.name for h in hosts]) + job._get_memcache_connection().set.assert_any_call('5', [h.name for h in hosts]) for host in hosts: job._get_memcache_connection().set.assert_any_call('{}-{}'.format(5, host.name), json.dumps(host.ansible_facts)) job._get_memcache_connection().set.assert_any_call('{}-{}-modified'.format(5, host.name), host.ansible_facts_modified.isoformat())