Billy McMonagle01/06/2023, 9:19 PM
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?
@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), )
Mason Menges01/06/2023, 9:29 PM
Billy McMonagle01/06/2023, 9:48 PM
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.