Skip to content

DiagnosticPublisher attempts to use the main asyncio event loop from worker threads (which fails) #336

Description

@pavel-kirienko

Here, the call to ensure_future is invalid because emit can be invoked from any thread while we must use the asyncio loop from the node thread:

self._fut = asyncio.ensure_future(self._publish(dcs_rec))

Related: #334

Metadata

Metadata

Assignees

No one assigned

    Type

    No type

    Projects

    No projects

      Milestone

      No milestone

      Relationships

      None yet

      Development

      No branches or pull requests

      Issue actions