diff --git a/cmd/osbuild-worker/main.go b/cmd/osbuild-worker/main.go index 310952b0e..61a15ff60 100644 --- a/cmd/osbuild-worker/main.go +++ b/cmd/osbuild-worker/main.go @@ -15,6 +15,7 @@ import ( "github.com/BurntSushi/toml" + "github.com/osbuild/osbuild-composer/internal/common" "github.com/osbuild/osbuild-composer/internal/upload/azure" "github.com/osbuild/osbuild-composer/internal/upload/koji" "github.com/osbuild/osbuild-composer/internal/worker" @@ -228,7 +229,7 @@ func main() { for { fmt.Println("Waiting for a new job...") - job, err := client.RequestJob(acceptedJobTypes) + job, err := client.RequestJob(acceptedJobTypes, common.CurrentArch()) if err != nil { log.Fatal(err) } diff --git a/internal/worker/client.go b/internal/worker/client.go index 0337b7859..be1856a28 100644 --- a/internal/worker/client.go +++ b/internal/worker/client.go @@ -15,7 +15,7 @@ import ( "time" "github.com/google/uuid" - "github.com/osbuild/osbuild-composer/internal/common" + "github.com/osbuild/osbuild-composer/internal/worker/api" ) @@ -162,7 +162,7 @@ func (c *Client) NewRequest(method, url string, body io.Reader) (*http.Request, return req, nil } -func (c *Client) RequestJob(types []string) (Job, error) { +func (c *Client) RequestJob(types []string, arch string) (Job, error) { url, err := c.server.Parse("jobs") if err != nil { // This only happens when "jobs" cannot be parsed. @@ -172,7 +172,7 @@ func (c *Client) RequestJob(types []string) (Job, error) { var buf bytes.Buffer err = json.NewEncoder(&buf).Encode(api.RequestJobJSONRequestBody{ Types: types, - Arch: common.CurrentArch(), + Arch: arch, }) if err != nil { panic(err)