[GO] `UpdateConcurrencyLimit` the concurrency limit is not reflecting in Kestra

[Pradumnasaraf]

Describe the issue

UpdateConcurrencyLimit the concurrency limit is not reflecting in Kestra

package main

import (
	"context"
	"encoding/json"
	"fmt"
	kestraClient "github.com/kestra-io/client-sdk/go-sdk/kestra_api_client"
	"os"
)

func main() {
	host := "http://localhost:8021"
	configuration := kestraClient.NewConfiguration()
	configuration.Servers = []kestraClient.ServerConfiguration{
		{URL: host},
	}
	apiClient := kestraClient.NewAPIClient(configuration)

	ctx := context.Background()
	ctx = context.WithValue(ctx, kestraClient.ContextBasicAuth, kestraClient.BasicAuth{
		UserName: "psaraf@kestra.io",
		Password: "Kestra@123",
	})
	flowId := "test1" // string | 
	namespace := "qa" // string | 
	tenant := "pradumnasaraf" // string | 
	running := int32(1)
	concurrencyLimit := *kestraClient.NewConcurrencyLimit(tenant, namespace, flowId) // ConcurrencyLimit |
	concurrencyLimit.Running = &running

	resp, r, err := apiClient.FlowsAPI.UpdateConcurrencyLimit(ctx, flowId, namespace, tenant).ConcurrencyLimit(concurrencyLimit).Execute()
	if err != nil {
		fmt.Fprintf(os.Stderr, "❌ Error calling UpdateConcurrencyLimit: %v\n", err)
		if r != nil {
			fmt.Fprintf(os.Stderr, "❌ HTTP status: %s\n", r.Status)
		}
		if gErr, ok := err.(*kestraClient.GenericOpenAPIError); ok {
			if body := gErr.Body(); len(body) > 0 {
				fmt.Fprintf(os.Stderr, "❌ Response body: %s\n", string(body))
			}
		}
		return
	}

	// Print response.
	if b, mErr := json.MarshalIndent(resp, "", "  "); mErr == nil {
		fmt.Fprintf(os.Stdout, "✅ Response:\n%s\n", string(b))
	} else {
		fmt.Fprintf(os.Stdout, "✅ Response: %+v\n", resp)
	}

}

Environment

• Kestra Version: develop

[AcevedoR]

I think you need to set a concurrency first in the flow or something like this, I dont know very well this api but I think it's the same in Kestra api

[Pradumnasaraf]

So if I set the concurrency to 1 and I have 4 executions in the queue, then I update it to 3, will it release the two more from the queue, and will the executions start running? I’m not sure; this method is very confusing. I tested too: https://jam.dev/c/a68f5df6-eab4-4e5d-b3e4-d9654d5d7ad4 Can you check and clarify?

[Ben8t]

For ref. it might be this part in the UI. Not something in the flow definition itself. To be checked