Total Complexity | 3 |
Total Lines | 13 |
Duplicated Lines | 0 % |
Changes | 0 |
1 | import asyncio |
||
2 | |||
3 | from gremlin_python.process import traversal |
||
4 | |||
5 | |||
6 | class AsyncTraversalStrategies(traversal.TraversalStrategies): |
||
7 | |||
8 | async def apply_strategies(self, traversal): |
||
9 | for traversal_strategy in self.traversal_strategies: |
||
10 | func = traversal_strategy.apply(traversal) |
||
11 | if asyncio.iscoroutine(func): |
||
12 | await func |
||
13 |