issue_comments: 939079727

This data as json

html_url issue_url id node_id user created_at updated_at author_association body reactions issue performed_via_github_app
https://github.com/simonw/datasette/pull/1481#issuecomment-939079727 https://api.github.com/repos/simonw/datasette/issues/1481 939079727 IC_kwDOBm6k_c43-Tgv 9599 2021-10-08T19:50:52Z 2021-10-08T19:50:52Z OWNER

And here's the relevant Janus code: https://github.com/aio-libs/janus/blob/d7970f8b76bcac2e087067ca4575ac845e481874/janus/init.py#L24-L42

```python class Queue(Generic[T]): def init(self, maxsize: int = 0) -> None: self._loop = current_loop() self._maxsize = maxsize

    self._init(maxsize)

    self._unfinished_tasks = 0

    self._sync_mutex = threading.Lock()
    self._sync_not_empty = threading.Condition(self._sync_mutex)
    self._sync_not_full = threading.Condition(self._sync_mutex)
    self._all_tasks_done = threading.Condition(self._sync_mutex)

    self._async_mutex = asyncio.Lock()
    # "loop argument must agree with lock" exception is raised here:
    self._async_not_empty = asyncio.Condition(self._async_mutex)
    self._async_not_full = asyncio.Condition(self._async_mutex)
    self._finished = asyncio.Event()
    self._finished.set()

```

 
{
    "total_count": 0,
    "+1": 0,
    "-1": 0,
    "laugh": 0,
    "hooray": 0,
    "confused": 0,
    "heart": 0,
    "rocket": 0,
    "eyes": 0
}
 1020436713