def METHOD_NAME():
    @observable_source_asset
    def foo(_context) -> DataVersion:
        return DataVersion("alpha")
    instance = DagsterInstance.ephemeral()
    result = observe([foo], instance=instance, tags={"key1": "value1"})
    assert result.success
    assert result.dagster_run.tags == {"key1": "value1"}