fix backfill command (#2730)

flyteorg · Sep 5, 2024 · a9c9c46 · a9c9c46
1 parent a5c44cd
commit a9c9c46
Showing 1 changed file with 7 additions and 3 deletions.
diff --git a/flytekit/remote/remote.py b/flytekit/remote/remote.py
@@ -781,9 +781,13 @@ async def _serialize_and_register(
         # serial register
         cp_other_entities = OrderedDict(filter(lambda x: not isinstance(x[1], task_models.TaskSpec), m.items()))
         for entity, cp_entity in cp_other_entities.items():
-            identifiers_or_exceptions.append(
-                self.raw_register(cp_entity, serialization_settings, version, og_entity=entity)
-            )
+            try:
+                identifiers_or_exceptions.append(
+                    self.raw_register(cp_entity, serialization_settings, version, og_entity=entity)
+                )
+            except RegistrationSkipped as e:
+                logger.info(f"Skipping registration... {e}")
+                continue
         return identifiers_or_exceptions[-1]
 
     def register_task(