Fix issues with logging contextvars #31
Conversation
clean_python/dramatiq/async_actor.py
Outdated
| async def wrapped_coro() -> R: | ||
| for ctx_var, value in context_dump: | ||
| ctx_var.set(value) |
There was a problem hiding this comment.
Ik begin langzamerhand een Paracetamol nodig te hebben, maar ctx_var hééft deze value toch al? Moet in een andere context niet een hele nieuwe ContextVar worden gemaakt met dezelfde waarde?
There was a problem hiding this comment.
Het is een raar fenomeen die contextvars. Maar het werkt echt zo: je maakt een globale ContextVar instantie aan, die een andere waarde kan hebben binnen verschillende contexten.
Een andere thread is een andere context, dacht ik.
Maar, wat blijkt, het is default gedrag van run_coroutine_threadsafe om de context te propageren, ook naar een andere thread. Dus wat ik hier doe is al in asyncio geimplementeerd. Ik heb deze wijziging dus teruggedraaid en inderdaad: de test die ik heb geschreven werkt nog steeds.
No description provided.