Roman Maliushkin
06/01/2023, 1:15 PM@op(
ins={
"some_asset": In(asset_key=AssetKey(["path"]))
}
)
def some_op(context: OpExecutionContext, some_asset: DataFrame):
<http://context.log.info|context.log.info>(some_asset.count())
What I get:
dagster._core.errors.DagsterInvariantViolationError: Attempting to access asset_key, but no asset is associated with this input
But I am sure I have an asset_key
with key "path"Zach
06/01/2023, 3:01 PMclaire
06/01/2023, 5:04 PM