Added Pytest airflow

Author: gmcjy

dags/Dockerfile

@@ -0,0 +1,10 @@
+FROM python:3.8-slim-buster
+
+WORKDIR /app
+
+# COPY requirements.txt requirements.txt
+# RUN pip3 install -r requirements.txt
+
+COPY . .
+
+CMD [ "python3", "-m" , "test.py"]

dags/example_pod.py

@@ -44,7 +44,23 @@
         get_logs=True
     )
 
+
+    pytest = KubernetesPodOperator(
+        namespace='default',
+        image="python-docker:test",
+        image_pull_policy="IfNotPresent",
+        name="Pytest_Abc",
+        task_id="Python_test",
+        dag=dag,
+        is_delete_operator_pod=False,
+        in_cluster=True,
+        startup_timeout_seconds=600,
+        get_logs=True
+    )
+
     end = DummyOperator(task_id='end', dag=dag, trigger_rule='all_success')
 
-    start >> test >> end
+    start >> test 
+    start >> pytest
+    pytest >> end
 

dags/python_print.yaml

@@ -0,0 +1,11 @@
+apiVersion: v1
+kind: Pod
+metadata:
+  name: abc-python-cli
+spec:
+  containers:
+  - name: abc-python-cli
+    image: python-docker:test
+    command: ["python3","-m","test"]
+    imagePullPolicy: IfNotPresent
+  restartPolicy: Always

dags/test.py

@@ -0,0 +1,4 @@
+
+if __name__ == '__main__':
+	print("ABC")
+	print("*"*100)