Projet

Général

Profil

Révision 3ec624e8

ID3ec624e84472bc9d6c3f55ffad1f61d4e96c9b53
Parent fd2a8b3b
Enfant b7d577ce

Ajouté par Alisson Patricio il y a plus de 13 ans

Update task's states to work with Celery 3.0

Voir les différences:

plugins/celery/celery_tasks
64 64 
		'task_details': '/api/task/name/%s',
65 65 
}
66 66 
TASK_STATES = (
67 
			'task-accepted',
68 
			'task-received',
69 
			'task-succeeded',
70 
			'task-failed',
71 
			'task-retried',
67 
			'PENDING',
68 
			'RECEIVED',
69 
			'STARTED',
70 
			'SUCCESS',
71 
			'FAILURE',
72 
			'REVOKED',
73 
			'RETRY'
72 74 
)
73 75 

  		




  74
  76
  
    
def get_data(what, api_url, *args):


  		




  ......




  90
  92
  
    
		sys.exit(-1)


  		




  91
  93
  
    

  		




  92
  94
  
    
def clean_state_name(state_name):


  		




  93
  
  
    
	return state_name.replace('task-', '')


  		




  
  95
  
    
	return state_name.lower()


  		




  94
  96
  
    

  		




  95
  97
  
    
# Config


  		




  96
  98
  
    
def print_config(workers = None):


  		




  ......




  115
  117
  
    
	data = get_data('tasks', api_url)


  		




  116
  118
  
    
	


  		




  117
  119
  
    
	counters = dict([(key, 0) for key in TASK_STATES])


  		




  118
  
  
    
	for task_name, task_data in data.iteritems():


  		




  119
  
  
    
		for entry in task_data:


  		




  120
  
  
    
			if not entry.get('state', None):


  		




  121
  
  
    
				continue


  		




  122
  
  
    
			


  		




  123
  
  
    
			state = entry.get('state', None)


  		




  124
  
  
    
			hostname = entry.get('hostname', None)


  		




  125
  
  
    
			


  		




  126
  
  
    
			if workers and hostname not in workers:


  		




  127
  
  
    
				continue


  		




  128
  
  
    
			


  		




  129
  
  
    
			counters[state] += 1


  		




  
  120
  
    
	for task_name, task_data in data:


  		




  
  121
  
    
		state = task_data['state']


  		




  
  122
  
    
		hostname = task_data['worker']['hostname']


  		




  
  123
  
    
		


  		




  
  124
  
    
		if workers and hostname not in workers:


  		




  
  125
  
    
			continue


  		




  
  126
  
    
		


  		




  
  127
  
    
		counters[state] += 1


  		




  130
  128
  
    
			


  		




  131
  129
  
    
	for name in TASK_STATES:


  		




  132
  130
  
    
		name_cleaned = clean_state_name(name)


  		












Formats disponibles :  Unified diff