diff --git a/flytekit/remote/remote.py b/flytekit/remote/remote.py index 2cb8103647..2c4f836a4a 100644 --- 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(