Skip to content

Commit 421212d

Browse files
committed
revert to 0.13
1 parent 45b62b0 commit 421212d

File tree

19 files changed

+191
-1064
lines changed

19 files changed

+191
-1064
lines changed

changelog/+infrahubctl_errors.changed.md

Lines changed: 0 additions & 1 deletion
This file was deleted.

changelog/3900.fixed.md

Lines changed: 0 additions & 1 deletion
This file was deleted.

changelog/3908.added.md

Lines changed: 0 additions & 1 deletion
This file was deleted.

changelog/4056.fixed.md

Lines changed: 0 additions & 1 deletion
This file was deleted.

infrahub_sdk/batch.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@ class BatchTask:
1010
task: Callable[[Any], Awaitable[Any]]
1111
args: tuple[Any, ...]
1212
kwargs: dict[str, Any]
13-
node: Optional[Any] = None
13+
node: Optional[InfrahubNode] = None
1414

1515

1616
async def execute_batch_task_in_pool(
@@ -43,7 +43,9 @@ def __init__(
4343
def num_tasks(self) -> int:
4444
return len(self._tasks)
4545

46-
def add(self, *args: Any, task: Callable, node: Optional[Any] = None, **kwargs: Any) -> None:
46+
def add(
47+
self, *args: Any, task: Callable[[Any], Awaitable[Any]], node: Optional[InfrahubNode] = None, **kwargs: Any
48+
) -> None:
4749
self._tasks.append(BatchTask(task=task, node=node, args=args, kwargs=kwargs))
4850

4951
async def execute(self) -> AsyncGenerator:

0 commit comments

Comments
 (0)