code: def __init__(self, priority_fn=None, qux="", resource="", retries=0):
      self.priority_fn = priority_fn or (lambda k: 0)
      self.qux = qux
      self.resource = resource
      self.retries = retries
  
      self.priority_matches = 0
      self.resource_matches = 0
      self.retry_matches = 0
      self.qux_matches = 0
  
file_path: distributed/distributed/protocol/tests/test_highlevelgraph.py
imports: from __future__ import annotations
  import pytest
  from numpy.testing import assert_array_equal
  import dask
  import dask.array
  import dask.dataframe
  from distributed.diagnostics import SchedulerPlugin
  from distributed.utils_test import gen_cluster
label_desc: Use image node_id 1 to create a new ExampleAnnotationPlugin object from inherited base classes: SchedulerPlugin with example: obj = ExampleAnnotationPlugin(priority_fn, qux, resource, retries)