Skip to content

Commit 3801f0e

Browse files
committed
feat(schema): add new fields to task query result
1 parent 063161c commit 3801f0e

File tree

2 files changed

+6
-0
lines changed

2 files changed

+6
-0
lines changed

README.md

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -54,6 +54,7 @@ c.download_artifact(
5454

5555
| **Mitosis** | **pynetmito** |
5656
| :---------: | :-----------: |
57+
| 0.6.1 | 0.2.2 |
5758
| 0.6.0 | 0.2.1 |
5859
| 0.6.0 | 0.2.0 |
5960
| 0.5.3 | 0.1.3 |

src/pynetmito/schemas.py

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -241,6 +241,7 @@ class TaskResultMessage(str, Enum):
241241
RESOURCE_FORBIDDEN = "ResourceForbidden"
242242
WATCH_TIMEOUT = "WatchTimeout"
243243
USER_CANCELLATION = "UserCancellation"
244+
SUBMIT_NEW_TASK_FAILED = "SubmitNewTaskFailed"
244245

245246

246247
class RemoteResourceArtifact(BaseAPIModel):
@@ -432,6 +433,8 @@ class TaskQueryInfo(BaseAPIModel):
432433
priority: int
433434
spec: dict
434435
result: Optional[dict] = Field(default=None)
436+
upstream_task_uuid: Optional[UUID4] = Field(default=None)
437+
downstream_task_uuid: Optional[UUID4] = Field(default=None)
435438

436439
@field_validator("created_at", mode="before")
437440
@classmethod
@@ -471,6 +474,8 @@ class ParsedTaskQueryInfo(BaseAPIModel):
471474
priority: int
472475
spec: TaskSpec
473476
result: Optional[TaskResultSpec] = Field(default=None)
477+
upstream_task_uuid: Optional[UUID4] = Field(default=None)
478+
downstream_task_uuid: Optional[UUID4] = Field(default=None)
474479

475480
@field_validator("created_at", mode="before")
476481
@classmethod

0 commit comments

Comments
 (0)