Arkindex import task

requires common!32

arkindex_tasks/__init__.py

@@ -13,6 +13,12 @@ else:
     default_working_dir = Path(tempfile.mkdtemp())
 
 
+def _get_id(element):
+    if isinstance(element, dict) and element.get('id'):
+        return element['id']
+    return str(element)
+
+
 def dump_elements(file_path=None, **elements_lists):
     """
     Helper method to write a list of elements in task artifacts directory
@@ -24,7 +30,7 @@ def dump_elements(file_path=None, **elements_lists):
 
     elements = []
     for elt_type in elements_lists:
-        elements_ids = elements_lists[elt_type]
+        elements_ids = list(map(_get_id, elements_lists[elt_type]))
         elements.extend([
             {
                 "type": elt_type,