Skip to content

Commit

Permalink
Add to wait terminate states
Browse files Browse the repository at this point in the history
  • Loading branch information
greenape committed Jun 16, 2022
1 parent ac314d8 commit 0360181
Showing 1 changed file with 5 additions and 1 deletion.
6 changes: 5 additions & 1 deletion flowmachine/flowmachine/core/query_state.py
Original file line number Diff line number Diff line change
Expand Up @@ -377,6 +377,10 @@ def wait_until_complete(self, sleep_duration=1):
"""
if self.is_executing or self.is_queued or self.is_resetting:
while not (
self.is_finished_executing or self.is_cancelled or self.is_known
self.is_finished_executing
or self.is_cancelled
or self.is_known
or self.is_errored
or self.is_errored_in_reset
):
_sleep(sleep_duration)

0 comments on commit 0360181

Please sign in to comment.