polish

chanzuckerberg · Apr 14, 2020 · 1049ab4 · 1049ab4
1 parent 88ff4e7
commit 1049ab4
Showing 1 changed file with 3 additions and 5 deletions.
diff --git a/WDL/runtime/task.py b/WDL/runtime/task.py
@@ -481,11 +481,9 @@ def _run(
                 while exit_code is None:
                     time.sleep(random.uniform(1.0, 2.0))  # spread out work over the GIL
                     if terminating():
-                        quiet = (  # suppress log noise if docker task only sat in the queue
-                            self._observed_states.intersection(
-                                {"(UNKNOWN)", "new", "allocated", "pending"}
-                            )
-                            == self._observed_states
+                        quiet = not self._observed_states.difference(
+                            # reduce log noise if the terminated task only sat in docker's queue
+                            {"(UNKNOWN)", "new", "allocated", "pending"}
                         )
                         if not quiet:
                             self.poll_service(logger, svc, verbose=True)