Fix file_type

FAIRDataPipeline · Mar 29, 2022 · 6da168b · 6da168b
1 parent 2259ecc
commit 6da168b
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/data_pipeline_api/link.py b/data_pipeline_api/link.py
@@ -22,6 +22,8 @@ def resolve_write(
         file_type = "netcdf"
     # Get metadata from config
     write = handle["yaml"]["write"][index]
+    if write["file_type"]:
+        file_type = write["file_type"]
     write_data_product = write["data_product"]
     write_version = write["use"]["version"]
     description = write["description"]