Samuel Stütz
11/08/2022, 1:10 PMAn exception was thrown during execution that is likely a framework error, rather than an error in user code.
dagster._check.CheckError: Invariant failed. Description: all_assets_materialize has no op named account10__loadtest1__asset1.
We tried some loadtest of dagit. And generated all this generic assets in a factory. Locally this execution works but on k8s deployed it fails
these are the asset ops
@asset(key_prefix=context.asset_key_prefix(), name=asset_name, ins={"upstream": AssetIn(key=upstream_key)}, group_name=asset_group_name, partitions_def=daily_partitions_definition)
def anAsset(upstream):
time.sleep(asset_materialization_sleep_sec)
return 42
assets += [anAsset]
dagster v 1.0.16yuhan
11/11/2022, 2:18 AM