debugging issues with git parameters

dags/imageflow_dag.py

@@ -93,17 +93,6 @@ default_args = {
 @dag(start_date=datetime(2021, 1,1), schedule_interval='@daily', catchup=False, default_args=default_args,)
 def imageflow_dag(**dag_input):
 
-
-    # Set the base path and base output path default values
-
-    run_id = time.strftime("%Y-%m-%d--%H-%M-%S", time.gmtime())
-        
-    base_path = "/scan_params/" + run_id
-    base_output_path = "/gate_output_pipeline/" + run_id
-    
-    Variable.set(key="base_path", value=base_path)
-    Variable.set(key="base_output_path", value=base_output_path)
-    Variable.set(key="run_id", value=run_id)
     
     # Create gate volume and volume mounts
     gate_volume = k8s.V1Volume(name="imageflow-gate-volume",persistent_volume_claim=k8s.V1PersistentVolumeClaimVolumeSource(claim_name="gate-disk"))
@@ -215,6 +204,13 @@ def imageflow_dag(**dag_input):
         Returns:
             int: The return value indicating the success of the function (always 0 in this case)
         """
+        
+        base_path = "/scan_params/" + kwargs['dag_run'].conf.get('run_id') 
+        base_output_path = "/gate_output_pipeline/" + kwargs['dag_run'].conf.get('run_id') 
+        
+        Variable.set(key="base_path", value=base_path)
+        Variable.set(key="base_output_path", value=base_output_path)
+        
 
         # Create the base path directory if it doesn't exist
         if not os.path.exists(f"{Variable.get('base_path')}"):