#231

Author: paxtonhare

marklogic-data-hub/src/main/resources/ml-modules/root/com.marklogic.hub/lib/flow-lib.xqy

@@ -516,6 +516,8 @@ declare function flow:run-flow(
   $content as item()?,
   $options as map:map) as empty-sequence()
 {
+  (: assert that we are in query mode :)
+  let $_ts as xs:unsignedLong := xdmp:request-timestamp()
   let $envelope := flow:run-plugins($flow, $identifier, $content, $options)
   let $_ :=
     for $writer in $flow/hub:writer
@@ -760,9 +762,20 @@ declare function flow:run-writer(
   let $before := xdmp:elapsed-time()
   let $resp :=
     try {
-      xdmp:invoke-function(function() {
+      xdmp:eval('
+        declare variable $func external;
+        declare variable $identifier external;
+        declare variable $envelope external;
+        declare variable $options external;
+
         $func($identifier, $envelope, $options)
-      },
+      ',
+      map:new((
+        map:entry("func", $func),
+        map:entry("identifier", $identifier),
+        map:entry("envelope", $envelope),
+        map:entry("options", $options)
+      )),
       map:new((
         map:entry("isolation", "different-transaction"),
         map:entry("database", xdmp:database($config:FINAL-DATABASE)),

marklogic-data-hub/src/main/resources/ml-modules/services/flow.xqy

@@ -71,7 +71,7 @@ declare function get(
  :
  : The flow xml is provided in the request body
  :)
-declare %rapi:transaction-mode("update") function post(
+declare function post(
   $context as map:map,
   $params  as map:map,
   $input   as document-node()*