https://dagster.io/ logo
Title
s

Samuel Stütz

11/08/2022, 1:10 PM
Has anyone come across an Error like this before?
An 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.16
y

yuhan

11/11/2022, 2:18 AM
do you mind sharing more details about how you deploy the code to k8s?