|
33 | 33 |
|
34 | 34 |
|
35 | 35 | def test_to_sdk_task_state() -> None: |
36 | | - assert to_sdk_task_state(vertexai_types.State.STATE_UNSPECIFIED) == TaskState.unknown |
37 | | - assert to_sdk_task_state(vertexai_types.State.SUBMITTED) == TaskState.submitted |
| 36 | + assert ( |
| 37 | + to_sdk_task_state(vertexai_types.State.STATE_UNSPECIFIED) |
| 38 | + == TaskState.unknown |
| 39 | + ) |
| 40 | + assert ( |
| 41 | + to_sdk_task_state(vertexai_types.State.SUBMITTED) == TaskState.submitted |
| 42 | + ) |
38 | 43 | assert to_sdk_task_state(vertexai_types.State.WORKING) == TaskState.working |
39 | | - assert to_sdk_task_state(vertexai_types.State.COMPLETED) == TaskState.completed |
40 | | - assert to_sdk_task_state(vertexai_types.State.CANCELLED) == TaskState.canceled |
| 44 | + assert ( |
| 45 | + to_sdk_task_state(vertexai_types.State.COMPLETED) == TaskState.completed |
| 46 | + ) |
| 47 | + assert ( |
| 48 | + to_sdk_task_state(vertexai_types.State.CANCELLED) == TaskState.canceled |
| 49 | + ) |
41 | 50 | assert to_sdk_task_state(vertexai_types.State.FAILED) == TaskState.failed |
42 | | - assert to_sdk_task_state(vertexai_types.State.REJECTED) == TaskState.rejected |
| 51 | + assert ( |
| 52 | + to_sdk_task_state(vertexai_types.State.REJECTED) == TaskState.rejected |
| 53 | + ) |
43 | 54 | assert ( |
44 | 55 | to_sdk_task_state(vertexai_types.State.INPUT_REQUIRED) |
45 | 56 | == TaskState.input_required |
46 | 57 | ) |
47 | 58 | assert ( |
48 | | - to_sdk_task_state(vertexai_types.State.AUTH_REQUIRED) == TaskState.auth_required |
| 59 | + to_sdk_task_state(vertexai_types.State.AUTH_REQUIRED) |
| 60 | + == TaskState.auth_required |
49 | 61 | ) |
50 | 62 | assert to_sdk_task_state(999) == TaskState.unknown # type: ignore |
51 | 63 |
|
52 | 64 |
|
53 | 65 | def test_to_stored_task_state() -> None: |
54 | 66 | assert ( |
55 | | - to_stored_task_state(TaskState.unknown) == vertexai_types.State.STATE_UNSPECIFIED |
| 67 | + to_stored_task_state(TaskState.unknown) |
| 68 | + == vertexai_types.State.STATE_UNSPECIFIED |
| 69 | + ) |
| 70 | + assert ( |
| 71 | + to_stored_task_state(TaskState.submitted) |
| 72 | + == vertexai_types.State.SUBMITTED |
| 73 | + ) |
| 74 | + assert ( |
| 75 | + to_stored_task_state(TaskState.working) == vertexai_types.State.WORKING |
| 76 | + ) |
| 77 | + assert ( |
| 78 | + to_stored_task_state(TaskState.completed) |
| 79 | + == vertexai_types.State.COMPLETED |
| 80 | + ) |
| 81 | + assert ( |
| 82 | + to_stored_task_state(TaskState.canceled) |
| 83 | + == vertexai_types.State.CANCELLED |
56 | 84 | ) |
57 | | - assert to_stored_task_state(TaskState.submitted) == vertexai_types.State.SUBMITTED |
58 | | - assert to_stored_task_state(TaskState.working) == vertexai_types.State.WORKING |
59 | | - assert to_stored_task_state(TaskState.completed) == vertexai_types.State.COMPLETED |
60 | | - assert to_stored_task_state(TaskState.canceled) == vertexai_types.State.CANCELLED |
61 | 85 | assert to_stored_task_state(TaskState.failed) == vertexai_types.State.FAILED |
62 | | - assert to_stored_task_state(TaskState.rejected) == vertexai_types.State.REJECTED |
| 86 | + assert ( |
| 87 | + to_stored_task_state(TaskState.rejected) |
| 88 | + == vertexai_types.State.REJECTED |
| 89 | + ) |
63 | 90 | assert ( |
64 | 91 | to_stored_task_state(TaskState.input_required) |
65 | 92 | == vertexai_types.State.INPUT_REQUIRED |
|
0 commit comments