Skip to content

Commit 0b025b8

Browse files
authored
feat: add runs to pipeline in openhexa client (#290)
1 parent 0033704 commit 0b025b8

File tree

4 files changed

+51
-1
lines changed

4 files changed

+51
-1
lines changed

openhexa/graphql/graphql_client/__init__.py

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -336,6 +336,9 @@
336336
PipelinePipelineByCodeNewTemplateVersions,
337337
PipelinePipelineByCodeRecipients,
338338
PipelinePipelineByCodeRecipientsUser,
339+
PipelinePipelineByCodeRuns,
340+
PipelinePipelineByCodeRunsItems,
341+
PipelinePipelineByCodeRunsItemsUser,
339342
PipelinePipelineByCodeSourceTemplate,
340343
)
341344
from .pipelines import (
@@ -612,6 +615,9 @@
612615
"PipelinePipelineByCodeNewTemplateVersions",
613616
"PipelinePipelineByCodeRecipients",
614617
"PipelinePipelineByCodeRecipientsUser",
618+
"PipelinePipelineByCodeRuns",
619+
"PipelinePipelineByCodeRunsItems",
620+
"PipelinePipelineByCodeRunsItemsUser",
615621
"PipelinePipelineByCodeSourceTemplate",
616622
"PipelineRecipientError",
617623
"PipelineRunOrderBy",

openhexa/graphql/graphql_client/client.py

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -175,6 +175,18 @@ def pipeline(
175175
}
176176
createdAt
177177
}
178+
runs(orderBy: EXECUTION_DATE_DESC, page: 1, perPage: 10) {
179+
items {
180+
id
181+
status
182+
executionDate
183+
user {
184+
id
185+
displayName
186+
email
187+
}
188+
}
189+
}
178190
webhookUrl
179191
webhookEnabled
180192
schedule

openhexa/graphql/graphql_client/pipeline.py

Lines changed: 21 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
from pydantic import Field
77

88
from .base_model import BaseModel
9-
from .enums import PipelineType
9+
from .enums import PipelineRunStatus, PipelineType
1010

1111

1212
class Pipeline(BaseModel):
@@ -22,6 +22,7 @@ class PipelinePipelineByCode(BaseModel):
2222
current_version: Optional["PipelinePipelineByCodeCurrentVersion"] = Field(
2323
alias="currentVersion"
2424
)
25+
runs: "PipelinePipelineByCodeRuns"
2526
webhook_url: Optional[str] = Field(alias="webhookUrl")
2627
webhook_enabled: bool = Field(alias="webhookEnabled")
2728
schedule: Optional[str]
@@ -56,6 +57,23 @@ class PipelinePipelineByCodeCurrentVersionUserAvatar(BaseModel):
5657
color: str
5758

5859

60+
class PipelinePipelineByCodeRuns(BaseModel):
61+
items: List["PipelinePipelineByCodeRunsItems"]
62+
63+
64+
class PipelinePipelineByCodeRunsItems(BaseModel):
65+
id: Any
66+
status: PipelineRunStatus
67+
execution_date: Optional[Any] = Field(alias="executionDate")
68+
user: Optional["PipelinePipelineByCodeRunsItemsUser"]
69+
70+
71+
class PipelinePipelineByCodeRunsItemsUser(BaseModel):
72+
id: Any
73+
display_name: str = Field(alias="displayName")
74+
email: str
75+
76+
5977
class PipelinePipelineByCodeSourceTemplate(BaseModel):
6078
id: Any
6179
code: str
@@ -82,4 +100,6 @@ class PipelinePipelineByCodeRecipientsUser(BaseModel):
82100
PipelinePipelineByCode.model_rebuild()
83101
PipelinePipelineByCodeCurrentVersion.model_rebuild()
84102
PipelinePipelineByCodeCurrentVersionUser.model_rebuild()
103+
PipelinePipelineByCodeRuns.model_rebuild()
104+
PipelinePipelineByCodeRunsItems.model_rebuild()
85105
PipelinePipelineByCodeRecipients.model_rebuild()

openhexa/graphql/queries.graphql

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -44,6 +44,18 @@ query Pipeline($workspaceSlug: String!, $pipelineCode: String!) {
4444
}
4545
createdAt
4646
}
47+
runs(orderBy: EXECUTION_DATE_DESC, page: 1, perPage: 10) {
48+
items {
49+
id
50+
status
51+
executionDate
52+
user {
53+
id
54+
displayName
55+
email
56+
}
57+
}
58+
}
4759
webhookUrl
4860
webhookEnabled
4961
schedule

0 commit comments

Comments
 (0)