def METHOD_NAME(context):
    all_asset_a_events = context.materialization_records_for_key(
        asset_key=AssetKey("asset_a"), limit=5
    )
    if len(all_asset_a_events) == 5:
        context.advance_cursor({AssetKey("asset_a"): all_asset_a_events[-1]})
        return RunRequest(
            run_key=context.cursor,
            run_config={
                "ops": {
                    "log_asset_sensor": {
                        "config": {"message": f"Asset events dict {all_asset_a_events}"}
                    }
                }
            },
        )