Skip to content

Commit

Permalink
Merge pull request #1550 from jluebbe/fix-typo
Browse files Browse the repository at this point in the history
remote/coordinator: fix typo
  • Loading branch information
Emantor authored Nov 22, 2024
2 parents b90ac44 + 3d53eb8 commit a919c66
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions labgrid/remote/coordinator.py
Original file line number Diff line number Diff line change
Expand Up @@ -309,7 +309,7 @@ async def request_task():
except Exception:
logging.exception("error in client message handler")

runnning_request_task = self.loop.create_task(request_task())
running_request_task = self.loop.create_task(request_task())

try:
async for out_msg in queue_as_aiter(out_msg_queue):
Expand All @@ -323,8 +323,8 @@ async def request_task():
logging.info("Never received startup from peer %s that disconnected", peer)
return

runnning_request_task.cancel()
await runnning_request_task
running_request_task.cancel()
await running_request_task
logging.debug("client aborted %s, cancelled: %s", session, context.cancelled())

def _add_default_place(self, name):
Expand Down Expand Up @@ -405,7 +405,7 @@ async def request_task():
except Exception:
logging.exception("error in exporter message handler")

runnning_request_task = self.loop.create_task(request_task())
running_request_task = self.loop.create_task(request_task())

try:
async for cmd in queue_as_aiter(command_queue):
Expand All @@ -419,8 +419,8 @@ async def request_task():
except Exception:
logging.exception("error in exporter command handler")
finally:
runnning_request_task.cancel()
await runnning_request_task
running_request_task.cancel()
await running_request_task

try:
session = self.exporters.pop(peer)
Expand Down

0 comments on commit a919c66

Please sign in to comment.