|
8 | 8 | from infrahub_sdk.exceptions import BranchNotFoundError, URLNotFoundError |
9 | 9 | from infrahub_sdk.node import InfrahubNode |
10 | 10 | from infrahub_sdk.schema import ProfileSchemaAPI |
11 | | -from infrahub_sdk.task.models import Task, TaskFilter, TaskState |
| 11 | +from infrahub_sdk.task.models import Task, TaskFilter, TaskLog, TaskState |
12 | 12 | from infrahub_sdk.testing.docker import TestInfrahubDockerClient |
13 | 13 | from infrahub_sdk.testing.schemas.animal import TESTING_ANIMAL, TESTING_CAT, TESTING_DOG, TESTING_PERSON, SchemaAnimal |
14 | 14 |
|
@@ -199,11 +199,14 @@ async def test_task_query(self, client: InfrahubClient, base_dataset, set_pagina |
199 | 199 | assert task |
200 | 200 | assert isinstance(task, Task) |
201 | 201 |
|
202 | | - # Query Task with logs |
203 | | - task = await client.task.get(id=tasks[0].id, include_logs=True) |
204 | | - assert task |
205 | | - assert isinstance(task, Task) |
206 | | - assert task.logs |
| 202 | + # Query Tasks with logs |
| 203 | + tasks = await client.task.filter(filter=TaskFilter(state=[TaskState.COMPLETED]), include_logs=True) |
| 204 | + all_logs = [log for task in tasks for log in task.logs] |
| 205 | + assert all_logs |
| 206 | + assert isinstance(all_logs[0], TaskLog) |
| 207 | + assert all_logs[0].message |
| 208 | + assert all_logs[0].timestamp |
| 209 | + assert all_logs[0].severity |
207 | 210 |
|
208 | 211 | # async def test_get_generic_filter_source(self, client: InfrahubClient, base_dataset): |
209 | 212 | # admin = await client.get(kind="CoreAccount", name__value="admin") |
|
0 commit comments