Kendal Burkhart
11/16/2021, 7:33 PMwith flow("api") as flow:
client = get_client(api_key, api_secret)
main = get_data(client)
mapped = get_mapped_data.map(prefect.unmapped(client), main)
The issue is that sometimes the flow can run for more than an hour,
at which time the access token for the API expires. (and 1 hour is max
that issuer allows) I can catch the error in a mapped task and try doing a token refresh.
But I'm unsure whether the new token will be available to mapped tasks, or
if each mapped task will end up requesting it's own new token, or something
else different entirely.
I guess I'm asking what the best way is to address this problem.
Thanks!Kevin Kho
Kevin Kho