Billy McMonagle
01/06/2023, 9:19 PM@flow
async def show_parameters(foo=1, bar=2):
flow_run_context = FlowRunContext.get()
parameters = flow_run_context.flow_run.parameters
await send_incoming_webhook_message.fn(
slack_webhook=SlackWebhook(url=SLACK_WEBHOOK_URL),
text=str(parameters),
)
The parameters are definitely passed into the flow, but aren't available from the context. When I run a similar flow locally, I am able to get the parameters with this method. Is it something to do with the execution environment?Mason Menges
01/06/2023, 9:29 PMBilly McMonagle
01/06/2023, 9:48 PM@flow(persist_result=True
and it didn't work. I'll dig into it a bit more but it's surprising to me that these would be related. Everything is happening inside a single kubernetes job, nothing is being distributed. It's not really worth messing around with persistance, this is a relatively small issue and I'm sure I can work around it.