Курсор. Обработка данных в параллельных процессах

with concurrent.futures.ThreadPoolExecutor(max_processes) as executor:
        while True:
            data_batch = []
            tasks = []
            
            cursor.execute(query)
            rows = cursor.fetchone()
 
            if not rows:
                break
            
            for row in cursor:
                data_batch.append(row)
 
                if len(data_batch) == batch_size:
                    task = executor.submit(process_batch, data_batch.copy())
                    tasks.append(task)
                    data_batch = []
            
            # остаток записей меньше batch_size
            if data_batch:                
                task = executor.submit(process_batch, data_batch.copy())
                tasks.append(task)
                data_batch = [] 
           
            for task in concurrent.futures.as_completed(tasks):               
                result = task.result()

try:
        #make your code
except Exception as e:
        print(repr(e))

   cursor.execute(query)
    records = cursor.fetchall()
    
    record_chunks = [records[i:i + batch_size] for i in range(0, len(records), batch_size)]
    
    pool = multiprocessing.Pool(processes=max_processes)
 
    pool.map(process_batch, record_chunks)
 
    pool.close()
    pool.join()
 
    connection.commit()
    cursor.close()    
    connection.close()