diff --git a/airflow/dags/antispam-batch.py b/airflow/dags/antispam-batch.py index c0b5e13..cf95696 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", "6" + "--parallelism", "36" ], secrets=secrets, is_delete_operator_pod=True,