initial stage

airflow/dags/antispam-batch.py

@@ -50,13 +50,13 @@ task = KubernetesPodOperator(
     image='gbloisi/curation:1.0.0',
     image_pull_policy="Always",
     cmds=['python3'],
-    arguments=['/antispam-batch.py',
-               "--opensearch.host", conn.host,
-               "--opensearch.port", str(conn.port),
-               "--openai.host", "local-ai.kg-airflow.dev-1.eosc.intranet",
-               "--openai.port", "8000",
-               "--parallelism", "8"
-               ],
+    # arguments=['/antispam-batch.py',
+    #            "--opensearch.host", conn.host,
+    #            "--opensearch.port", str(conn.port),
+    #            "--openai.host", "local-ai.kg-airflow.dev-1.eosc.intranet",
+    #            "--openai.port", "8000",
+    #            "--parallelism", "8"
+    #            ],
     secrets=secrets,
     is_delete_operator_pod=True,
     in_cluster=True,