We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 8cb8ecd commit 89bc444Copy full SHA for 89bc444
labgrid/remote/coordinator.py
@@ -169,13 +169,22 @@ def __init__(self, request) -> None:
169
self.request = request
170
self.response = None
171
self.completed = asyncio.Event()
172
+ self.expired = False
173
174
def complete(self, response) -> None:
175
self.response = response
176
self.completed.set()
177
+ if self.expired:
178
+ logging.warning(
179
+ "exporter command already expired for request %s -> response %s", self.request, self.response
180
+ )
181
182
async def wait(self):
- await asyncio.wait_for(self.completed.wait(), 10)
183
+ try:
184
+ await asyncio.wait_for(self.completed.wait(), 10)
185
+ finally:
186
+ if self.response is None:
187
+ self.expired = True
188
189
190
class ExporterError(Exception):
0 commit comments