@@ -141,6 +141,7 @@ def create_geonode_resource(
141141 execution_id : str ,
142142 resource_type : Dataset = Dataset ,
143143 asset = None ,
144+ custom = {},
144145 ):
145146 """
146147 Base function to create the resource into geonode. Each handler can specify
@@ -171,7 +172,8 @@ def create_geonode_resource(
171172 resource_type = resource_type ,
172173 defaults = self .generate_resource_payload (
173174 layer_name , alternate , asset , _exec , workspace
174- )
175+ ),
176+ custom = custom ,
175177 )
176178
177179 saved_dataset .refresh_from_db ()
@@ -214,7 +216,9 @@ def overwrite_geonode_resource(
214216 alternate : str ,
215217 execution_id : str ,
216218 resource_type : Dataset = Dataset ,
217- files = None ,
219+ asset = None ,
220+ custom = {},
221+
218222 ):
219223 dataset = resource_type .objects .filter (alternate__icontains = alternate )
220224
@@ -227,7 +231,7 @@ def overwrite_geonode_resource(
227231 dataset = dataset .first ()
228232
229233 dataset = resource_manager .update (
230- dataset .uuid , instance = dataset , files = files
234+ dataset .uuid , instance = dataset , files = asset . location
231235 )
232236
233237 self .handle_xml_file (dataset , _exec )
@@ -240,7 +244,7 @@ def overwrite_geonode_resource(
240244 f"The dataset required { alternate } does not exists, but an overwrite is required, the resource will be created"
241245 )
242246 return self .create_geonode_resource (
243- layer_name , alternate , execution_id , resource_type , files
247+ layer_name , alternate , execution_id , resource_type , asset , custom = custom ,
244248 )
245249 elif not dataset .exists () and not _overwrite :
246250 logger .warning (
0 commit comments