Differential D705 Diff 2232 swh/indexer/origin_head.py

Changeset View

Standalone View

swh/indexer/origin_head.py

Show First 20 Lines • Show All 76 Lines • ▼ Show 20 Lines	def next_step(self, results, task):

# First task to run after this one: index the metadata of the		# First task to run after this one: index the metadata of the
# revision		# revision
task = create_task_dict(		task = create_task_dict(
revision_metadata_task,		revision_metadata_task,
'oneshot',		'oneshot',
ids=[res['revision_id'].decode() for res in results],		ids=[res['revision_id'].decode() for res in results],
policy_update='update-dups',		policy_update='update-dups',
next_step={		next_step=sub_task,
**sub_task,
'result_name': 'revisions_metadata'},
ardumontUnsubmitted Not Done Inline Actions how come you don't need that anymore? ardumont: how come you don't need that anymore?
vlorentzAuthorUnsubmitted Done Inline Actions D704 made it optional vlorentz: D704 made it optional
ardumontUnsubmitted Not Done Inline Actions Yes but why you needed it and now you don't? Also, i think it was opened only for that case ;) ardumont: Yes but why you needed it and now you don't? Also, i think it was opened only for that case ;)
vlorentzAuthorUnsubmitted Done Inline Actions Because the origin int meta indexer now calls `revision_metadata_get` instead of getting `revisions_metadata` via the scheduler. vlorentz: Because the origin int meta indexer now calls `revision_metadata_get` instead of getting…
)		)
if getattr(self, 'scheduler', None):		if getattr(self, 'scheduler', None):
scheduler = self.scheduler		scheduler = self.scheduler
else:		else:
scheduler = get_scheduler(**self.config['scheduler'])		scheduler = get_scheduler(**self.config['scheduler'])
scheduler.create_tasks([task])		scheduler.create_tasks([task])

# Dispatch		# Dispatch
▲ Show 20 Lines • Show All 126 Lines • Show Last 20 Lines