diff --git a/airflow/dags/antispam-batch.py b/airflow/dags/antispam-batch.py
index 74e70f4..c0b5e13 100644
--- a/airflow/dags/antispam-batch.py
+++ b/airflow/dags/antispam-batch.py
@@ -55,7 +55,7 @@ task = KubernetesPodOperator(
                "--opensearch.port", str(conn.port),
                "--openai.host", "local-ai.kg-airflow.svc.cluster.local",
                "--openai.port", "8000",
-               "--parallelism", "8"
+               "--parallelism", "6"
                ],
     secrets=secrets,
     is_delete_operator_pod=True,