🐛 FIX: Ignore exists seq on changes worker (#253)

cnpm · Jun 27, 2022 · d578baf · d578baf
1 parent c63159d
commit d578baf
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/app/core/service/ChangesStreamService.ts b/app/core/service/ChangesStreamService.ts
@@ -145,7 +145,7 @@ export class ChangesStreamService extends AbstractService {
         for (const change of data.results) {
           const seq = change.seq;
           const fullname = change.id;
-          if (seq && fullname) {
+          if (seq && fullname && seq !== since) {
             await this.packageSyncerService.createTask(fullname, {
               authorIp: os.hostname(),
               authorId: 'ChangesStreamService',