code: def __init__(self, *args, **kwargs):
      super().__init__(*args, **kwargs)
      self.counter = 0
  
file_path: distributed/distributed/shuffle/tests/test_disk_buffer.py
imports: from __future__ import annotations
  import asyncio
  import os
  from pathlib import Path
  from typing import Any
  import pytest
  from distributed.shuffle._disk import DiskShardsBuffer
  from distributed.shuffle._limiter import ResourceLimiter
  from distributed.utils_test import gen_test
label_desc: Use image node_id 1 to create a new EventuallyBrokenDiskShardsBuffer object from inherited base classes: DiskShardsBuffer with example: obj = EventuallyBrokenDiskShardsBuffer()