hatchet-dev/hatchet py/1.40.0 on GitHub

Overview

Added support for tenant-scoped shared concurrency strategies. Declare a ConcurrencyExpression with is_tenant_scoped=True and a name, and reference the same name from the concurrency list of tasks in different workflows so they share a single concurrency limit. Tenant-scoped entries can be mixed with ordinary workflow-scoped entries on the same task.
ConcurrencyExpression.max_runs now accepts int | str: a string is a CEL expression over task input computing the max runs for each concurrency group, so different groups (e.g. pricing tiers) can have different limits.
Fixes another durable callback ordering bug which would cause NonDeterminismErrors to be raised on replay in the case where e.g. children were spawned recursively, concurrently.
Makes workflows register concurrently on start to speed up worker boot time

Install the SDK using pip:

pip install hatchet-sdk

Or using poetry:

poetry add hatchet-sdk

For detailed documentation, examples, and best practices, visit:

feat(sdks): new concurrency features (dynamic max runs, tenant-scoped concurrency) (#4873) by @abelanger5