Fix flake8 lint (#6712)

Author: wxtim

tests/integration/scripts/test_set.py

@@ -19,16 +19,18 @@
 Note: see also functional tests
 """
 
-import logging
+from typing import Callable
+
 import pytest
 
 from cylc.flow.cycling.integer import IntegerPoint
 from cylc.flow.data_messages_pb2 import PbTaskProxy
 from cylc.flow.data_store_mgr import TASK_PROXIES
 from cylc.flow.scheduler import Scheduler
-from cylc.flow.task_state import TASK_STATUS_SUCCEEDED, TASK_STATUS_WAITING
-
-from typing import Callable
+from cylc.flow.task_state import (
+    TASK_STATUS_SUCCEEDED,
+    TASK_STATUS_WAITING,
+)
 
 
 async def test_set_parentless_spawning(

tests/integration/test_task_pool.py

@@ -14,6 +14,7 @@
 # You should have received a copy of the GNU General Public License
 # along with this program.  If not, see <http://www.gnu.org/licenses/>.
 
+from json import loads
 import logging
 from typing import (
     TYPE_CHECKING,
@@ -22,38 +23,42 @@
     Iterable,
     List,
     Tuple,
-    Union
+    Union,
 )
 
 import pytest
 from pytest import param
-from json import loads
 
-from cylc.flow import CYLC_LOG
-from cylc.flow import commands
+from cylc.flow import (
+    CYLC_LOG,
+    commands,
+)
 from cylc.flow.cycling.integer import IntegerPoint
 from cylc.flow.cycling.iso8601 import ISO8601Point
 from cylc.flow.data_messages_pb2 import PbPrerequisite
 from cylc.flow.data_store_mgr import TASK_PROXIES
+from cylc.flow.flow_mgr import (
+    FLOW_ALL,
+    FLOW_NONE,
+)
 from cylc.flow.task_events_mgr import TaskEventsManager
 from cylc.flow.task_outputs import (
+    TASK_OUTPUT_FAILED,
     TASK_OUTPUT_SUCCEEDED,
-    TASK_OUTPUT_FAILED
 )
-
-from cylc.flow.flow_mgr import FLOW_ALL, FLOW_NONE
 from cylc.flow.task_proxy import TaskProxy
 from cylc.flow.task_state import (
-    TASK_STATUS_WAITING,
+    TASK_STATUS_EXPIRED,
+    TASK_STATUS_FAILED,
     TASK_STATUS_PREPARING,
-    TASK_STATUS_SUBMITTED,
     TASK_STATUS_RUNNING,
-    TASK_STATUS_SUCCEEDED,
-    TASK_STATUS_FAILED,
-    TASK_STATUS_EXPIRED,
     TASK_STATUS_SUBMIT_FAILED,
+    TASK_STATUS_SUBMITTED,
+    TASK_STATUS_SUCCEEDED,
+    TASK_STATUS_WAITING,
 )
 
+
 if TYPE_CHECKING:
     from cylc.flow.cycling import PointBase
     from cylc.flow.scheduler import Scheduler
@@ -1805,7 +1810,9 @@ async def test_compute_runahead_with_no_tasks(flow, scheduler, run):
         assert schd.pool.get_tasks() == []
 
 
-async def test_compute_runahead_with_no_sequences(flow, scheduler, start, run, complete):
+async def test_compute_runahead_with_no_sequences(
+    flow, scheduler, start, run, complete
+):
     """It should handle no sequences within the start-stop cycle range.
 
     See https://github.com/cylc/cylc-flow/issues/6154
@@ -1815,9 +1822,9 @@ async def test_compute_runahead_with_no_sequences(flow, scheduler, start, run, c
             'cycling mode': 'integer',
             'initial cycle point': '1',
             'graph': {
-               'P1': 'foo[-P1] => foo'
-            }
-        }
+                'P1': 'foo[-P1] => foo',
+            },
+        },
     }
     id_ = flow(cfg)
     schd = scheduler(id_, paused_start=False)

tests/unit/test_taskdef.py

@@ -103,7 +103,6 @@ def test_generate_graph_parents_2(tmp_flow_config):
     ]
 
 
-
 @pytest.mark.parametrize(
     "task, point, expected",
     [