@@ -53,7 +53,10 @@ func (api *API) templateVersion(rw http.ResponseWriter, r *http.Request) {
53 53
ctx := r.Context()
54 54
templateVersion := httpmw.TemplateVersionParam(r)
55 55 56 -
jobs, err := api.Database.GetProvisionerJobsByIDsWithQueuePosition(ctx, []uuid.UUID{templateVersion.JobID})
56 +
jobs, err := api.Database.GetProvisionerJobsByIDsWithQueuePosition(ctx, database.GetProvisionerJobsByIDsWithQueuePositionParams{
57 +
IDs: []uuid.UUID{templateVersion.JobID},
58 +
StaleIntervalMS: provisionerdserver.StaleInterval.Milliseconds(),
59 +
})
57 60
if err != nil || len(jobs) == 0 {
58 61
httpapi.Write(ctx, rw, http.StatusInternalServerError, codersdk.Response{
59 62
Message: "Internal error fetching provisioner job.",
@@ -182,7 +185,10 @@ func (api *API) patchTemplateVersion(rw http.ResponseWriter, r *http.Request) {
182 185
return
183 186
}
184 187 185 -
jobs, err := api.Database.GetProvisionerJobsByIDsWithQueuePosition(ctx, []uuid.UUID{templateVersion.JobID})
188 +
jobs, err := api.Database.GetProvisionerJobsByIDsWithQueuePosition(ctx, database.GetProvisionerJobsByIDsWithQueuePositionParams{
189 +
IDs: []uuid.UUID{templateVersion.JobID},
190 +
StaleIntervalMS: provisionerdserver.StaleInterval.Milliseconds(),
191 +
})
186 192
if err != nil || len(jobs) == 0 {
187 193
httpapi.Write(ctx, rw, http.StatusInternalServerError, codersdk.Response{
188 194
Message: "Internal error fetching provisioner job.",
@@ -733,7 +739,10 @@ func (api *API) fetchTemplateVersionDryRunJob(rw http.ResponseWriter, r *http.Re
733 739
return database.GetProvisionerJobsByIDsWithQueuePositionRow{}, false
734 740
}
735 741 736 -
jobs, err := api.Database.GetProvisionerJobsByIDsWithQueuePosition(ctx, []uuid.UUID{jobUUID})
742 +
jobs, err := api.Database.GetProvisionerJobsByIDsWithQueuePosition(ctx, database.GetProvisionerJobsByIDsWithQueuePositionParams{
743 +
IDs: []uuid.UUID{jobUUID},
744 +
StaleIntervalMS: provisionerdserver.StaleInterval.Milliseconds(),
745 +
})
737 746
if httpapi.Is404Error(err) {
738 747
httpapi.Write(ctx, rw, http.StatusNotFound, codersdk.Response{
739 748
Message: fmt.Sprintf("Provisioner job %q not found.", jobUUID),
@@ -865,7 +874,10 @@ func (api *API) templateVersionsByTemplate(rw http.ResponseWriter, r *http.Reque
865 874
for _, version := range versions {
866 875
jobIDs = append(jobIDs, version.JobID)
867 876
}
868 -
jobs, err := store.GetProvisionerJobsByIDsWithQueuePosition(ctx, jobIDs)
877 +
jobs, err := store.GetProvisionerJobsByIDsWithQueuePosition(ctx, database.GetProvisionerJobsByIDsWithQueuePositionParams{
878 +
IDs: jobIDs,
879 +
StaleIntervalMS: provisionerdserver.StaleInterval.Milliseconds(),
880 +
})
869 881
if err != nil {
870 882
httpapi.Write(ctx, rw, http.StatusInternalServerError, codersdk.Response{
871 883
Message: "Internal error fetching provisioner job.",
@@ -933,7 +945,10 @@ func (api *API) templateVersionByName(rw http.ResponseWriter, r *http.Request) {
933 945
})
934 946
return
935 947
}
936 -
jobs, err := api.Database.GetProvisionerJobsByIDsWithQueuePosition(ctx, []uuid.UUID{templateVersion.JobID})
948 +
jobs, err := api.Database.GetProvisionerJobsByIDsWithQueuePosition(ctx, database.GetProvisionerJobsByIDsWithQueuePositionParams{
949 +
IDs: []uuid.UUID{templateVersion.JobID},
950 +
StaleIntervalMS: provisionerdserver.StaleInterval.Milliseconds(),
951 +
})
937 952
if err != nil || len(jobs) == 0 {
938 953
httpapi.Write(ctx, rw, http.StatusInternalServerError, codersdk.Response{
939 954
Message: "Internal error fetching provisioner job.",
@@ -1013,7 +1028,10 @@ func (api *API) templateVersionByOrganizationTemplateAndName(rw http.ResponseWri
1013 1028
})
1014 1029
return
1015 1030
}
1016 -
jobs, err := api.Database.GetProvisionerJobsByIDsWithQueuePosition(ctx, []uuid.UUID{templateVersion.JobID})
1031 +
jobs, err := api.Database.GetProvisionerJobsByIDsWithQueuePosition(ctx, database.GetProvisionerJobsByIDsWithQueuePositionParams{
1032 +
IDs: []uuid.UUID{templateVersion.JobID},
1033 +
StaleIntervalMS: provisionerdserver.StaleInterval.Milliseconds(),
1034 +
})
1017 1035
if err != nil || len(jobs) == 0 {
1018 1036
httpapi.Write(ctx, rw, http.StatusInternalServerError, codersdk.Response{
1019 1037
Message: "Internal error fetching provisioner job.",
@@ -1115,7 +1133,10 @@ func (api *API) previousTemplateVersionByOrganizationTemplateAndName(rw http.Res
1115 1133
return
1116 1134
}
1117 1135 1118 -
jobs, err := api.Database.GetProvisionerJobsByIDsWithQueuePosition(ctx, []uuid.UUID{previousTemplateVersion.JobID})
1136 +
jobs, err := api.Database.GetProvisionerJobsByIDsWithQueuePosition(ctx, database.GetProvisionerJobsByIDsWithQueuePositionParams{
1137 +
IDs: []uuid.UUID{previousTemplateVersion.JobID},
1138 +
StaleIntervalMS: provisionerdserver.StaleInterval.Milliseconds(),
1139 +
})
1119 1140
if err != nil || len(jobs) == 0 {
1120 1141
httpapi.Write(ctx, rw, http.StatusInternalServerError, codersdk.Response{
1121 1142
Message: "Internal error fetching provisioner job.",
RetroSearch is an open source project built by @garambo | Open a GitHub Issue
Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo
HTML:
3.2
| Encoding:
UTF-8
| Version:
0.7.4