@@ -1030,7 +1030,6 @@ async def WaitForActive(self, nodeid, *, timeoutSeconds=30.0, stayActiveDuration
1030
1030
await WaitForCheckIn (ScopedNodeId (nodeid , self ._fabricIndex ), timeoutSeconds = timeoutSeconds )
1031
1031
return await self .SendCommand (nodeid , 0 , Clusters .IcdManagement .Commands .StayActiveRequest (stayActiveDuration = stayActiveDurationMs ))
1032
1032
1033
-
1034
1033
async def GetConnectedDevice (self , nodeid , allowPASE : bool = True , timeoutMs : typing .Optional [int ] = None ,
1035
1034
payloadCapability : int = TransportPayloadCapability .MRP_PAYLOAD ):
1036
1035
''' Gets an OperationalDeviceProxy or CommissioneeDeviceProxy for the specified Node.
@@ -1199,11 +1198,11 @@ async def SendCommand(self, nodeid: int, endpoint: int, payload: ClusterObjects.
1199
1198
'''
1200
1199
self .CheckIsActive ()
1201
1200
1202
- eventLoop = asyncio .get_running_loop ()
1203
- future = eventLoop .create_future ()
1201
+ eventLoop = asyncio .get_running_loop ()
1202
+ future = eventLoop .create_future ()
1204
1203
1205
- device = await self .GetConnectedDevice (nodeid , timeoutMs = interactionTimeoutMs , payloadCapability = payloadCapability )
1206
- res = await ClusterCommand .SendCommand (
1204
+ device = await self .GetConnectedDevice (nodeid , timeoutMs = interactionTimeoutMs , payloadCapability = payloadCapability )
1205
+ res = await ClusterCommand .SendCommand (
1207
1206
future , eventLoop , responseType , device .deviceProxy , ClusterCommand .CommandPath (
1208
1207
EndpointId = endpoint ,
1209
1208
ClusterId = payload .cluster_id ,
0 commit comments