Skip to content

Commit

Permalink
suppress errors in openr
Browse files Browse the repository at this point in the history
Differential Revision: D53101222

fbshipit-source-id: abad8b6f0c6837ae90335c35178f8e8fbaa7d3e1
  • Loading branch information
generatedunixname89002005307016 authored and facebook-github-bot committed Jan 26, 2024
1 parent 47e852f commit 44db9a7
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 0 deletions.
3 changes: 3 additions & 0 deletions openr/py/openr/cli/commands/fib.py
Original file line number Diff line number Diff line change
Expand Up @@ -531,6 +531,9 @@ async def _run(
# Await for an update
if not awaited_updates:
awaited_updates = [updates.__anext__()]
# pyre-fixme[6]: For 1st argument expected `Iterable[Variable[_FT (bound
# to Future[typing.Any])]]` but got
# `Union[List[Awaitable[RouteDatabaseDelta]], Set[typing.Any]]`.
done, awaited_updates = await asyncio.wait(awaited_updates, timeout=1)
if not done:
continue
Expand Down
3 changes: 3 additions & 0 deletions openr/py/openr/cli/commands/kvstore.py
Original file line number Diff line number Diff line change
Expand Up @@ -895,6 +895,9 @@ async def _run(
# Await for an update
if not awaited_updates:
awaited_updates = [updates.__anext__()]
# pyre-fixme[6]: For 1st argument expected `Iterable[Variable[_FT (bound
# to Future[typing.Any])]]` but got `Union[List[Awaitable[Publication]],
# Set[typing.Any]]`.
done, awaited_updates = await asyncio.wait(awaited_updates, timeout=1)
if not done:
continue
Expand Down

0 comments on commit 44db9a7

Please sign in to comment.