Hey, I am running a flow locally and have another flow deployed in the cloud. I loop over something and create multiple sub flows.

create_flow_run.run(
            flow_name="advanced_cleaning",
            project_name="modelling",
            run_name=f"data_update={data_update}",
            parameters=dict(data_update=data_update),
        )

When I run this it is called multiple times, but only one sometimes two flows are triggered in the cloud, is this a possible bug? Do run names need to be unique? This is being called from within a task fyi

This has to do with the idempotency key. These tasks use the context task run id as the default idempotency key. Multiple invocations will use the same key and only trigger one flow run, so you need to supply multiple idempotency keys to generate multiple runs

are there any examples of this? I dont really get what you are saying, where do I get the idempotency key from ? And why does it work fine when it is running from the cloud flow and not locally?

You can just supply any string as the idempotency key so you can do something like datetime.now() as a string and it will trigger multiple runs

got it, thanks mate

That was added actually let me see the changelog

ah ok, any breaking changes I should be aware of if I upgrade?

From 0.15.5 to 0.15.8 should be absolutely nothing

incredible

You seen to be up super late?

it is 7.40am 😆

Ah lol cuz you normally ping later in the day

yeah, I usually start work, then get stuck and you save me lol