uranusjr commented on issue #64620: URL: https://github.com/apache/airflow/issues/64620#issuecomment-4234789293
@kalluripradeep I don’t think we want to swap the call out to threading.Lock; this would make all async calls blocking even if they are used in the same event loop. Instead, I think we should only lock in the sync calls. Reading what CommsDecoder (the equivalent used in task workers) does, I thought it’d be possible to add the threading lock on top of the asyncio lock, but when I did that (https://github.com/apache/airflow/pull/64882), it’s reported the triggerer would enter a state where it no longer takes any triggers. I think that needs fixing too. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
