-
Notifications
You must be signed in to change notification settings - Fork 495
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[drqYtb6r] apoc.cypher.run* procedures don't return results (extended) #3624
Conversation
460e4df
to
5373354
Compare
ee5791d
to
9e8be28
Compare
9e8be28
to
3c20805
Compare
@@ -385,7 +387,7 @@ public Stream<MapResult> parallel2(@Name("fragment") String fragment, @Name("par | |||
} | |||
return futures.stream().flatMap(f -> { | |||
try { | |||
return f.get().stream().map(MapResult::new); | |||
return EntityUtil.anyRebind(tx, f.get()).stream().map(MapResult::new); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Why this?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
We need to do the entity rebind of the result f.get()
(which can be a Map.of("key", <ENTITY>)
)
in order to avoid the error The transaction has been closed.
,
e.g. with the testCypherParallel2WithResults
case.
@vga91 do we need to rebind also other methods like |
The other procedures work also without rebind. I created tests similar to |
* [drqYtb6r] apoc.cypher.run* procedures don't return results (neo4j/apoc#431) * [drqYtb6r] apoc.cypher.run* procedures don't return results * [drqYtb6r] fixed docker tests * [drqYtb6r] added test with other apoc.cpyher.run* procedures * [drqYtb6r] apoc.cypher.run* procedures don't return results (extended) (#3624)
apoc.cypher.parallel
andapoc.cypher.runFile(s)
CypherExtendedTest
toCypherEnterpriseExtendedTest
apoc.cypher.*
procedure to check other potential similar cases.