initial stage

airflow/dags/antispam-batch.py

@@ -4,6 +4,7 @@ from datetime import timedelta, datetime
 import pendulum
 from airflow import DAG
 from airflow.hooks.base import BaseHook
+from airflow.models.baseoperator import chain
 from airflow.providers.cncf.kubernetes.operators.pod import KubernetesPodOperator
 from airflow.providers.cncf.kubernetes.secret import Secret
 
@@ -26,10 +27,6 @@ dag = DAG(
 )
 
 
-def print_hello():
-    print("Hello World!")
-
-
 secrets = [
     Secret(
         deploy_type='env',
@@ -67,4 +64,4 @@ task = KubernetesPodOperator(
 )
 
 # Set the task dependencies
-task >> print_hello
+chain(task)