(An Untitled Masterwork)
ActivePublic
Actions

Authored by vlorentz on Feb 22 2021, 3:45 PM.

Tags

None

Subscribers

None

	diff --git a/swh/clearlydefined/orchestrator.py b/swh/clearlydefined/orchestrator.py
	index 41beb9b..c35259e 100644
	--- a/swh/clearlydefined/orchestrator.py
	+++ b/swh/clearlydefined/orchestrator.py
	@@ -121,16 +121,16 @@ def map_previously_unmapped_data(storage: StorageInterface, cursor, connection)
	(cd_path,),
	)
	unmapped_row = cursor.fetchall()[0]
	- if orchestrate_row(
	+ orchestrate_row(
	storage=storage,
	row=Row(
	path=unmapped_row[0], metadata=unmapped_row[1], date=unmapped_row[2]
	),
	cursor=cursor,
	connection=connection,
	- ):
	- cursor.execute("DELETE FROM unmapped_data WHERE path=%s", (cd_path,))
	- connection.commit()
	+ )
	+ cursor.execute("DELETE FROM unmapped_data WHERE path=%s", (cd_path,))
	+ connection.commit()


	def write_in_not_mapped(cursor, write_connection, cd_path: str) -> None:

(An Untitled Masterwork)ActivePublicActions