Fix taskmanager failing to launch workflow job

This was caused by taskmanager instance group refactoring. This
re-enables that functionality
This commit is contained in:
Matthew Jones
2017-05-23 11:15:57 -04:00
parent 27369aebe9
commit adf4be29b7
2 changed files with 7 additions and 1 deletions

View File

@@ -499,8 +499,12 @@ class WorkflowJob(UnifiedJob, WorkflowJobOptions, SurveyJobMixin, JobNotificatio
def get_notification_friendly_name(self):
return "Workflow Job"
@property
def preferred_instance_groups(self):
return self.global_instance_groups
'''
A WorkflowJob is a virtual job. It doesn't result in a celery task.
'''
def start_celery_task(self, opts, error_callback, success_callback):
def start_celery_task(self, opts, error_callback, success_callback, queue):
return None