const chunkSize = 1000;

            for (let i = 0; i < Math.ceil(personsToAddToSegment.length / chunkSize); i++) {
                const chunk = personsToAddToSegment.slice(i * chunkSize, (i + 1) * chunkSize);

                const addResponse = await fetch(
                    `https://track.customer.io/api/v1/segments/${cohort.segmentId}/add_customers?id_type=email`,
                    {
                        method: "POST",
                        headers: {
                            Authorization: `Basic ${Buffer.from(`${environment.CUSTOMER_IO_SITE_ID}:${environment.CUSTOMER_IO_TRACK_API_KEY}`).toString("base64")}`,
                        },
                        body: JSON.stringify({
                            ids: chunk.map((person) => person.properties.email),
                        }),
                    },
                );

                if (!addResponse.ok) {
                    const text = await addResponse.text();

                    console.log("Failed to add persons to segment", text);

                    continue;
                }

                console.log(`Added ${chunk.length} persons to segment for cohort ${cohort.cohortId}.`);

                try {
                    await db.insert(schema.cohortPersonsTable).values(
                        chunk.map((person) => ({
                            cohortId: cohort.cohortId,
                            userId: person.uuid,
                        })),
                    );
                } catch (error) {
                    console.log("Failed to add persons to cohort persons in db", error);
                }
            }

            const chunkSize = 1000;

            for (let i = 0; i < Math.ceil(personsToAddToSegment.length / chunkSize); i++) {
                const chunk = personsToAddToSegment.slice(i * chunkSize, (i + 1) * chunkSize);

                const addResponse = await fetch(
                    `https://track.customer.io/api/v1/segments/${cohort.segmentId}/add_customers?id_type=email`,
                    {
                        method: "POST",
                        headers: {
                            Authorization: `Basic ${Buffer.from(`${environment.CUSTOMER_IO_SITE_ID}:${environment.CUSTOMER_IO_TRACK_API_KEY}`).toString("base64")}`,
                        },
                        body: JSON.stringify({
                            ids: chunk.map((person) => person.properties.email),
                        }),
                    },
                );

                if (!addResponse.ok) {
                    const text = await addResponse.text();

                    console.log("Failed to add persons to segment", text);

                    continue;
                }

                console.log(`Added ${chunk.length} persons to segment for cohort ${cohort.cohortId}.`);

                try {
                    await db.insert(schema.cohortPersonsTable).values(
                        chunk.map((person) => ({
                            cohortId: cohort.cohortId,
                            userId: person.uuid,
                        })),
                    );
                } catch (error) {
                    console.log("Failed to add persons to cohort persons in db", error);
                }
            }