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: