Hi all, I'm trying a test job for multi-asset, with the asset decoration like this

@multi_asset(
    partitions_def=daily_partitions,
    can_subset=True,
    required_resource_keys={"my_client"},
    outs={
        "A": AssetOut(
            key_prefix=["raw"],
        ),
        "B": AssetOut(
            key_prefix=["raw"],
        ),
    }
)
def my_assets(context):
    for obj in context.selected_output_names:
        yield Output(value=<some_value>, output_name=obj)

And here is my test job:

@repository
def my_repo():
    return [
        with_resources(
            load_assets_from_package_module(raw),
            resource_defs=get_env_resources(deployment_env),
        ),
        ScheduleDefinition(
            job=define_asset_job("test_job", selection=["raw/A"]), cron_schedule="@daily"
        ),
    ]

my_repo().get_all_jobs()[1].execute_in_process(partition_key="2022-08-10")

I got the following error

DagsterStepOutputNotFoundError: Core compute for op "my_assets" did not return an output for non-optional output "B"

I wonder why that error, when I have already set

can_subset=True

? Thanks

I know this got resolved in the other thread, but adding the answer so others can find it too!