diff --git a/echo-side/dags/monitor.py b/echo-side/dags/monitor.py index d2135c9..087fa48 100644 --- a/echo-side/dags/monitor.py +++ b/echo-side/dags/monitor.py @@ -5,12 +5,12 @@ from airflow.models import Variable from datetime import timedelta -from kubernetes.client import models -from datetime import datetime +# from kubernetes.client import models +# from datetime import datetime -# Create k8s storage mount for large, persistent NFS disk space +# # Create k8s storage mount for large, persistent NFS disk space -volume_dss_mount = models.V1VolumeMount(name="logs-volume", mount_path="/lsst-backup-logs", sub_path=None, read_only=False,) +# volume_dss_mount = models.V1VolumeMount(name="logs-volume", mount_path="/lsst-backup-logs", sub_path=None, read_only=False,) # Define default arguments for the DAG default_args = { @@ -40,7 +40,7 @@ 'ECHO_S3_SECRET_KEY': Variable.get("ECHO_S3_SECRET_KEY"), }, dag=dag, - volume_mounts=[volume_dss_mount], + mounts=["/lsst-backup-logs:/lsst-backup-logs"], get_logs=True, )