diff --git a/archiver/pipelines/archive-resource.xpl b/archiver/pipelines/archive-resource.xpl index 59cbc3b..fdaad97 100644 --- a/archiver/pipelines/archive-resource.xpl +++ b/archiver/pipelines/archive-resource.xpl @@ -222,6 +222,9 @@ for $as in /archive-set + + + @@ -237,7 +240,7 @@ for $q in /queue return insert for $href in distinct-values($links/link/@abs-href) let $link := $links/link[@abs-href = $href][1] - return + return into $q, for $a in /queue/action where $a/@uuid = $(uuid) return diff --git a/archiver/pipelines/archive-set.xpl b/archiver/pipelines/archive-set.xpl index 62334ed..8f89fa7 100644 --- a/archiver/pipelines/archive-set.xpl +++ b/archiver/pipelines/archive-set.xpl @@ -31,6 +31,9 @@ + + + @@ -45,7 +48,7 @@ declare namespace util = "http://exist-db.org/xquery/util"; for $q in /queue return update - insert + insert into $q, for $a in /queue/action where $a/@uuid = $(uuid) return diff --git a/archiver/pipelines/post-archive-request.xpl b/archiver/pipelines/post-archive-request.xpl index 1fc5885..41df24a 100644 --- a/archiver/pipelines/post-archive-request.xpl +++ b/archiver/pipelines/post-archive-request.xpl @@ -23,7 +23,7 @@ declare namespace util = "http://exist-db.org/xquery/util"; for $q in /queue return update - insert + insert into $q ]]> diff --git a/archiver/pipelines/scheduler.xpl b/archiver/pipelines/scheduler.xpl index 8f60dfe..ca19fb3 100644 --- a/archiver/pipelines/scheduler.xpl +++ b/archiver/pipelines/scheduler.xpl @@ -19,8 +19,8 @@