, each time with different parameters.
something of the sort:
Copy code
@flow
def go_eat():
...
@flow
def main():
animals = ['dog', 'cat', 'monkey']
for animal in animals:
go_eat(animal)
I want to make those
go_eat
flows to run in parallel, and I wonder how to implement this.
it would be best if I could make up to 2 animals to
go_eat
in parallel, but no more than that.
I'm not sure if I somehow better use the prefect queue concurrency mechanism, or if I better implement this in pure python.
any suggestions?
Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.