I want to define a piece of metadata on a graph_asset, and have that metadata be accessible via the context in ops

[achen187]

I basically want something like this:

@graph_asset(
    config={"my_key": "my_value"},
    tags={"my_key" "my_value"},
    metadata={"my_key": "my_value"})
def dummy_asset():
    return dummy_op_2(dummy_op())

@op
def dummy_op_2(context, dummy_op):
    value = context.getConfig("my_key")
    value = context.getTag("my_key")
    value = context.getMetadata("my_key")

@op
def dummy_op(context):
    value = context.getConfig("my_key")
    value = context.getTag("my_key")
    value = context.getMetadata("my_key")

I tried using Resources for this, but I actually have multiple graph_assets in my Definition that may each have a different value for "my_key".

Whats the best path forward for something like this?

[jamiedemaria]

Using metadata you can do something like this

@op
def dummy_op_2(context, dummy_op):
    value = context.assets_def.metadata_by_key[dummy_asset.key]
    context.log.info(value)

@op
def dummy_op(context):
    value = context.assets_def.metadata_by_key[dummy_asset.key]
    context.log.info(value)


@graph_asset(
    metadata={"my_key": "my_value"})
def dummy_asset():
    return dummy_op_2(dummy_op())

with config you could do something like this

@op(
    config_schema={"value": str}
)
def dummy_op_2(context, dummy_op):
    value = context.op_config["value"]
    context.log.info(value)

@op(
    config_schema={"value": str}
)
def dummy_op(context):
    value = context.op_config["value"]
    context.log.info(value)


@graph_asset(
    config={
        "dummy_op": {
            "config": { "value": "my_value" }
        },
        "dummy_op_2": {
            "config": { "value": "my_value" }
        }
    },
)
def dummy_asset():
    return dummy_op_2(dummy_op())

[zcemycl]

Very helpful, it is hard to understand from the docs.