Source code for aiogremlin.remote.remote_connection
from gremlin_python.driver.remote_connection import RemoteStrategy
[docs]class AsyncRemoteStrategy(RemoteStrategy):
[docs] async def apply(self, traversal):
if traversal.traversers is None:
remote_traversal = await self.remote_connection.submit(
traversal.bytecode)
traversal.remote_results = remote_traversal
traversal.side_effects = remote_traversal.side_effects
traversal.traversers = remote_traversal.traversers