@@ -320,7 +320,7 @@ def __call__(self, path: TypedAttributePath, transaction: SubscriptionTransactio
320
320
"""This is the subscription callback when an attribute is updated.
321
321
It checks the passed in attribute is the same as the subscribed to attribute and
322
322
then posts it into the queue for later processing."""
323
-
323
+
324
324
asserts .assert_equal (path .AttributeType , self ._expected_attribute ,
325
325
f"[AttributeChangeCallback] Attribute mismatch. Expected: { self ._expected_attribute } , received: { path .AttributeType } " )
326
326
logging .info (f"[AttributeChangeCallback] Attribute update callback for { path .AttributeType } " )
@@ -331,13 +331,15 @@ def wait_for_report(self):
331
331
try :
332
332
path , transaction = self ._output .get (block = True , timeout = 10 )
333
333
except queue .Empty :
334
- asserts .fail (f"[AttributeChangeCallback] Failed to receive a report for the { self ._expected_attribute } attribute change" )
334
+ asserts .fail (
335
+ f"[AttributeChangeCallback] Failed to receive a report for the { self ._expected_attribute } attribute change" )
335
336
336
337
asserts .assert_equal (path .AttributeType , self ._expected_attribute ,
337
338
f"[AttributeChangeCallback] Received incorrect report. Expected: { self ._expected_attribute } , received: { path .AttributeType } " )
338
339
try :
339
340
attribute_value = transaction .GetAttribute (path )
340
- logging .info (f"[AttributeChangeCallback] Got attribute subscription report. Attribute { path .AttributeType } . Updated value: { attribute_value } . SubscriptionId: { transaction .subscriptionId } " )
341
+ logging .info (
342
+ f"[AttributeChangeCallback] Got attribute subscription report. Attribute { path .AttributeType } . Updated value: { attribute_value } . SubscriptionId: { transaction .subscriptionId } " )
341
343
except KeyError :
342
344
asserts .fail ("[AttributeChangeCallback] Attribute {expected_attribute} not found in returned report" )
343
345
0 commit comments