shaba/awx
1
0
Fork 0
mirror of https://github.com/ansible/awx.git synced 2024-11-02 09:51:09 +03:00
Code Releases Activity

Temporarily relax task notification and rely on polling

Browse Source
This commit is contained in:
Matthew Jones 2014-03-23 18:37:30 -04:00
parent 10e6baaca0
commit 3e88894f85
4 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
awx/main/models/inventory.py
View File

@ -781,5 +781,5 @@ class InventoryUpdate(CommonTask):
self.save() self.save()
self.start_args = encrypt_field(self, 'start_args') self.start_args = encrypt_field(self, 'start_args')
self.save() self.save()
notify_task_runner.delay(dict(task_type="inventory_update", id=self.id, metadata=kwargs)) # notify_task_runner.delay(dict(task_type="inventory_update", id=self.id, metadata=kwargs))
return True return True

2
awx/main/models/jobs.py
View File

@ -400,7 +400,7 @@ class Job(CommonTask):
self.save() self.save()
self.start_args = encrypt_field(self, 'start_args') self.start_args = encrypt_field(self, 'start_args')
self.save() self.save()
notify_task_runner.delay(dict(task_type="ansible_playbook", id=self.id)) # notify_task_runner.delay(dict(task_type="ansible_playbook", id=self.id))
return True return True
def start(self, error_callback, **kwargs): def start(self, error_callback, **kwargs):

2
awx/main/models/projects.py
View File

@ -393,7 +393,7 @@ class ProjectUpdate(CommonTask):
self.save() self.save()
self.start_args = encrypt_field(self, 'start_args') self.start_args = encrypt_field(self, 'start_args')
self.save() self.save()
notify_task_runner.delay(dict(task_type="project_update", id=self.id, metadata=kwargs)) # notify_task_runner.delay(dict(task_type="project_update", id=self.id, metadata=kwargs))
return True return True
def _update_parent_instance(self): def _update_parent_instance(self):

3
awx/main/tasks.py
View File

@ -132,7 +132,8 @@ class BaseTask(Task):
self.model._meta.object_name, retry_count) self.model._meta.object_name, retry_count)
def signal_finished(self, pk): def signal_finished(self, pk):
notify_task_runner(dict(complete=pk)) pass
# notify_task_runner(dict(complete=pk))
def get_model(self, pk): def get_model(self, pk):
return self.model.objects.get(pk=pk) return self.model.objects.get(pk=pk)