Close the thread-local client (call on worker exit).
()
| 738 | |
| 739 | |
| 740 | def close_dirty_client(): |
| 741 | """Close the thread-local client (call on worker exit).""" |
| 742 | client = getattr(_thread_local, 'dirty_client', None) |
| 743 | if client is not None: |
| 744 | client.close() |
| 745 | _thread_local.dirty_client = None |
| 746 | |
| 747 | |
| 748 | async def close_dirty_client_async(): |