File tree 1 file changed +0
-17
lines changed
1 file changed +0
-17
lines changed Original file line number Diff line number Diff line change @@ -391,23 +391,6 @@ def attribute_report_counts(self) -> dict[ClusterObjects.ClusterAttributeDescrip
391
391
def attribute_reports (self ) -> dict [ClusterObjects .ClusterAttributeDescriptor , AttributeValue ]:
392
392
return self ._attribute_reports
393
393
394
-
395
- class AttributeChangeCallback :
396
- def __init__ (self , expected_attribute : ClusterObjects .ClusterAttributeDescriptor ):
397
- self ._output = queue .Queue ()
398
- self ._expected_attribute = expected_attribute
399
-
400
- def __call__ (self , path : TypedAttributePath , transaction : SubscriptionTransaction ):
401
- """This is the subscription callback when an attribute is updated.
402
- It checks the passed in attribute is the same as the subscribed to attribute and
403
- then posts it into the queue for later processing."""
404
-
405
- asserts .assert_equal (path .AttributeType , self ._expected_attribute ,
406
- f"[AttributeChangeCallback] Attribute mismatch. Expected: { self ._expected_attribute } , received: { path .AttributeType } " )
407
- logging .info (f"[AttributeChangeCallback] Attribute update callback for { path .AttributeType } " )
408
- q = (path , transaction )
409
- self ._output .put (q )
410
-
411
394
def wait_for_report (self ):
412
395
try :
413
396
path , transaction = self ._output .get (block = True , timeout = 10 )
You can’t perform that action at this time.
0 commit comments