def teardown(self):
        """Teardown process executed on each process/worker after processing ends.
        This is needed for tasks like closing connections to end-points.
        """
Teardown process executed on each process/worker after processing ends.
        This is needed for tasks like closing connections to end-points.
        
src/datachain/lib/udf.py