Refactor set_cache_coro method call in RunnableVerticesManager

This commit is contained in:
Gabriel Luiz Freitas Almeida 2024-03-27 18:41:19 -03:00
commit ac17ab7ac6

View file

@ -85,7 +85,7 @@ class RunnableVerticesManager:
for v_id in set(next_runnable_vertices): # Use set to avoid duplicates
self.update_vertex_run_state(v_id, is_runnable=False)
self.remove_from_predecessors(v_id)
await set_cache_coro(graph, lock)
await set_cache_coro(data=graph, lock=lock)
return next_runnable_vertices
@staticmethod