Skip to content

Commit

Permalink
owkmeans: Use invalidated state instead of blocking
Browse files Browse the repository at this point in the history
  • Loading branch information
ales-erjavec committed Nov 19, 2019
1 parent 2994f4e commit 73187d0
Show file tree
Hide file tree
Showing 2 changed files with 10 additions and 10 deletions.
6 changes: 3 additions & 3 deletions Orange/widgets/unsupervised/owkmeans.py
Original file line number Diff line number Diff line change
Expand Up @@ -322,7 +322,7 @@ def __commit_finished(self):
assert self.data is not None

self.__task = None
self.setBlocking(False)
self.setInvalidated(False)
self.progressBarFinished()

if self.optimize_k:
Expand Down Expand Up @@ -355,7 +355,7 @@ def __launch_tasks(self, ks):

self.__task = Task(futures, watcher)
self.progressBarInit()
self.setBlocking(True)
self.setInvalidated(True)

def cancel(self):
if self.__task is not None:
Expand All @@ -368,7 +368,7 @@ def cancel(self):
task.watcher.doneAll.disconnect(self.__commit_finished)

self.progressBarFinished()
self.setBlocking(False)
self.setInvalidated(False)

def run_optimization(self):
if not self.enough_data_instances(self.k_from):
Expand Down
14 changes: 7 additions & 7 deletions Orange/widgets/unsupervised/tests/test_owkmeans.py
Original file line number Diff line number Diff line change
Expand Up @@ -73,7 +73,7 @@ def test_optimization_report_display(self):
self.assertFalse(self.widget.mainArea.isHidden())
self.widget.apply_button.button.click()

self.wait_until_stop_blocking()
self.wait_until_finished()
self.assertEqual(self.widget.table_view.model().rowCount() > 0, True)

def test_changing_k_changes_radio(self):
Expand Down Expand Up @@ -284,13 +284,13 @@ def test_optimization_fails(self):

self.KMeansFail.fail_on = set(range(3, 9))
widget.invalidate()
self.wait_until_stop_blocking()
self.wait_until_finished()
self.assertTrue(widget.Error.failed.is_shown())
self.assertIsNone(self.get_output(self.widget.Outputs.annotated_data))

self.KMeansFail.fail_on = set()
widget.invalidate()
self.wait_until_stop_blocking()
self.wait_until_finished()
self.assertFalse(widget.Error.failed.is_shown())
self.assertEqual(widget.selected_row(), 0)
self.assertIsNotNone(self.get_output(self.widget.Outputs.annotated_data))
Expand All @@ -307,7 +307,7 @@ def test_run_fails(self):

self.KMeansFail.fail_on = set()
self.widget.invalidate()
self.wait_until_stop_blocking()
self.wait_until_finished()
self.assertFalse(self.widget.Error.failed.is_shown())
self.assertIsNotNone(self.get_output(self.widget.Outputs.annotated_data))

Expand Down Expand Up @@ -429,7 +429,7 @@ def test_invalidate_clusterings_cancels_jobs(self):
# Now, invalidate by changing max_iter
widget.max_iterations = widget.max_iterations + 1
widget.invalidate()
self.wait_until_stop_blocking()
self.wait_until_finished()

self.assertEqual(widget.clusterings, {})

Expand Down Expand Up @@ -513,7 +513,7 @@ def test_saved_selection(self):
self.widget.send_data = Mock()
self.widget.optimize_k = True
self.send_signal(self.widget.Inputs.data, self.data)
self.wait_until_stop_blocking()
self.wait_until_finished()
self.widget.table_view.selectRow(2)
self.assertEqual(self.widget.selected_row(), 2)
self.assertEqual(self.widget.send_data.call_count, 3)
Expand All @@ -522,7 +522,7 @@ def test_saved_selection(self):
w = self.create_widget(OWKMeans, stored_settings=settings)
w.send_data = Mock()
self.send_signal(w.Inputs.data, self.data, widget=w)
self.wait_until_stop_blocking(widget=w)
self.wait_until_finished(widget=w)
self.assertEqual(w.send_data.call_count, 2)
self.assertEqual(self.widget.selected_row(), w.selected_row())

Expand Down

0 comments on commit 73187d0

Please sign in to comment.