just implemented the following code: _saEngine is just the sqlalchemy engine I use.
logging some vars to the terminal window in my routine and this listener, and I see that this routine is called in the worker after forking. from celery.signals import worker_process_init @worker_process_init.connect def mycelery_atfork(signal=None, sender=None, **named): _saEngine.dispose() -- You received this message because you are subscribed to the Google Groups "sqlalchemy" group. To unsubscribe from this group and stop receiving emails from it, send an email to sqlalchemy+unsubscr...@googlegroups.com. To post to this group, send email to sqlalchemy@googlegroups.com. Visit this group at https://groups.google.com/group/sqlalchemy. For more options, visit https://groups.google.com/d/optout.
