I have a quick question: how can I set a flow_run_id within the call of a

FLOW_OBJ.run()

? I'm currently doing the following:

with prefect.context(flow_run_id="asdf"):
            EMAIL.run(flow_run_id="asdfasdf", name="TEST")

neither (context, nor the variable in the kwargs of the

run

function) actually change the flow_run_id when its output in the logger 😞 Do I need to wrap the flow_run_id in a state variable? If so whats the best way to do this? Finally, I'm running this flow over a dask cluster so idk if my issue here is affected by this issue: https://github.com/PrefectHQ/prefect/issues/2883

Hi @Michael Reeves - are you trying to do this purely with Core? If so, this isn't currently possible without overwriting the

flow.run

method since it's currently being reset there. This is something we can expose though to make it a mutable prop when running locally.

that would be wonderful 🙂

we can make this PR quickly if you’re willing to work off the master branch

yeah I can do that

We'll have to open and merge a PR to allow that first @Michael Reeves

anything I can do to help?

if you’d like to make the PR that’d be cool! You need to loop over each of these variables: https://github.com/PrefectHQ/prefect/blob/a88c86174b70b9de6c110f1c1524b70d4b18b96e/src/prefect/core/flow.py#L1002-L1007 and use

flow_run_context.setdefault(key, value)

Ok wasn't running master branch, but now I am 😄 Yup EZ, is there a format I should follow for the PR?

once you make that change, run

black .

on the codebase to format it

idk if I have the

black

binary on my computer?

run

pip install black

and that’s all you need

sorry that took a while haha, heres the PR: https://github.com/PrefectHQ/prefect/pull/3163

Awesome thanks! I gave you a suggestion to simplify it

ok fixed it

So setdefault is essentially “if the key does not already exist in the dictionary, use this value, else just keep it as-is”

sweet!

yea no problem!