removed castor recon

dags/imageflow_dag.py

@@ -294,19 +294,19 @@ def imageflow_dag(**dag_input):
     
     
 
-    castor_image_reconstruction_task = KubernetesPodOperator(
-    namespace="airflow",
-    image="saumitra9946/castor-v3.1.1:2",
-    name="castor_image_reconstruction_task",
-    task_id="castor_image_reconstruction_task",
-    is_delete_operator_pod=True,
-    volumes=[gate_volume, castor_volume, gate_output_pipeline_volume],
-    volume_mounts=[gate_volume_mount, castor_volume_mount, gate_output_pipeline_volume_mount],
-    cmds=[f"{Variable.get('base_output_path')}/castor_reconstruction.sh"],
-    arguments=[f"{Variable.get('base_output_path')}"],
-    security_context = {"runAsNonRoot": False},
-    get_logs=True,
-    )
+    # castor_image_reconstruction_task = KubernetesPodOperator(
+    # namespace="airflow",
+    # image="saumitra9946/castor-v3.1.1:2",
+    # name="castor_image_reconstruction_task",
+    # task_id="castor_image_reconstruction_task",
+    # is_delete_operator_pod=True,
+    # volumes=[gate_volume, castor_volume, gate_output_pipeline_volume],
+    # volume_mounts=[gate_volume_mount, castor_volume_mount, gate_output_pipeline_volume_mount],
+    # cmds=[f"{Variable.get('base_output_path')}/castor_reconstruction.sh"],
+    # arguments=[f"{Variable.get('base_output_path')}"],
+    # security_context = {"runAsNonRoot": False},
+    # get_logs=True,
+    # )
 
 
     def get_image_statistics(image_3d):