Skip to content

Commit 1a635a2

Browse files
committed
Fix flake8 lint
1 parent 59f3da4 commit 1a635a2

File tree

3 files changed

+29
-21
lines changed

3 files changed

+29
-21
lines changed

tests/integration/scripts/test_set.py

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -19,16 +19,18 @@
1919
Note: see also functional tests
2020
"""
2121

22-
import logging
22+
from typing import Callable
23+
2324
import pytest
2425

2526
from cylc.flow.cycling.integer import IntegerPoint
2627
from cylc.flow.data_messages_pb2 import PbTaskProxy
2728
from cylc.flow.data_store_mgr import TASK_PROXIES
2829
from cylc.flow.scheduler import Scheduler
29-
from cylc.flow.task_state import TASK_STATUS_SUCCEEDED, TASK_STATUS_WAITING
30-
31-
from typing import Callable
30+
from cylc.flow.task_state import (
31+
TASK_STATUS_SUCCEEDED,
32+
TASK_STATUS_WAITING,
33+
)
3234

3335

3436
async def test_set_parentless_spawning(

tests/integration/test_task_pool.py

Lines changed: 23 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -14,6 +14,7 @@
1414
# You should have received a copy of the GNU General Public License
1515
# along with this program. If not, see <http://www.gnu.org/licenses/>.
1616

17+
from json import loads
1718
import logging
1819
from typing import (
1920
TYPE_CHECKING,
@@ -22,38 +23,42 @@
2223
Iterable,
2324
List,
2425
Tuple,
25-
Union
26+
Union,
2627
)
2728

2829
import pytest
2930
from pytest import param
30-
from json import loads
3131

32-
from cylc.flow import CYLC_LOG
33-
from cylc.flow import commands
32+
from cylc.flow import (
33+
CYLC_LOG,
34+
commands,
35+
)
3436
from cylc.flow.cycling.integer import IntegerPoint
3537
from cylc.flow.cycling.iso8601 import ISO8601Point
3638
from cylc.flow.data_messages_pb2 import PbPrerequisite
3739
from cylc.flow.data_store_mgr import TASK_PROXIES
40+
from cylc.flow.flow_mgr import (
41+
FLOW_ALL,
42+
FLOW_NONE,
43+
)
3844
from cylc.flow.task_events_mgr import TaskEventsManager
3945
from cylc.flow.task_outputs import (
46+
TASK_OUTPUT_FAILED,
4047
TASK_OUTPUT_SUCCEEDED,
41-
TASK_OUTPUT_FAILED
4248
)
43-
44-
from cylc.flow.flow_mgr import FLOW_ALL, FLOW_NONE
4549
from cylc.flow.task_proxy import TaskProxy
4650
from cylc.flow.task_state import (
47-
TASK_STATUS_WAITING,
51+
TASK_STATUS_EXPIRED,
52+
TASK_STATUS_FAILED,
4853
TASK_STATUS_PREPARING,
49-
TASK_STATUS_SUBMITTED,
5054
TASK_STATUS_RUNNING,
51-
TASK_STATUS_SUCCEEDED,
52-
TASK_STATUS_FAILED,
53-
TASK_STATUS_EXPIRED,
5455
TASK_STATUS_SUBMIT_FAILED,
56+
TASK_STATUS_SUBMITTED,
57+
TASK_STATUS_SUCCEEDED,
58+
TASK_STATUS_WAITING,
5559
)
5660

61+
5762
if TYPE_CHECKING:
5863
from cylc.flow.cycling import PointBase
5964
from cylc.flow.scheduler import Scheduler
@@ -1805,7 +1810,9 @@ async def test_compute_runahead_with_no_tasks(flow, scheduler, run):
18051810
assert schd.pool.get_tasks() == []
18061811

18071812

1808-
async def test_compute_runahead_with_no_sequences(flow, scheduler, start, run, complete):
1813+
async def test_compute_runahead_with_no_sequences(
1814+
flow, scheduler, start, run, complete
1815+
):
18091816
"""It should handle no sequences within the start-stop cycle range.
18101817
18111818
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
18151822
'cycling mode': 'integer',
18161823
'initial cycle point': '1',
18171824
'graph': {
1818-
'P1': 'foo[-P1] => foo'
1819-
}
1820-
}
1825+
'P1': 'foo[-P1] => foo',
1826+
},
1827+
},
18211828
}
18221829
id_ = flow(cfg)
18231830
schd = scheduler(id_, paused_start=False)

tests/unit/test_taskdef.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -103,7 +103,6 @@ def test_generate_graph_parents_2(tmp_flow_config):
103103
]
104104

105105

106-
107106
@pytest.mark.parametrize(
108107
"task, point, expected",
109108
[

0 commit comments

Comments
 (0)