RepeatStep does not appear to respect barriers

I was digging into some traversal performance and had something similar to the following:

g.V(<ids>).repeat(out()).until(out().count().is(0)).toList()

g.V(<ids>).repeat(out()).until(out().count().is(0)).toList()

g.V(<ids>).repeat(out()).until(out().count().is(0)).toList()

g.V(<ids>).repeat(out()).until(out().count().is(0)).toList()

For the graph implementation in question,

out()

out()

out()

out() is implemented on top of a

CollectingBarrierStep

CollectingBarrierStep

CollectingBarrierStep

CollectingBarrierStep.

I noticed that that fact is not respected by the repeat and it only gets 1 item at a time, i.e no aggregation.

I removed my strategy and changed the query to:

g.V(<ids>).repeat(barrier(10).out()).times(2).toList()

g.V(<ids>).repeat(barrier(10).out()).times(2).toList()

g.V(<ids>).repeat(barrier(10).out()).times(2).toList()

g.V(<ids>).repeat(barrier(10).out()).times(2).toList()

and then put breakpoints in the

FlatMapStep

FlatMapStep

FlatMapStep

FlatMapStep and it seemed that the barrier was still not respected and items came in 1 at a time.

Fully verifying this is an issue is difficult and I'd be surprised that this was not noticed before. Has anyone noticed anything similar or have reason to believe this is not the case?

RepeatStep does not appear to respect barriers

Similar Threads

Similar Threads

Similar Threads