Ошибка многопроцессорности и пула соединений: невозможно выбрать объект «psycopg2.extensions.connection»

Я пытаюсь передать объект базы данных, который использует пул соединений в Postgres, другому объекту класса, но продолжаю получать ошибку.

if __name__ == "__main__":
cores = calculate_number_of_cores()
pretty_print(f"Number of cores ==> {cores}")

db_manager = DatabaseManager()
with ProcessPoolExecutor(cores) as executor:
    while True:
        if LOCAL_RUN:
            pretty_print("ALERT: Doing a local run of the automation with limited capabilities.")

        list_of_clients = db_manager.get_clients()
        print(list_of_clients)
        random.shuffle(list_of_clients)

        list_of_not_attempted_clients_domains = db_manager.get_not_attempted_domains_that_matches_random_client_tags()
        group_of_clients_handlers = {}
        pretty_print(list_of_not_attempted_clients_domains)

        # no matches
        if not list_of_not_attempted_clients_domains:
            sleep = 60 * 10
            pretty_print(f'No matches found. Sleeping for {sleep}s')
            time.sleep(sleep)
            continue

        for client in list_of_clients:
            client_id = client[0]
            client_name = client[1]
            group_of_clients_handlers[client_id] = [ClientsHandler(db_manager), client_name]

        try:
            list(executor.map(
                partial(run, group_of_clients_handlers),
                list_of_not_attempted_clients_domains
            ))
            # for not_attempted_clients_domains in list_of_not_attempted_clients_domains:
            #     futures = executor.submit(run(group_of_clients_handlers, not_attempted_clients_domains))
            #     for future in concurrent.futures.as_completed(futures):
            #         pretty_print("Loading futures....")
            #         print(future.result())

            time.sleep(60)
            pretty_print("sleeping for 60secs")
        except Exception as err:
            pretty_print(err)

Я использую многопроцессорный модуль в Python. Моя цель — иметь готовые соединения, которые мы используем для каждого запроса к базе данных, вместо того, чтобы всегда подключаться к базе данных для каждого выполнения или процесса.

Я должен передать db_manager функции run, так как я не хочу создавать там новое соединение. Но из-за этого я получаю сообщение об ошибке: невозможно выбрать объект «psycopg2.extensions.connection».

Я даже не знаю точно, что это значит. Единственное, что я знаю, это то, что когда я вручную отправляю функцию run исполнителю, код работает правильно. Это закомментированный код.

Я не знаю другого способа справиться с этим. Я вроде как знаю, откуда возникает ошибка, но как ее решить, чтобы она не мешала моей настройке, — это такая боль.