client.cli.workflow.concurrency

Workflow concurrency command.

Functions

validate_max_tasks(→ int)	Validate that max_tasks is non-negative.
concurrency(→ None)	Dynamically adjust concurrent task limit.

Module Contents

client.cli.workflow.concurrency.validate_max_tasks(ctx: click.Context, param: click.Parameter, value: int) → int

Validate that max_tasks is non-negative.

client.cli.workflow.concurrency.concurrency(workflow_id: int, max_tasks: int) → None

Dynamically adjust concurrent task limit.

Change the maximum number of tasks that can run concurrently for a running workflow. Setting to 0 effectively pauses the workflow.

b .. rubric:: Examples

# Set concurrency limit to 100 jobmon workflow concurrency -w 12345 -m 100

# Pause workflow (set to 0) jobmon workflow concurrency -w 12345 -m 0