Skip to content

Commit be08a29

Browse files
committed
Removed utilisation of PipelineInfoMini as it had no utility
1 parent ffc3001 commit be08a29

File tree

2 files changed

+8
-15
lines changed

2 files changed

+8
-15
lines changed

shared.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -4567,7 +4567,7 @@ func HandleGetTriggers(resp http.ResponseWriter, request *http.Request) {
45674567
workflowsChan := make(chan []Workflow)
45684568
schedulesChan := make(chan []ScheduleOld)
45694569
hooksChan := make(chan []Hook)
4570-
pipelinesChan := make(chan []PipelineInfoMini)
4570+
pipelinesChan := make(chan []PipelineInfo)
45714571

45724572
errChan := make(chan error)
45734573

@@ -4618,7 +4618,7 @@ func HandleGetTriggers(resp http.ResponseWriter, request *http.Request) {
46184618
return
46194619
}
46204620

4621-
pipelines := []PipelineInfoMini{}
4621+
pipelines := []PipelineInfo{}
46224622
for _, env := range environments {
46234623
if env.Archived {
46244624
continue
@@ -4674,7 +4674,7 @@ func HandleGetTriggers(resp http.ResponseWriter, request *http.Request) {
46744674

46754675
hookMap := map[string]Hook{}
46764676
scheduleMap := map[string]ScheduleOld{}
4677-
pipelineMap := map[string]PipelineInfoMini{}
4677+
pipelineMap := map[string]PipelineInfo{}
46784678

46794679
for _, hook := range hooks {
46804680
hookMap[hook.Id] = hook

structs.go

Lines changed: 5 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -526,7 +526,7 @@ type Environment struct {
526526

527527
type LakeConfig struct {
528528
Enabled bool `json:"enabled" datastore:"enabled"`
529-
Pipelines []PipelineInfoMini `json:"pipelines" datastore:"pipelines"`
529+
Pipelines []PipelineInfo `json:"pipelines" datastore:"pipelines"`
530530
}
531531

532532
// Saves some data, not sure what to have here lol
@@ -2567,7 +2567,7 @@ type SubResponse struct {
25672567
}
25682568

25692569
type AllTriggersWrapper struct {
2570-
Pipelines []PipelineInfoMini `json:"pipelines"`
2570+
Pipelines []PipelineInfo `json:"pipelines"`
25712571
WebHooks []Hook `json:"webhooks"`
25722572
Schedules []ScheduleOld `json:"schedules"`
25732573
}
@@ -4462,16 +4462,6 @@ type DetectionResponse struct {
44624462
DownloadRepo string `json:"download_repo"`
44634463
}
44644464

4465-
type PipelineInfoMini struct {
4466-
Name string `json:"name"`
4467-
ID string `json:"id"`
4468-
Definition string `json:"definition"`
4469-
TotalRuns int `json:"total_runs"`
4470-
CreatedAt int64 `json:"created_at"`
4471-
4472-
Environment string `json:"environment"`
4473-
}
4474-
44754465
// The raw output from pipelines in Tenzir
44764466
type PipelineInfo struct {
44774467
ID string `json:"id"`
@@ -4502,6 +4492,9 @@ type PipelineInfo struct {
45024492
} `json:"autodelete"`
45034493
TTL any `json:"ttl"`
45044494
RemainingTTL any `json:"remaining_ttl"`
4495+
4496+
// Shuffle ref
4497+
Environment string `json:"environment"`
45054498
}
45064499

45074500
type PipelineInfoWrapper struct {

0 commit comments

Comments
 (0)