Skip to content

Commit 63f4250

Browse files
committed
Ignore typing issues.
1 parent 96592c4 commit 63f4250

File tree

3 files changed

+11
-6
lines changed

3 files changed

+11
-6
lines changed

src/pytask_parallel/execute.py

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -282,12 +282,14 @@ def _update_carry_over_node(
282282
return x
283283
raise NotImplementedError
284284

285-
structure_carry_over_products = tree_structure(carry_over_products)
286-
structure_produces = tree_structure(task.produces)
285+
structure_carry_over_products = tree_structure(carry_over_products) # type: ignore[arg-type]
286+
structure_produces = tree_structure(task.produces) # type: ignore[arg-type]
287287
# strict must be false when none is leaf.
288288
if structure_produces.is_prefix(structure_carry_over_products, strict=False):
289289
task.produces = tree_map(
290-
_update_carry_over_node, task.produces, carry_over_products
290+
_update_carry_over_node,
291+
task.produces, # type: ignore[arg-type]
292+
carry_over_products, # type: ignore[arg-type]
291293
) # type: ignore[assignment]
292294

293295

src/pytask_parallel/wrappers.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -267,7 +267,7 @@ def _save_and_carry_over_product(
267267
node.save(value)
268268
return None
269269

270-
return tree_map_with_path(_save_and_carry_over_product, task.produces)
270+
return tree_map_with_path(_save_and_carry_over_product, task.produces) # type: ignore[arg-type]
271271

272272

273273
def _write_local_files_to_remote(
@@ -279,7 +279,7 @@ def _write_local_files_to_remote(
279279
to be resolved.
280280
281281
"""
282-
return tree_map(lambda x: x.load() if isinstance(x, RemotePathNode) else x, kwargs) # type: ignore[return-value]
282+
return tree_map(lambda x: x.load() if isinstance(x, RemotePathNode) else x, kwargs) # type: ignore[arg-type, return-value]
283283

284284

285285
def _delete_local_files_on_remote(kwargs: dict[str, PyTree[Any]]) -> None:
@@ -296,4 +296,4 @@ def _delete(potential_node: Any) -> None:
296296
os.close(potential_node.fd)
297297
Path(potential_node.remote_path).unlink(missing_ok=True)
298298

299-
tree_map(_delete, kwargs)
299+
tree_map(_delete, kwargs) # type: ignore[arg-type]

tox.ini

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -14,6 +14,9 @@ extras =
1414
commands = mypy
1515

1616
[testenv:test]
17+
deps =
18+
pytask; python_version >= '3.9'
19+
pytask<0.5.2; python_version < '3.9'
1720
extras = test
1821
commands =
1922
pytest {posargs}

0 commit comments

Comments
 (0)