diff --git a/sql/upgrades/129.sql b/sql/upgrades/129.sql
index 5e37ea99..739c0fae 100644
--- a/sql/upgrades/129.sql
+++ b/sql/upgrades/129.sql
@@ -1,27 +1,33 @@
 -- SWH DB schema upgrade
 -- from_version: 128
 -- to_version: 129
 -- description: Update origin trigger to provide the full origin
 
 insert into dbversion(version, release, description)
       values(129, now(), 'Work In Progress');
 
 -- Asynchronous notification of new origin insertions
 create or replace function notify_new_origin()
   returns trigger
   language plpgsql
 as $$
   begin
     perform pg_notify('new_origin', json_build_object(
       'url', new.url::text,
       'type', new.type::text
     )::text);
     return null;
   end;
 $$;
 
 drop trigger notify_new_origin on origin;
 create trigger notify_new_origin
   after insert on origin
   for each row
   execute procedure notify_new_origin();
+
+
+create trigger notify_changed_origin_visit
+  after update on origin_visit
+  for each row
+  execute procedure notify_new_origin_visit();
diff --git a/swh/storage/sql/70-swh-triggers.sql b/swh/storage/sql/70-swh-triggers.sql
index d087bf1c..0042fb62 100644
--- a/swh/storage/sql/70-swh-triggers.sql
+++ b/swh/storage/sql/70-swh-triggers.sql
@@ -1,170 +1,156 @@
 -- Asynchronous notification of new content insertions
 create function notify_new_content()
   returns trigger
   language plpgsql
 as $$
   begin
     perform pg_notify('new_content', json_build_object(
       'sha1', encode(new.sha1, 'hex'),
       'sha1_git', encode(new.sha1_git, 'hex'),
       'sha256', encode(new.sha256, 'hex'),
       'blake2s256', encode(new.blake2s256, 'hex')
     )::text);
     return null;
   end;
 $$;
 
 create trigger notify_new_content
   after insert on content
   for each row
   execute procedure notify_new_content();
 
 
 -- Asynchronous notification of new origin insertions
 create function notify_new_origin()
   returns trigger
   language plpgsql
 as $$
   begin
     perform pg_notify('new_origin', json_build_object(
       'url', new.url::text,
       'type', new.type::text
     )::text);
     return null;
   end;
 $$;
 
 create trigger notify_new_origin
   after insert on origin
   for each row
   execute procedure notify_new_origin();
 
 
 -- Asynchronous notification of new skipped content insertions
 create function notify_new_skipped_content()
   returns trigger
   language plpgsql
 as $$
   begin
     perform pg_notify('new_skipped_content', json_build_object(
       'sha1', encode(new.sha1, 'hex'),
       'sha1_git', encode(new.sha1_git, 'hex'),
       'sha256', encode(new.sha256, 'hex'),
       'blake2s256', encode(new.blake2s256, 'hex')
     )::text);
     return null;
   end;
 $$;
 
 create trigger notify_new_skipped_content
   after insert on skipped_content
   for each row
   execute procedure notify_new_skipped_content();
 
 
 -- Asynchronous notification of new directory insertions
 create function notify_new_directory()
   returns trigger
   language plpgsql
 as $$
   begin
     perform pg_notify('new_directory', json_build_object('id', encode(new.id, 'hex'))::text);
     return null;
   end;
 $$;
 
 create trigger notify_new_directory
   after insert on directory
   for each row
   execute procedure notify_new_directory();
 
 
 -- Asynchronous notification of new revision insertions
 create function notify_new_revision()
   returns trigger
   language plpgsql
 as $$
   begin
     perform pg_notify('new_revision', json_build_object('id', encode(new.id, 'hex'))::text);
     return null;
   end;
 $$;
 
 create trigger notify_new_revision
   after insert on revision
   for each row
   execute procedure notify_new_revision();
 
 
 -- Asynchronous notification of new origin visits
 create function notify_new_origin_visit()
   returns trigger
   language plpgsql
 as $$
   begin
     perform pg_notify('new_origin_visit', json_build_object(
       'origin', new.origin,
       'visit', new.visit
     )::text);
     return null;
   end;
 $$;
 
 create trigger notify_new_origin_visit
   after insert on origin_visit
   for each row
   execute procedure notify_new_origin_visit();
 
 
--- Asynchronous notification of modified origin visits
-create function notify_changed_origin_visit()
-  returns trigger
-  language plpgsql
-as $$
-  begin
-    perform pg_notify('new_origin_visit', json_build_object(
-      'origin', new.origin,
-      'visit', new.visit
-    )::text);
-    return null;
-  end;
-$$;
-
 create trigger notify_changed_origin_visit
   after update on origin_visit
   for each row
-  execute procedure notify_changed_origin_visit();
+  execute procedure notify_new_origin_visit();
 
 
 -- Asynchronous notification of new release insertions
 create function notify_new_release()
   returns trigger
   language plpgsql
 as $$
   begin
     perform pg_notify('new_release', json_build_object('id', encode(new.id, 'hex'))::text);
     return null;
   end;
 $$;
 
 create trigger notify_new_release
   after insert on release
   for each row
   execute procedure notify_new_release();
 
 
 -- Asynchronous notification of new snapshot insertions
 create function notify_new_snapshot()
   returns trigger
   language plpgsql
 as $$
   begin
     perform pg_notify('new_snapshot', json_build_object('id', encode(new.id, 'hex'))::text);
     return null;
   end;
 $$;
 
 create trigger notify_new_snapshot
   after insert on snapshot
   for each row
   execute procedure notify_new_snapshot();