Changeset View

Standalone View

Show First 20 Lines • Show All 474 Lines • ▼ Show 20 Lines	def create_missing_origins_and_tasks(self, models_list, injected_repos):
tasks = {}		tasks = {}

def _origin_key(m):		def _origin_key(m):
_type = m.get('origin_type', m.get('type'))		_type = m.get('origin_type', m.get('type'))
_url = m.get('origin_url', m.get('url'))		_url = m.get('origin_url', m.get('url'))
return '%s-%s' % (_type, _url)		return '%s-%s' % (_type, _url)

def _task_key(m):		def _task_key(m):
return '%s-%s' % (m['type'], json.dumps(m['arguments']))		return '%s-%s' % (m['type'],
		json.dumps(m['arguments'], sort_keys=True))

for m in models_list:		for m in models_list:
ir = injected_repos[m['uid']]		ir = injected_repos[m['uid']]
if not ir.origin_id:		if not ir.origin_id:
origin_dict = self.origin_dict(**m)		origin_dict = self.origin_dict(**m)
origins[_origin_key(m)] = (ir, m, origin_dict)		origins[_origin_key(m)] = (ir, m, origin_dict)
if not ir.task_id:		if not ir.task_id:
task_dict = self.task_dict(**m)		task_dict = self.task_dict(**m)
▲ Show 20 Lines • Show All 60 Lines • Show Last 20 Lines