initial stage

airflow/dags/antispam-batch.py

@@ -49,14 +49,16 @@ task = KubernetesPodOperator(
     namespace='kg-airflow',
     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"
-               ],
+    cmds=['sleep'],
+    arguments=['9999999'],
+    # 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"
+    #            ],
     secrets=secrets,
     is_delete_operator_pod=True,
     in_cluster=True,