were you able to solve the above usecase? I have figured the way to use cxOracle session pool along with ThreadPoolExecutor to fetch data in chunks from Oracle and push it to Snowflake. Please let me know if you have it figured end to end as i’m seeing some data duplication mostly due to incorrect session handling or cursor caching.