Michael Reeves
08/14/2020, 8:24 PMFLOW_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/2883nicholas
08/14/2020, 9:26 PMflow.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.Michael Reeves
08/14/2020, 9:28 PMflow.run()
?
Thanks for the help 🙂Chris White
08/14/2020, 9:30 PMMichael Reeves
08/14/2020, 9:31 PMnicholas
08/14/2020, 9:31 PMMichael Reeves
08/14/2020, 9:32 PMChris White
08/14/2020, 9:33 PMflow_run_context.setdefault(key, value)
Michael Reeves
08/14/2020, 9:34 PMChris White
08/14/2020, 9:35 PMblack .
on the codebase to format itMichael Reeves
08/14/2020, 9:35 PMblack
binary on my computer?Chris White
08/14/2020, 9:35 PMpip install black
and that’s all you needMichael Reeves
08/14/2020, 11:42 PMChris White
08/14/2020, 11:58 PMMichael Reeves
08/15/2020, 12:13 AMChris White
08/15/2020, 12:14 AMMichael Reeves
08/15/2020, 12:22 AMChris White
08/15/2020, 1:39 AM