mirror of
https://github.com/hatchet-dev/hatchet.git
synced 2025-12-30 05:09:44 -06:00
8e80faf2d6
* api changes * doc changes * move docs * generated * generate * pkg * backmerge main * revert to main * revert main * race? * remove go tests
16 lines
305 B
Python
16 lines
305 B
Python
from examples.concurrency_limit_rr.worker import (
|
|
WorkflowInput,
|
|
concurrency_limit_rr_workflow,
|
|
)
|
|
from hatchet_sdk import Hatchet
|
|
|
|
hatchet = Hatchet()
|
|
|
|
for i in range(200):
|
|
group = "0"
|
|
|
|
if i % 2 == 0:
|
|
group = "1"
|
|
|
|
concurrency_limit_rr_workflow.run(WorkflowInput(group=group))
|