What i want to be able to do it carry on the chain...
# ask-community
a
What i want to be able to do it carry on the chain of maps to esseintialy do this:
hosts_data = cid.map(get_token).map(get_hosts_data).map(flatten_data).map(compare(mapped_data, db_cols)
I want to take the static value of db_cols, and pass it into the next mapped function (compare) alongside the dynaic data from the previous map. Here is the current code, how would I achieve that?
Copy code
@op()
def compare(host_data, db_cols):
    ...

@job
def test_pipeline():
    cid = get_cids()
    
    db_cols = get_db_cols()
    hosts_data = cid.map(get_token).map(get_hosts_data).map(flatten_data)
y