def METHOD_NAME(_):
    class MyIOManager(IOManager):
        def handle_output(self, context, obj):
            storage_dict[tuple(context.get_run_scoped_output_identifier())] = {
                "value": obj,
                "output_manager_name": name,
            }
        def load_input(self, context):
            result = storage_dict[
                tuple(context.upstream_output.get_run_scoped_output_identifier())
            ]
            return {**result, "input_manager_name": name}
    return MyIOManager()