fix: check if vertex is in vertices_being_run to check if it is runnable (#2668)

Co-authored-by: Cristhian Zanforlin Lousa <72977554+Cristhianzl@users.noreply.github.com>
This commit is contained in:
Gabriel Luiz Freitas Almeida 2024-07-12 17:26:05 -03:00 committed by GitHub
commit f5f5141cc4
No known key found for this signature in database
GPG key ID: B5690EEEBB952194

View file

@ -50,7 +50,10 @@ class RunnableVerticesManager:
"""Determines if a vertex is runnable."""
return (
vertex.is_active() and self.are_all_predecessors_fulfilled(vertex.id) and vertex.id in self.vertices_to_run
vertex.is_active()
and self.are_all_predecessors_fulfilled(vertex.id)
and vertex.id in self.vertices_to_run
and vertex.id not in self.vertices_being_run
)
def are_all_predecessors_fulfilled(self, vertex_id: str) -> bool: