How can I fetch the Dagster run Ids of the input assets of a job

[jhygate]

Hi, love Dagster, it's been a pleasure to work with and has been working wonders!

I am attempting to record a link between separate runs. I want to access the Dagster run_id for each of the input assets to a job. This is so that I can link my Mlfow runs together (by using the dagster run_ids as identifiers).

Any ideas on where I can start to look?

def _get_latest_run_id(context: AssetExecutionContext, asset_name: str) -> str | None:

    dag_instance = context._op_execution_context.instance
    record = dag_instance.get_latest_data_version_record(context.asset_key_for_input(asset_name))

This is what I'm using at the moment (I didn't write it so don't particularly know the context) - any hints?

[jhygate]

Oops - just discovered partition_key argument for dag_instance.get_latest_data_version_record.

This looks like it solves my issue