I have a fanned out op that uses an IOManager that takes the data and some metadata, writes the data to one database and the metadata to another. When we fan back in the op, I would like to collect that metadata in the

load_input

by reading from the database for the specific keys that we fanned out on, and then concatenate all that data together at the end. What would be the best way of passing that information to the

load_input

for any downstream assets? When I try to use

context.upstream_output.metadata

I get a KeyError