👋 we launched a workflow on the UI setting max parallelism and the Flyte UI in the execution shows the

Parallelism

attribute as

5

but the workflow executed with more than 5 tasks in parallel. Are we misunderstanding the parallelism attribute or is there a bug here?

Hm, that pretty much captures it. The test code I wrote is:

@task
def simple_task(idx: int) -> str:
    time.sleep(30)
    return f"task{idx}"
@dynamic
def run_tasks(n: int) -> List[str]:
    out = []
    for i in range(n):
        out.append(simple_task(i))
    return out

@workflow
def cttx_labeling() -> List[str]:
    return run_tasks(10)

are they all marked as Running or just Queued or Unknown state or are there actually more than 5 pods running in k8s

looking at our k8s dashboard I do see that 10 pods were in the

Running

phase concurrently

Yes, they were all immediately marked as running

hmm odd, what i usually see is 5 tasks in dynamic task will be running and other 5 are set to queued or unknown

@gentle-night-59824 I wonder why this doesn’t work for us

I'm not sure either - let me try repro-ing this and I'll look into it

Hey all! We encountered the same issue with max parallelism set to 5 *by default. Where is the exact location to configure the

MaxParallelism

value in the Helm chart? Thanks!

@elegant-toddler-67101, you should be able to configure it via flytectl: https://flyte-org.slack.com/archives/CP2HDHKE1/p1687109097892189?thread_ts=1687103342.136149&cid=CP2HDHKE1.

Is it not supported in the helm chart?

I think it should be supported. Do you have a

flyte-admin-base-config

config map in your deployment?