kombu icon indicating copy to clipboard operation
kombu copied to clipboard

Kombu does correct support multi-threading sqla broker

Open CrazyLionHeart opened this issue 4 years ago • 2 comments

In case running Celery with sqla+postgresql+psycopg2 broker with prefork model I facing with problem - all broker connection is died.

In logs we found error - This session in "prepared" state; no further SQL can be emmited within this transaction.

Short research show sqla broker does not use thread-local session object - https://docs.sqlalchemy.org/en/14/orm/contextual.html

CrazyLionHeart avatar Oct 01 '21 20:10 CrazyLionHeart

Hey @CrazyLionHeart :wave:, Thank you for opening an issue. We will get back to you as soon as we can. Also, check out our Open Collective and consider backing us - every little helps!

We also offer priority support for our sponsors. If you require immediate assistance please consider sponsoring us.

yeah the broker still need work on SQLA 1.4 release. we just added basic compatibility

auvipy avatar Oct 03 '21 06:10 auvipy