diff --git a/syncapi/storage/postgres/syncserver.go b/syncapi/storage/postgres/syncserver.go index a6e6ff141..cdd661cfd 100644 --- a/syncapi/storage/postgres/syncserver.go +++ b/syncapi/storage/postgres/syncserver.go @@ -172,11 +172,11 @@ func (d *SyncServerDatasource) WriteEvent( } pduPosition = pos - if err = d.handleBackwardExtremities(ctx, ev); err != nil { + if err = d.topology.insertEventInTopology(ctx, ev); err != nil { return err } - if err = d.topology.insertEventInTopology(ctx, ev); err != nil { + if err = d.handleBackwardExtremities(ctx, ev); err != nil { return err }